aboutsummaryrefslogtreecommitdiff
path: root/src/datastore
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-05-31 16:12:40 +0000
committerChristian Grothoff <christian@grothoff.org>2011-05-31 16:12:40 +0000
commite7ad9414f006c31e426b62db34d965c03a7edd79 (patch)
treef4b311110aa3ce6131abd15086bcc0bb4e57a05e /src/datastore
parenta1d67fd731c7fdf4af682e551d87b1c7cf6064c2 (diff)
downloadgnunet-e7ad9414f006c31e426b62db34d965c03a7edd79.tar.gz
gnunet-e7ad9414f006c31e426b62db34d965c03a7edd79.zip
skip here
Diffstat (limited to 'src/datastore')
-rw-r--r--src/datastore/datastore_api.c18
1 files 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,
585 struct GNUNET_DATASTORE_QueueEntry *qe; 585 struct GNUNET_DATASTORE_QueueEntry *qe;
586 586
587 h->in_receive = GNUNET_NO; 587 h->in_receive = GNUNET_NO;
588 if (h->skip_next_messages > 0)
589 {
590 h->skip_next_messages--;
591 process_queue (h);
592 return;
593 }
588 if (NULL == (qe = h->queue_head)) 594 if (NULL == (qe = h->queue_head))
589 { 595 {
590 GNUNET_break (0); 596 GNUNET_break (0);
@@ -778,12 +784,6 @@ process_status_message (void *cls,
778 int32_t status; 784 int32_t status;
779 int was_transmitted; 785 int was_transmitted;
780 786
781 if (h->skip_next_messages > 0)
782 {
783 h->skip_next_messages--;
784 process_queue (h);
785 return;
786 }
787 if (NULL == (qe = h->queue_head)) 787 if (NULL == (qe = h->queue_head))
788 { 788 {
789 GNUNET_break (0); 789 GNUNET_break (0);
@@ -1252,12 +1252,6 @@ process_result_message (void *cls,
1252 struct ResultContext rc; 1252 struct ResultContext rc;
1253 const struct DataMessage *dm; 1253 const struct DataMessage *dm;
1254 1254
1255 if (h->skip_next_messages > 0)
1256 {
1257 h->skip_next_messages--;
1258 process_queue (h);
1259 return;
1260 }
1261 if (msg == NULL) 1255 if (msg == NULL)
1262 { 1256 {
1263 qe = h->queue_head; 1257 qe = h->queue_head;