aboutsummaryrefslogtreecommitdiff
path: root/src/datastore
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2011-05-30 09:04:56 +0000
committerChristian Grothoff <christian@grothoff.org>2011-05-30 09:04:56 +0000
commit70da089f6a5d3cd9adc389133f5a4918e2b84e63 (patch)
tree9ae447aff892c1f6f32ab329475c51a26c2004e4 /src/datastore
parentf2a3397e7329b307d58b8cd3e4389bc7294db6af (diff)
downloadgnunet-70da089f6a5d3cd9adc389133f5a4918e2b84e63.tar.gz
gnunet-70da089f6a5d3cd9adc389133f5a4918e2b84e63.zip
fix
Diffstat (limited to 'src/datastore')
-rw-r--r--src/datastore/datastore_api.c5
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,