diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-05-31 16:12:40 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-05-31 16:12:40 +0000 |
commit | e7ad9414f006c31e426b62db34d965c03a7edd79 (patch) | |
tree | f4b311110aa3ce6131abd15086bcc0bb4e57a05e /src/datastore | |
parent | a1d67fd731c7fdf4af682e551d87b1c7cf6064c2 (diff) | |
download | gnunet-e7ad9414f006c31e426b62db34d965c03a7edd79.tar.gz gnunet-e7ad9414f006c31e426b62db34d965c03a7edd79.zip |
skip here
Diffstat (limited to 'src/datastore')
-rw-r--r-- | src/datastore/datastore_api.c | 18 |
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; |