diff options
author | Christian Grothoff <christian@grothoff.org> | 2011-05-30 09:04:56 +0000 |
---|---|---|
committer | Christian Grothoff <christian@grothoff.org> | 2011-05-30 09:04:56 +0000 |
commit | 70da089f6a5d3cd9adc389133f5a4918e2b84e63 (patch) | |
tree | 9ae447aff892c1f6f32ab329475c51a26c2004e4 /src/datastore | |
parent | f2a3397e7329b307d58b8cd3e4389bc7294db6af (diff) | |
download | gnunet-70da089f6a5d3cd9adc389133f5a4918e2b84e63.tar.gz gnunet-70da089f6a5d3cd9adc389133f5a4918e2b84e63.zip |
fix
Diffstat (limited to 'src/datastore')
-rw-r--r-- | src/datastore/datastore_api.c | 5 |
1 files changed, 5 insertions, 0 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index d861157d9..33b5cc232 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -764,6 +764,8 @@ process_status_message (void *cls, | |||
764 | _("Failed to receive status response from database.")); | 764 | _("Failed to receive status response from database.")); |
765 | if (was_transmitted == GNUNET_YES) | 765 | if (was_transmitted == GNUNET_YES) |
766 | do_disconnect (h); | 766 | do_disconnect (h); |
767 | else | ||
768 | process_queue (h); | ||
767 | return; | 769 | return; |
768 | } | 770 | } |
769 | GNUNET_assert (GNUNET_YES == qe->was_transmitted); | 771 | GNUNET_assert (GNUNET_YES == qe->was_transmitted); |
@@ -1234,6 +1236,8 @@ process_result_message (void *cls, | |||
1234 | NULL, 0, NULL, 0, 0, 0, | 1236 | NULL, 0, NULL, 0, 0, 0, |
1235 | GNUNET_TIME_UNIT_ZERO_ABS, 0); | 1237 | GNUNET_TIME_UNIT_ZERO_ABS, 0); |
1236 | } | 1238 | } |
1239 | else | ||
1240 | process_queue (h); | ||
1237 | return; | 1241 | return; |
1238 | } | 1242 | } |
1239 | if (ntohs(msg->type) == GNUNET_MESSAGE_TYPE_DATASTORE_DATA_END) | 1243 | if (ntohs(msg->type) == GNUNET_MESSAGE_TYPE_DATASTORE_DATA_END) |
@@ -1289,6 +1293,7 @@ process_result_message (void *cls, | |||
1289 | #endif | 1293 | #endif |
1290 | free_queue_entry (qe); | 1294 | free_queue_entry (qe); |
1291 | h->retry_time.rel_value = 0; | 1295 | h->retry_time.rel_value = 0; |
1296 | process_queue (h); | ||
1292 | if (rc.proc != NULL) | 1297 | if (rc.proc != NULL) |
1293 | rc.proc (rc.proc_cls, | 1298 | rc.proc (rc.proc_cls, |
1294 | &dm->key, | 1299 | &dm->key, |