diff options
author | Omar Tarabai <tarabai@devegypt.com> | 2014-05-16 12:54:18 +0000 |
---|---|---|
committer | Omar Tarabai <tarabai@devegypt.com> | 2014-05-16 12:54:18 +0000 |
commit | aeaf5c97d7d115d99f30e86be66c622b7a6ebf4f (patch) | |
tree | 13e3f037af1fc84188b91e6054153714ad3f631a /src/peerstore/peerstore_common.c | |
parent | 369811cfb47a51f240c7c4872e29c6eccd21fb0c (diff) | |
download | gnunet-aeaf5c97d7d115d99f30e86be66c622b7a6ebf4f.tar.gz gnunet-aeaf5c97d7d115d99f30e86be66c622b7a6ebf4f.zip |
towards peerstore iterate
Diffstat (limited to 'src/peerstore/peerstore_common.c')
-rw-r--r-- | src/peerstore/peerstore_common.c | 12 |
1 files changed, 7 insertions, 5 deletions
diff --git a/src/peerstore/peerstore_common.c b/src/peerstore/peerstore_common.c index f8c6862de..6b8b80985 100644 --- a/src/peerstore/peerstore_common.c +++ b/src/peerstore/peerstore_common.c | |||
@@ -33,7 +33,8 @@ | |||
33 | * @param key record key string (can be NULL) | 33 | * @param key record key string (can be NULL) |
34 | * @param value record value BLOB (can be NULL) | 34 | * @param value record value BLOB (can be NULL) |
35 | * @param value_size record value size in bytes (set to 0 if value is NULL) | 35 | * @param value_size record value size in bytes (set to 0 if value is NULL) |
36 | * @param lifetime relative time after which the record expires | 36 | * @param expiry absolute time after which the record expires |
37 | * @param msg_type message type to be set in header | ||
37 | * @return pointer to record message struct | 38 | * @return pointer to record message struct |
38 | */ | 39 | */ |
39 | struct StoreRecordMessage * | 40 | struct StoreRecordMessage * |
@@ -42,7 +43,8 @@ PEERSTORE_create_record_message(const char *sub_system, | |||
42 | const char *key, | 43 | const char *key, |
43 | const void *value, | 44 | const void *value, |
44 | size_t value_size, | 45 | size_t value_size, |
45 | struct GNUNET_TIME_Relative lifetime) | 46 | struct GNUNET_TIME_Absolute expiry, |
47 | uint16_t msg_type) | ||
46 | { | 48 | { |
47 | struct StoreRecordMessage *srm; | 49 | struct StoreRecordMessage *srm; |
48 | size_t ss_size; | 50 | size_t ss_size; |
@@ -61,9 +63,9 @@ PEERSTORE_create_record_message(const char *sub_system, | |||
61 | value_size; | 63 | value_size; |
62 | srm = GNUNET_malloc(request_size); | 64 | srm = GNUNET_malloc(request_size); |
63 | srm->header.size = htons(request_size); | 65 | srm->header.size = htons(request_size); |
64 | srm->header.type = htons(GNUNET_MESSAGE_TYPE_PEERSTORE_STORE); | 66 | srm->header.type = htons(msg_type); |
65 | srm->key_size = htons(key_size); | 67 | srm->key_size = htons(key_size); |
66 | srm->lifetime = lifetime; | 68 | srm->expiry = expiry; |
67 | if(NULL == peer) | 69 | if(NULL == peer) |
68 | srm->peer_set = htons(GNUNET_NO); | 70 | srm->peer_set = htons(GNUNET_NO); |
69 | else | 71 | else |
@@ -116,7 +118,7 @@ PEERSTORE_parse_record_message(const struct GNUNET_MessageHeader *message) | |||
116 | record->peer = GNUNET_new(struct GNUNET_PeerIdentity); | 118 | record->peer = GNUNET_new(struct GNUNET_PeerIdentity); |
117 | memcpy(record->peer, &srm->peer, sizeof(struct GNUNET_PeerIdentity)); | 119 | memcpy(record->peer, &srm->peer, sizeof(struct GNUNET_PeerIdentity)); |
118 | } | 120 | } |
119 | record->lifetime = srm->lifetime; | 121 | record->expiry = srm->expiry; |
120 | dummy = (char *)&srm[1]; | 122 | dummy = (char *)&srm[1]; |
121 | if(ss_size > 0) | 123 | if(ss_size > 0) |
122 | { | 124 | { |