aboutsummaryrefslogtreecommitdiff
path: root/src/datastore/datastore_api.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r--src/datastore/datastore_api.c8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c
index 2fb250b96..461440c85 100644
--- a/src/datastore/datastore_api.c
+++ b/src/datastore/datastore_api.c
@@ -475,7 +475,7 @@ make_queue_entry (struct GNUNET_DATASTORE_Handle *h, size_t msize,
475 GNUNET_assert (pos->response_proc != NULL); 475 GNUNET_assert (pos->response_proc != NULL);
476 /* move 'pos' element to head so that it will be 476 /* move 'pos' element to head so that it will be
477 * killed on 'NULL' call below */ 477 * killed on 'NULL' call below */
478 LOG (GNUNET_ERROR_TYPE_DEBUG, "Dropping request from datastore queue\n"); 478 LOG (GNUNET_ERROR_TYPE_DEBUG, "Dropping request from datastore queue\n");
479 GNUNET_CONTAINER_DLL_remove (h->queue_head, h->queue_tail, pos); 479 GNUNET_CONTAINER_DLL_remove (h->queue_head, h->queue_tail, pos);
480 GNUNET_CONTAINER_DLL_insert (h->queue_head, h->queue_tail, pos); 480 GNUNET_CONTAINER_DLL_insert (h->queue_head, h->queue_tail, pos);
481 GNUNET_STATISTICS_update (h->stats, 481 GNUNET_STATISTICS_update (h->stats,
@@ -691,7 +691,7 @@ process_queue (struct GNUNET_DATASTORE_Handle *h)
691 * @param emsg error message 691 * @param emsg error message
692 */ 692 */
693static void 693static void
694drop_status_cont (void *cls, int32_t result, 694drop_status_cont (void *cls, int32_t result,
695 struct GNUNET_TIME_Absolute min_expiration, 695 struct GNUNET_TIME_Absolute min_expiration,
696 const char *emsg) 696 const char *emsg)
697{ 697{
@@ -800,7 +800,7 @@ process_status_message (void *cls, const struct GNUNET_MessageHeader *msg)
800 h->retry_time = GNUNET_TIME_UNIT_ZERO; 800 h->retry_time = GNUNET_TIME_UNIT_ZERO;
801 process_queue (h); 801 process_queue (h);
802 if (rc.cont != NULL) 802 if (rc.cont != NULL)
803 rc.cont (rc.cont_cls, status, 803 rc.cont (rc.cont_cls, status,
804 GNUNET_TIME_absolute_ntoh (sm->min_expiration), 804 GNUNET_TIME_absolute_ntoh (sm->min_expiration),
805 emsg); 805 emsg);
806} 806}
@@ -1039,7 +1039,7 @@ GNUNET_DATASTORE_update (struct GNUNET_DATASTORE_Handle *h, uint64_t uid,
1039 cont = &drop_status_cont; 1039 cont = &drop_status_cont;
1040 LOG (GNUNET_ERROR_TYPE_DEBUG, 1040 LOG (GNUNET_ERROR_TYPE_DEBUG,
1041 "Asked to update entry %llu raising priority by %u and expiration to %s\n", 1041 "Asked to update entry %llu raising priority by %u and expiration to %s\n",
1042 uid, 1042 uid,
1043 (unsigned int) priority, 1043 (unsigned int) priority,
1044 GNUNET_STRINGS_absolute_time_to_string (expiration)); 1044 GNUNET_STRINGS_absolute_time_to_string (expiration));
1045 qc.sc.cont = cont; 1045 qc.sc.cont = cont;