diff options
author | Omar Tarabai <tarabai@devegypt.com> | 2014-05-17 16:57:49 +0000 |
---|---|---|
committer | Omar Tarabai <tarabai@devegypt.com> | 2014-05-17 16:57:49 +0000 |
commit | 7eb684ec9f93d52ebae09729fcf01c16580b5cb9 (patch) | |
tree | 72a44f01de2dc157f47a0a70ccb90d36154ddcbf /src/peerstore/peerstore_common.c | |
parent | 83c058a5ea11b6d7aa05cb71963c6063cb373603 (diff) | |
download | gnunet-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.c | 14 |
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 | */ |
40 | struct StoreRecordMessage * | 40 | struct StoreRecordMessage * |
41 | PEERSTORE_create_record_message(const char *sub_system, | 41 | PEERSTORE_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 |