diff options
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r-- | src/datastore/datastore_api.c | 20 |
1 files changed, 12 insertions, 8 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c index fab3bf0ca..2fb250b96 100644 --- a/src/datastore/datastore_api.c +++ b/src/datastore/datastore_api.c | |||
@@ -850,9 +850,10 @@ GNUNET_DATASTORE_put (struct GNUNET_DATASTORE_Handle *h, uint32_t rid, | |||
850 | union QueueContext qc; | 850 | union QueueContext qc; |
851 | 851 | ||
852 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 852 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
853 | "Asked to put %u bytes of data under key `%s' for %llu ms\n", size, | 853 | "Asked to put %u bytes of data under key `%s' for %s\n", size, |
854 | GNUNET_h2s (key), | 854 | GNUNET_h2s (key), |
855 | GNUNET_TIME_absolute_get_remaining (expiration).rel_value); | 855 | GNUNET_STRINGS_relative_time_to_string (GNUNET_TIME_absolute_get_remaining (expiration), |
856 | GNUNET_YES)); | ||
856 | msize = sizeof (struct DataMessage) + size; | 857 | msize = sizeof (struct DataMessage) + size; |
857 | GNUNET_assert (msize < GNUNET_SERVER_MAX_MESSAGE_SIZE); | 858 | GNUNET_assert (msize < GNUNET_SERVER_MAX_MESSAGE_SIZE); |
858 | qc.sc.cont = cont; | 859 | qc.sc.cont = cont; |
@@ -1037,8 +1038,10 @@ GNUNET_DATASTORE_update (struct GNUNET_DATASTORE_Handle *h, uint64_t uid, | |||
1037 | if (cont == NULL) | 1038 | if (cont == NULL) |
1038 | cont = &drop_status_cont; | 1039 | cont = &drop_status_cont; |
1039 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1040 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
1040 | "Asked to update entry %llu raising priority by %u and expiration to %llu\n", | 1041 | "Asked to update entry %llu raising priority by %u and expiration to %s\n", |
1041 | uid, (unsigned int) priority, (unsigned long long) expiration.abs_value); | 1042 | uid, |
1043 | (unsigned int) priority, | ||
1044 | GNUNET_STRINGS_absolute_time_to_string (expiration)); | ||
1042 | qc.sc.cont = cont; | 1045 | qc.sc.cont = cont; |
1043 | qc.sc.cont_cls = cont_cls; | 1046 | qc.sc.cont_cls = cont_cls; |
1044 | qe = make_queue_entry (h, sizeof (struct UpdateMessage), queue_priority, | 1047 | qe = make_queue_entry (h, sizeof (struct UpdateMessage), queue_priority, |
@@ -1268,8 +1271,9 @@ GNUNET_DATASTORE_get_for_replication (struct GNUNET_DATASTORE_Handle *h, | |||
1268 | union QueueContext qc; | 1271 | union QueueContext qc; |
1269 | 1272 | ||
1270 | GNUNET_assert (NULL != proc); | 1273 | GNUNET_assert (NULL != proc); |
1271 | LOG (GNUNET_ERROR_TYPE_DEBUG, "Asked to get replication entry in %llu ms\n", | 1274 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
1272 | (unsigned long long) timeout.rel_value); | 1275 | "Asked to get replication entry in %s\n", |
1276 | GNUNET_STRINGS_relative_time_to_string (timeout, GNUNET_YES)); | ||
1273 | qc.rc.proc = proc; | 1277 | qc.rc.proc = proc; |
1274 | qc.rc.proc_cls = proc_cls; | 1278 | qc.rc.proc_cls = proc_cls; |
1275 | qe = make_queue_entry (h, sizeof (struct GNUNET_MessageHeader), | 1279 | qe = make_queue_entry (h, sizeof (struct GNUNET_MessageHeader), |
@@ -1330,9 +1334,9 @@ GNUNET_DATASTORE_get_zero_anonymity (struct GNUNET_DATASTORE_Handle *h, | |||
1330 | GNUNET_assert (NULL != proc); | 1334 | GNUNET_assert (NULL != proc); |
1331 | GNUNET_assert (type != GNUNET_BLOCK_TYPE_ANY); | 1335 | GNUNET_assert (type != GNUNET_BLOCK_TYPE_ANY); |
1332 | LOG (GNUNET_ERROR_TYPE_DEBUG, | 1336 | LOG (GNUNET_ERROR_TYPE_DEBUG, |
1333 | "Asked to get %llu-th zero-anonymity entry of type %d in %llu ms\n", | 1337 | "Asked to get %llu-th zero-anonymity entry of type %d in %s\n", |
1334 | (unsigned long long) offset, type, | 1338 | (unsigned long long) offset, type, |
1335 | (unsigned long long) timeout.rel_value); | 1339 | GNUNET_STRINGS_relative_time_to_string (timeout, GNUNET_YES)); |
1336 | qc.rc.proc = proc; | 1340 | qc.rc.proc = proc; |
1337 | qc.rc.proc_cls = proc_cls; | 1341 | qc.rc.proc_cls = proc_cls; |
1338 | qe = make_queue_entry (h, sizeof (struct GetZeroAnonymityMessage), | 1342 | qe = make_queue_entry (h, sizeof (struct GetZeroAnonymityMessage), |