diff options
Diffstat (limited to 'src/datastore/datastore_api.c')
-rw-r--r-- | src/datastore/datastore_api.c | 22 |
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, |