From 268f5f028cbe9e554635d1ff09528eaa81fceaff Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Andreas=20=C3=96man?= Date: Tue, 20 Nov 2007 08:14:11 +0000 Subject: [PATCH] only put packet on storage queue if we actually stored it --- buffer.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) diff --git a/buffer.c b/buffer.c index 247b0e92..a33c46d8 100644 --- a/buffer.c +++ b/buffer.c @@ -294,9 +294,6 @@ storage_disk_enq(th_pkt_t *pkt) char fbuf[500]; int fd; - TAILQ_INSERT_TAIL(&store_disk_queue, pkt, pkt_disk_link); - store_disk_size += pkt->pkt_payloadlen; - if(curstore == NULL) { snprintf(fbuf, sizeof(fbuf), "%s/s%d", store_path, ++store_tally); @@ -315,6 +312,9 @@ storage_disk_enq(th_pkt_t *pkt) if(s != NULL) { + TAILQ_INSERT_TAIL(&store_disk_queue, pkt, pkt_disk_link); + store_disk_size += pkt->pkt_payloadlen; + s->ts_refcount++; pkt->pkt_storage = s; pkt->pkt_storage_offset = s->ts_offset;