aboutsummaryrefslogtreecommitdiff
path: root/src/peerstore/peerstore_common.c
diff options
context:
space:
mode:
authorOmar Tarabai <tarabai@devegypt.com>2014-05-17 16:57:49 +0000
committerOmar Tarabai <tarabai@devegypt.com>2014-05-17 16:57:49 +0000
commit7eb684ec9f93d52ebae09729fcf01c16580b5cb9 (patch)
tree72a44f01de2dc157f47a0a70ccb90d36154ddcbf /src/peerstore/peerstore_common.c
parent83c058a5ea11b6d7aa05cb71963c6063cb373603 (diff)
downloadgnunet-7eb684ec9f93d52ebae09729fcf01c16580b5cb9.tar.gz
gnunet-7eb684ec9f93d52ebae09729fcf01c16580b5cb9.zip
peestore: towards iterate functionality
Diffstat (limited to 'src/peerstore/peerstore_common.c')
-rw-r--r--src/peerstore/peerstore_common.c14
1 files changed, 8 insertions, 6 deletions
diff --git a/src/peerstore/peerstore_common.c b/src/peerstore/peerstore_common.c
index 2cb9d0077..5783973b6 100644
--- a/src/peerstore/peerstore_common.c
+++ b/src/peerstore/peerstore_common.c
@@ -36,14 +36,14 @@
36 * @param expiry absolute 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 * @param msg_type message type to be set in header
38 * @return pointer to record message struct 38 * @return pointer to record message struct
39 * 39 */
40struct StoreRecordMessage * 40struct StoreRecordMessage *
41PEERSTORE_create_record_message(const char *sub_system, 41PEERSTORE_create_record_message(const char *sub_system,
42 const struct GNUNET_PeerIdentity *peer, 42 const struct GNUNET_PeerIdentity *peer,
43 const char *key, 43 const char *key,
44 const void *value, 44 const void *value,
45 size_t value_size, 45 size_t value_size,
46 struct GNUNET_TIME_Absolute expiry, 46 struct GNUNET_TIME_Absolute *expiry,
47 uint16_t msg_type) 47 uint16_t msg_type)
48{ 48{
49 struct StoreRecordMessage *srm; 49 struct StoreRecordMessage *srm;
@@ -65,7 +65,8 @@ PEERSTORE_create_record_message(const char *sub_system,
65 srm->header.size = htons(request_size); 65 srm->header.size = htons(request_size);
66 srm->header.type = htons(msg_type); 66 srm->header.type = htons(msg_type);
67 srm->key_size = htons(key_size); 67 srm->key_size = htons(key_size);
68 srm->expiry = expiry; 68 if(NULL != expiry)
69 srm->expiry = *expiry;
69 if(NULL == peer) 70 if(NULL == peer)
70 srm->peer_set = htons(GNUNET_NO); 71 srm->peer_set = htons(GNUNET_NO);
71 else 72 else
@@ -83,7 +84,7 @@ PEERSTORE_create_record_message(const char *sub_system,
83 memcpy(dummy, value, value_size); 84 memcpy(dummy, value, value_size);
84 return srm; 85 return srm;
85 86
86}*/ 87}
87 88
88/** 89/**
89 * Creates a MQ envelope for a single record 90 * Creates a MQ envelope for a single record
@@ -103,7 +104,7 @@ PEERSTORE_create_record_mq_envelope(const char *sub_system,
103 const char *key, 104 const char *key,
104 const void *value, 105 const void *value,
105 size_t value_size, 106 size_t value_size,
106 struct GNUNET_TIME_Absolute expiry, 107 struct GNUNET_TIME_Absolute *expiry,
107 uint16_t msg_type) 108 uint16_t msg_type)
108{ 109{
109 struct StoreRecordMessage *srm; 110 struct StoreRecordMessage *srm;
@@ -124,7 +125,8 @@ PEERSTORE_create_record_mq_envelope(const char *sub_system,
124 value_size; 125 value_size;
125 ev = GNUNET_MQ_msg_extra(srm, msg_size, msg_type); 126 ev = GNUNET_MQ_msg_extra(srm, msg_size, msg_type);
126 srm->key_size = htons(key_size); 127 srm->key_size = htons(key_size);
127 srm->expiry = expiry; 128 if(NULL != expiry)
129 srm->expiry = *expiry;
128 if(NULL == peer) 130 if(NULL == peer)
129 srm->peer_set = htons(GNUNET_NO); 131 srm->peer_set = htons(GNUNET_NO);
130 else 132 else