From: Christian Grothoff Date: Tue, 31 May 2011 16:12:40 +0000 (+0000) Subject: skip here X-Git-Tag: initial-import-from-subversion-38251~18369 X-Git-Url: https://git.librecmc.org/?a=commitdiff_plain;h=e7ad9414f006c31e426b62db34d965c03a7edd79;p=oweals%2Fgnunet.git skip here --- 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;