From e7ad9414f006c31e426b62db34d965c03a7edd79 Mon Sep 17 00:00:00 2001 From: Christian Grothoff Date: Tue, 31 May 2011 16:12:40 +0000 Subject: [PATCH] skip here --- src/datastore/datastore_api.c | 18 ++++++------------ 1 file changed, 6 insertions(+), 12 deletions(-) diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index 350c35638..a3196530e 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c @@ -585,6 +585,12 @@ receive_cb (void *cls, struct GNUNET_DATASTORE_QueueEntry *qe; h->in_receive = GNUNET_NO; + if (h->skip_next_messages > 0) + { + h->skip_next_messages--; + process_queue (h); + return; + } if (NULL == (qe = h->queue_head)) { GNUNET_break (0); @@ -778,12 +784,6 @@ process_status_message (void *cls, int32_t status; int was_transmitted; - if (h->skip_next_messages > 0) - { - h->skip_next_messages--; - process_queue (h); - return; - } if (NULL == (qe = h->queue_head)) { GNUNET_break (0); @@ -1252,12 +1252,6 @@ process_result_message (void *cls, struct ResultContext rc; const struct DataMessage *dm; - if (h->skip_next_messages > 0) - { - h->skip_next_messages--; - process_queue (h); - return; - } if (msg == NULL) { qe = h->queue_head; -- 2.25.1