WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Affero General Public License for more details.
-
+
You should have received a copy of the GNU Affero General Public License
along with this program. If not, see <http://www.gnu.org/licenses/>.
*
*/
void
-PEERSTORE_hash_key (const char *sub_system,
- const struct GNUNET_PeerIdentity *peer,
- const char *key,
- struct GNUNET_HashCode *ret)
+PEERSTORE_hash_key(const char *sub_system,
+ const struct GNUNET_PeerIdentity *peer,
+ const char *key,
+ struct GNUNET_HashCode *ret)
{
size_t sssize;
size_t psize;
void *block;
void *blockptr;
- sssize = strlen (sub_system) + 1;
- psize = sizeof (struct GNUNET_PeerIdentity);
- ksize = strlen (key) + 1;
+ sssize = strlen(sub_system) + 1;
+ psize = sizeof(struct GNUNET_PeerIdentity);
+ ksize = strlen(key) + 1;
totalsize = sssize + psize + ksize;
- block = GNUNET_malloc (totalsize);
+ block = GNUNET_malloc(totalsize);
blockptr = block;
- GNUNET_memcpy (blockptr, sub_system, sssize);
+ GNUNET_memcpy(blockptr, sub_system, sssize);
blockptr += sssize;
- GNUNET_memcpy (blockptr, peer, psize);
+ GNUNET_memcpy(blockptr, peer, psize);
blockptr += psize;
- GNUNET_memcpy (blockptr, key, ksize);
- GNUNET_CRYPTO_hash (block, totalsize, ret);
- GNUNET_free (block);
+ GNUNET_memcpy(blockptr, key, ksize);
+ GNUNET_CRYPTO_hash(block, totalsize, ret);
+ GNUNET_free(block);
}
* @return pointer to record message struct
*/
struct GNUNET_MQ_Envelope *
-PEERSTORE_create_record_mq_envelope (const char *sub_system,
- const struct GNUNET_PeerIdentity *peer,
- const char *key,
- const void *value,
- size_t value_size,
- struct GNUNET_TIME_Absolute expiry,
- enum GNUNET_PEERSTORE_StoreOption options,
- uint16_t msg_type)
+PEERSTORE_create_record_mq_envelope(const char *sub_system,
+ const struct GNUNET_PeerIdentity *peer,
+ const char *key,
+ const void *value,
+ size_t value_size,
+ struct GNUNET_TIME_Absolute expiry,
+ enum GNUNET_PEERSTORE_StoreOption options,
+ uint16_t msg_type)
{
struct StoreRecordMessage *srm;
struct GNUNET_MQ_Envelope *ev;
size_t msg_size;
void *dummy;
- GNUNET_assert (NULL != sub_system);
- ss_size = strlen (sub_system) + 1;
+ GNUNET_assert(NULL != sub_system);
+ ss_size = strlen(sub_system) + 1;
if (NULL == key)
key_size = 0;
else
- key_size = strlen (key) + 1;
+ key_size = strlen(key) + 1;
msg_size = ss_size + key_size + value_size;
- ev = GNUNET_MQ_msg_extra (srm, msg_size, msg_type);
- srm->key_size = htons (key_size);
- srm->expiry = GNUNET_TIME_absolute_hton (expiry);
+ ev = GNUNET_MQ_msg_extra(srm, msg_size, msg_type);
+ srm->key_size = htons(key_size);
+ srm->expiry = GNUNET_TIME_absolute_hton(expiry);
if (NULL == peer)
- srm->peer_set = htons (GNUNET_NO);
+ srm->peer_set = htons(GNUNET_NO);
else
- {
- srm->peer_set = htons (GNUNET_YES);
- srm->peer = *peer;
- }
- srm->sub_system_size = htons (ss_size);
- srm->value_size = htons (value_size);
- srm->options = htonl (options);
+ {
+ srm->peer_set = htons(GNUNET_YES);
+ srm->peer = *peer;
+ }
+ srm->sub_system_size = htons(ss_size);
+ srm->value_size = htons(value_size);
+ srm->options = htonl(options);
dummy = &srm[1];
- GNUNET_memcpy (dummy, sub_system, ss_size);
+ GNUNET_memcpy(dummy, sub_system, ss_size);
dummy += ss_size;
- GNUNET_memcpy (dummy, key, key_size);
+ GNUNET_memcpy(dummy, key, key_size);
dummy += key_size;
- GNUNET_memcpy (dummy, value, value_size);
+ GNUNET_memcpy(dummy, value, value_size);
return ev;
}
* @return Pointer to record or NULL if error
*/
struct GNUNET_PEERSTORE_Record *
-PEERSTORE_parse_record_message (const struct StoreRecordMessage *srm)
+PEERSTORE_parse_record_message(const struct StoreRecordMessage *srm)
{
struct GNUNET_PEERSTORE_Record *record;
uint16_t req_size;
uint16_t value_size;
char *dummy;
- req_size = ntohs (srm->header.size) - sizeof (*srm);
- ss_size = ntohs (srm->sub_system_size);
- key_size = ntohs (srm->key_size);
- value_size = ntohs (srm->value_size);
+ req_size = ntohs(srm->header.size) - sizeof(*srm);
+ ss_size = ntohs(srm->sub_system_size);
+ key_size = ntohs(srm->key_size);
+ value_size = ntohs(srm->value_size);
if (ss_size + key_size + value_size != req_size)
- {
- GNUNET_break (0);
- return NULL;
- }
- record = GNUNET_new (struct GNUNET_PEERSTORE_Record);
- if (GNUNET_YES == ntohs (srm->peer_set))
- {
- record->peer = srm->peer;
- }
- record->expiry = GNUNET_TIME_absolute_ntoh (srm->expiry);
- dummy = (char *) &srm[1];
+ {
+ GNUNET_break(0);
+ return NULL;
+ }
+ record = GNUNET_new(struct GNUNET_PEERSTORE_Record);
+ if (GNUNET_YES == ntohs(srm->peer_set))
+ {
+ record->peer = srm->peer;
+ }
+ record->expiry = GNUNET_TIME_absolute_ntoh(srm->expiry);
+ dummy = (char *)&srm[1];
if (ss_size > 0)
- {
- record->sub_system = GNUNET_strdup (dummy);
- dummy += ss_size;
- }
+ {
+ record->sub_system = GNUNET_strdup(dummy);
+ dummy += ss_size;
+ }
if (key_size > 0)
- {
- record->key = GNUNET_strdup (dummy);
- dummy += key_size;
- }
+ {
+ record->key = GNUNET_strdup(dummy);
+ dummy += key_size;
+ }
if (value_size > 0)
- {
- record->value = GNUNET_malloc (value_size);
- GNUNET_memcpy (record->value,
- dummy,
- value_size);
- }
+ {
+ record->value = GNUNET_malloc(value_size);
+ GNUNET_memcpy(record->value,
+ dummy,
+ value_size);
+ }
record->value_size = value_size;
return record;
}
* @param record
*/
void
-PEERSTORE_destroy_record (struct GNUNET_PEERSTORE_Record *record)
+PEERSTORE_destroy_record(struct GNUNET_PEERSTORE_Record *record)
{
if (NULL != record->sub_system)
- GNUNET_free (record->sub_system);
+ GNUNET_free(record->sub_system);
if (NULL != record->key)
- GNUNET_free (record->key);
+ GNUNET_free(record->key);
if (NULL != record->value)
- {
- GNUNET_free (record->value);
- record->value = 0;
- }
- GNUNET_free (record);
+ {
+ GNUNET_free(record->value);
+ record->value = 0;
+ }
+ GNUNET_free(record);
}