diff options
Diffstat (limited to 'src/service/peerstore/peerstore_common.c')
-rw-r--r-- | src/service/peerstore/peerstore_common.c | 17 |
1 files changed, 3 insertions, 14 deletions
diff --git a/src/service/peerstore/peerstore_common.c b/src/service/peerstore/peerstore_common.c index e3bb77d86..5d4d06c0c 100644 --- a/src/service/peerstore/peerstore_common.c +++ b/src/service/peerstore/peerstore_common.c | |||
@@ -59,21 +59,9 @@ PEERSTORE_hash_key (const char *sub_system, | |||
59 | } | 59 | } |
60 | 60 | ||
61 | 61 | ||
62 | /** | ||
63 | * Creates a MQ envelope for a single record | ||
64 | * | ||
65 | * @param sub_system sub system string | ||
66 | * @param peer Peer identity (can be NULL) | ||
67 | * @param key record key string (can be NULL) | ||
68 | * @param value record value BLOB (can be NULL) | ||
69 | * @param value_size record value size in bytes (set to 0 if value is NULL) | ||
70 | * @param expiry time after which the record expires | ||
71 | * @param options options specific to the storage operation | ||
72 | * @param msg_type message type to be set in header | ||
73 | * @return pointer to record message struct | ||
74 | */ | ||
75 | struct GNUNET_MQ_Envelope * | 62 | struct GNUNET_MQ_Envelope * |
76 | PEERSTORE_create_record_mq_envelope (const char *sub_system, | 63 | PEERSTORE_create_record_mq_envelope (uint32_t rid, |
64 | const char *sub_system, | ||
77 | const struct GNUNET_PeerIdentity *peer, | 65 | const struct GNUNET_PeerIdentity *peer, |
78 | const char *key, | 66 | const char *key, |
79 | const void *value, | 67 | const void *value, |
@@ -106,6 +94,7 @@ PEERSTORE_create_record_mq_envelope (const char *sub_system, | |||
106 | srm->peer_set = htons (GNUNET_YES); | 94 | srm->peer_set = htons (GNUNET_YES); |
107 | srm->peer = *peer; | 95 | srm->peer = *peer; |
108 | } | 96 | } |
97 | srm->rid = rid; | ||
109 | srm->sub_system_size = htons (ss_size); | 98 | srm->sub_system_size = htons (ss_size); |
110 | srm->value_size = htons (value_size); | 99 | srm->value_size = htons (value_size); |
111 | srm->options = htonl (options); | 100 | srm->options = htonl (options); |