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.c22
1 files changed, 12 insertions, 10 deletions
diff --git a/src/datastore/datastore_api.c b/src/datastore/datastore_api.c
index 26e1e501d..31f7a997f 100644
--- a/src/datastore/datastore_api.c
+++ b/src/datastore/datastore_api.c
@@ -352,7 +352,11 @@ mq_error_handler (void *cls,
352 qc.rc.proc (qc.rc.proc_cls, 352 qc.rc.proc (qc.rc.proc_cls,
353 NULL, 353 NULL,
354 0, 354 0,
355 NULL, 0, 0, 0, 355 NULL,
356 0,
357 0,
358 0,
359 0,
356 GNUNET_TIME_UNIT_ZERO_ABS, 360 GNUNET_TIME_UNIT_ZERO_ABS,
357 0); 361 0);
358 break; 362 break;
@@ -468,7 +472,11 @@ GNUNET_DATASTORE_disconnect (struct GNUNET_DATASTORE_Handle *h,
468 qe->qc.rc.proc (qe->qc.rc.proc_cls, 472 qe->qc.rc.proc (qe->qc.rc.proc_cls,
469 NULL, 473 NULL,
470 0, 474 0,
471 NULL, 0, 0, 0, 475 NULL,
476 0,
477 0,
478 0,
479 0,
472 GNUNET_TIME_UNIT_ZERO_ABS, 480 GNUNET_TIME_UNIT_ZERO_ABS,
473 0); 481 0);
474 break; 482 break;
@@ -825,6 +833,7 @@ handle_data (void *cls,
825 ntohl (dm->type), 833 ntohl (dm->type),
826 ntohl (dm->priority), 834 ntohl (dm->priority),
827 ntohl (dm->anonymity), 835 ntohl (dm->anonymity),
836 ntohl (dm->replication),
828 GNUNET_TIME_absolute_ntoh (dm->expiration), 837 GNUNET_TIME_absolute_ntoh (dm->expiration),
829 GNUNET_ntohll (dm->uid)); 838 GNUNET_ntohll (dm->uid));
830} 839}
@@ -887,6 +896,7 @@ handle_data_end (void *cls,
887 0, 896 0,
888 0, 897 0,
889 0, 898 0,
899 0,
890 GNUNET_TIME_UNIT_ZERO_ABS, 900 GNUNET_TIME_UNIT_ZERO_ABS,
891 0); 901 0);
892} 902}
@@ -1022,8 +1032,6 @@ GNUNET_DATASTORE_put (struct GNUNET_DATASTORE_Handle *h,
1022 dm->priority = htonl (priority); 1032 dm->priority = htonl (priority);
1023 dm->anonymity = htonl (anonymity); 1033 dm->anonymity = htonl (anonymity);
1024 dm->replication = htonl (replication); 1034 dm->replication = htonl (replication);
1025 dm->reserved = htonl (0);
1026 dm->uid = GNUNET_htonll (0);
1027 dm->expiration = GNUNET_TIME_absolute_hton (expiration); 1035 dm->expiration = GNUNET_TIME_absolute_hton (expiration);
1028 dm->key = *key; 1036 dm->key = *key;
1029 GNUNET_memcpy (&dm[1], 1037 GNUNET_memcpy (&dm[1],
@@ -1226,13 +1234,7 @@ GNUNET_DATASTORE_remove (struct GNUNET_DATASTORE_Handle *h,
1226 env = GNUNET_MQ_msg_extra (dm, 1234 env = GNUNET_MQ_msg_extra (dm,
1227 size, 1235 size,
1228 GNUNET_MESSAGE_TYPE_DATASTORE_REMOVE); 1236 GNUNET_MESSAGE_TYPE_DATASTORE_REMOVE);
1229 dm->rid = htonl (0);
1230 dm->size = htonl (size); 1237 dm->size = htonl (size);
1231 dm->type = htonl (0);
1232 dm->priority = htonl (0);
1233 dm->anonymity = htonl (0);
1234 dm->uid = GNUNET_htonll (0);
1235 dm->expiration = GNUNET_TIME_absolute_hton (GNUNET_TIME_UNIT_ZERO_ABS);
1236 dm->key = *key; 1238 dm->key = *key;
1237 GNUNET_memcpy (&dm[1], 1239 GNUNET_memcpy (&dm[1],
1238 data, 1240 data,