aboutsummaryrefslogtreecommitdiff
path: root/src/peerstore/peerstore_common.c
diff options
context:
space:
mode:
authorOmar Tarabai <tarabai@devegypt.com>2014-05-16 12:54:18 +0000
committerOmar Tarabai <tarabai@devegypt.com>2014-05-16 12:54:18 +0000
commitaeaf5c97d7d115d99f30e86be66c622b7a6ebf4f (patch)
tree13e3f037af1fc84188b91e6054153714ad3f631a /src/peerstore/peerstore_common.c
parent369811cfb47a51f240c7c4872e29c6eccd21fb0c (diff)
downloadgnunet-aeaf5c97d7d115d99f30e86be66c622b7a6ebf4f.tar.gz
gnunet-aeaf5c97d7d115d99f30e86be66c622b7a6ebf4f.zip
towards peerstore iterate
Diffstat (limited to 'src/peerstore/peerstore_common.c')
-rw-r--r--src/peerstore/peerstore_common.c12
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 */
39struct StoreRecordMessage * 40struct 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 {