diff options
Diffstat (limited to 'src/fs/gnunet-service-fs_pr.h')
| -rw-r--r-- | src/fs/gnunet-service-fs_pr.h | 89 |
1 files changed, 41 insertions, 48 deletions
diff --git a/src/fs/gnunet-service-fs_pr.h b/src/fs/gnunet-service-fs_pr.h index f2e7bcf626..b68989be7a 100644 --- a/src/fs/gnunet-service-fs_pr.h +++ b/src/fs/gnunet-service-fs_pr.h @@ -201,33 +201,19 @@ typedef void (*GSF_PendingRequestReplyHandler) (void *cls, * @param rh_cls closure for rh * @return handle for the new pending request */ -struct GSF_PendingRequest *GSF_pending_request_create_ (enum - GSF_PendingRequestOptions - options, - enum GNUNET_BLOCK_Type - type, - const GNUNET_HashCode * - query, - const GNUNET_HashCode * - namespace, - const struct - GNUNET_PeerIdentity - *target, - const char *bf_data, - size_t bf_size, - uint32_t mingle, - uint32_t - anonymity_level, - uint32_t priority, - int32_t ttl, - GNUNET_PEER_Id - sender_pid, - const GNUNET_HashCode * - replies_seen, - unsigned int - replies_seen_count, - GSF_PendingRequestReplyHandler - rh, void *rh_cls); +struct GSF_PendingRequest * +GSF_pending_request_create_ (enum GSF_PendingRequestOptions options, + enum GNUNET_BLOCK_Type type, + const GNUNET_HashCode * query, + const GNUNET_HashCode * namespace, + const struct GNUNET_PeerIdentity *target, + const char *bf_data, size_t bf_size, + uint32_t mingle, uint32_t anonymity_level, + uint32_t priority, int32_t ttl, + GNUNET_PEER_Id sender_pid, + const GNUNET_HashCode * replies_seen, + unsigned int replies_seen_count, + GSF_PendingRequestReplyHandler rh, void *rh_cls); /** @@ -238,9 +224,10 @@ struct GSF_PendingRequest *GSF_pending_request_create_ (enum * @param replies_seen hash codes of replies that we've seen * @param replies_seen_count size of the replies_seen array */ -void GSF_pending_request_update_ (struct GSF_PendingRequest *pr, - const GNUNET_HashCode * replies_seen, - unsigned int replies_seen_count); +void +GSF_pending_request_update_ (struct GSF_PendingRequest *pr, + const GNUNET_HashCode * replies_seen, + unsigned int replies_seen_count); /** @@ -249,9 +236,8 @@ void GSF_pending_request_update_ (struct GSF_PendingRequest *pr, * @param pr pending request * @return associated public data */ -struct GSF_PendingRequestData *GSF_pending_request_get_data_ (struct - GSF_PendingRequest - *pr); +struct GSF_PendingRequestData * +GSF_pending_request_get_data_ (struct GSF_PendingRequest *pr); /** @@ -263,8 +249,9 @@ struct GSF_PendingRequestData *GSF_pending_request_get_data_ (struct * @param pra another pending request * @return GNUNET_OK if the requests are compatible */ -int GSF_pending_request_is_compatible_ (struct GSF_PendingRequest *pra, - struct GSF_PendingRequest *prb); +int +GSF_pending_request_is_compatible_ (struct GSF_PendingRequest *pra, + struct GSF_PendingRequest *prb); /** @@ -276,9 +263,9 @@ int GSF_pending_request_is_compatible_ (struct GSF_PendingRequest *pra, * @param buf where to copy the message (can be NULL) * @return number of bytes needed (if buf_size too small) or used */ -size_t GSF_pending_request_get_message_ (struct GSF_PendingRequest - *pr, size_t buf_size, - void *buf); +size_t +GSF_pending_request_get_message_ (struct GSF_PendingRequest *pr, + size_t buf_size, void *buf); /** @@ -287,8 +274,8 @@ size_t GSF_pending_request_get_message_ (struct GSF_PendingRequest * @param pr request to cancel * @param full_cleanup fully purge the request */ -void GSF_pending_request_cancel_ (struct GSF_PendingRequest *pr, - int full_cleanup); +void +GSF_pending_request_cancel_ (struct GSF_PendingRequest *pr, int full_cleanup); /** @@ -311,7 +298,8 @@ typedef int (*GSF_PendingRequestIterator) (void *cls, * @param it function to call for each request * @param cls closure for it */ -void GSF_iterate_pending_requests_ (GSF_PendingRequestIterator it, void *cls); +void +GSF_iterate_pending_requests_ (GSF_PendingRequestIterator it, void *cls); /** @@ -327,8 +315,9 @@ void GSF_iterate_pending_requests_ (GSF_PendingRequestIterator it, void *cls); * GNUNET_SYSERR if the message was malformed (close connection, * do not cache under any circumstances) */ -int GSF_handle_p2p_content_ (struct GSF_ConnectedPeer *cp, - const struct GNUNET_MessageHeader *message); +int +GSF_handle_p2p_content_ (struct GSF_ConnectedPeer *cp, + const struct GNUNET_MessageHeader *message); /** @@ -336,7 +325,8 @@ int GSF_handle_p2p_content_ (struct GSF_ConnectedPeer *cp, * * @param pr the pending request to process */ -void GSF_dht_lookup_ (struct GSF_PendingRequest *pr); +void +GSF_dht_lookup_ (struct GSF_PendingRequest *pr); /** @@ -360,20 +350,23 @@ typedef void (*GSF_LocalLookupContinuation) (void *cls, * @param cont function to call at the end * @param cont_cls closure for cont */ -void GSF_local_lookup_ (struct GSF_PendingRequest *pr, - GSF_LocalLookupContinuation cont, void *cont_cls); +void +GSF_local_lookup_ (struct GSF_PendingRequest *pr, + GSF_LocalLookupContinuation cont, void *cont_cls); /** * Setup the subsystem. */ -void GSF_pending_request_init_ (void); +void +GSF_pending_request_init_ (void); /** * Shutdown the subsystem. */ -void GSF_pending_request_done_ (void); +void +GSF_pending_request_done_ (void); #endif |