diff options
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r-- | src/datastore/datastore_api.c | 8 |
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 | */ |
693 | static void | 693 | static void |
694 | drop_status_cont (void *cls, int32_t result, | 694 | drop_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; |