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.c20
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),