aboutsummaryrefslogtreecommitdiff
path: root/src/datastore
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-05-30 15:48:47 +0000
committerChristian Grothoff <christian@grothoff.org>2011-05-30 15:48:47 +0000
commitd1ba1e15c1865919ed6d3cb43806e21e760039cf (patch)
treead5ca46a0c264b4cddefdeec3a124aa8acef4854 /src/datastore
parent8031aae4cff1190302330797d149c20cc1404b8a (diff)
downloadgnunet-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.c3
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