diff options
author | Omar Tarabai <tarabai@devegypt.com> | 2014-07-24 12:44:24 +0000 |
---|---|---|
committer | Omar Tarabai <tarabai@devegypt.com> | 2014-07-24 12:44:24 +0000 |
commit | c057bd312c783e0a2f3783dfd888a66f490b0a30 (patch) | |
tree | ff87b7bf7189a723045d7c851d2d383b786724ec /src/peerstore/gnunet-service-peerstore.c | |
parent | f2594744c121f45f3b36867b051220e7186d6f9b (diff) |
peerstore: doxygen
Diffstat (limited to 'src/peerstore/gnunet-service-peerstore.c')
-rw-r--r-- | src/peerstore/gnunet-service-peerstore.c | 52 |
1 files changed, 28 insertions, 24 deletions
diff --git a/src/peerstore/gnunet-service-peerstore.c b/src/peerstore/gnunet-service-peerstore.c index b7128dda5d..c93d2cc953 100644 --- a/src/peerstore/gnunet-service-peerstore.c +++ b/src/peerstore/gnunet-service-peerstore.c @@ -207,26 +207,29 @@ handle_client_disconnect (void *cls, * Function called by for each matching record. * * @param cls closure - * @param peer peer identity - * @param sub_system name of the GNUnet sub system responsible - * @param value stored value - * @param size size of stored value + * @param record peerstore record found + * @param emsg error message or NULL if no errors + * @return #GNUNET_YES to continue iteration */ -static int record_iterator(void *cls, - struct GNUNET_PEERSTORE_Record *record, - char *emsg) +static int +record_iterator (void *cls, + struct GNUNET_PEERSTORE_Record *record, + char *emsg) { struct GNUNET_SERVER_Client *client = cls; struct StoreRecordMessage *srm; - srm = PEERSTORE_create_record_message(record->sub_system, - record->peer, - record->key, - record->value, - record->value_size, - record->expiry, - GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE_RECORD); - GNUNET_SERVER_notification_context_unicast(nc, client, (struct GNUNET_MessageHeader *)srm, GNUNET_NO); + srm = + PEERSTORE_create_record_message(record->sub_system, + record->peer, + record->key, + record->value, + record->value_size, + record->expiry, + GNUNET_MESSAGE_TYPE_PEERSTORE_ITERATE_RECORD); + GNUNET_SERVER_notification_context_unicast (nc, client, + (struct GNUNET_MessageHeader *)srm, + GNUNET_NO); GNUNET_free(srm); return GNUNET_YES; } @@ -348,17 +351,18 @@ static void handle_iterate (void *cls, GNUNET_SERVER_receive_done(client, GNUNET_SYSERR); return; } - GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, "Iterate request: ss `%s', peer `%s', key `%s'\n", - record->sub_system, - (NULL == record->peer) ? "NULL" : GNUNET_i2s(record->peer), - (NULL == record->key) ? "NULL" : record->key); + GNUNET_log(GNUNET_ERROR_TYPE_DEBUG, + "Iterate request: ss `%s', peer `%s', key `%s'\n", + record->sub_system, + (NULL == record->peer) ? "NULL" : GNUNET_i2s(record->peer), + (NULL == record->key) ? "NULL" : record->key); GNUNET_SERVER_notification_context_add(nc, client); if(GNUNET_OK == db->iterate_records(db->cls, - record->sub_system, - record->peer, - record->key, - &record_iterator, - client)) + record->sub_system, + record->peer, + record->key, + &record_iterator, + client)) { endmsg = GNUNET_new(struct GNUNET_MessageHeader); endmsg->size = htons(sizeof(struct GNUNET_MessageHeader)); |