diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-05-30 15:48:47 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-05-30 15:48:47 +0000 |
commit | d1ba1e15c1865919ed6d3cb43806e21e760039cf (patch) | |
tree | ad5ca46a0c264b4cddefdeec3a124aa8acef4854 /src/datastore | |
parent | 8031aae4cff1190302330797d149c20cc1404b8a (diff) | |
download | gnunet-d1ba1e15c1865919ed6d3cb43806e21e760039cf.tar.gz gnunet-d1ba1e15c1865919ed6d3cb43806e21e760039cf.zip |
do not remove from queue if already transmitted
Diffstat (limited to 'src/datastore')
-rw-r--r-- | src/datastore/datastore_api.c | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index 07e48931e..9738588a7 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -465,7 +465,8 @@ make_queue_entry (struct GNUNET_DATASTORE_Handle *h, | |||
465 | pos = ret->next; | 465 | pos = ret->next; |
466 | while (pos != NULL) | 466 | while (pos != NULL) |
467 | { | 467 | { |
468 | if (pos->max_queue < h->queue_size) | 468 | if ( (pos->max_queue < h->queue_size) && |
469 | (pos->was_transmitted == GNUNET_NO) ) | ||
469 | { | 470 | { |
470 | GNUNET_assert (pos->response_proc != NULL); | 471 | GNUNET_assert (pos->response_proc != NULL); |
471 | /* move 'pos' element to head so that it will be | 472 | /* move 'pos' element to head so that it will be |