diff options
author | Julius Bünger <buenger@mytum.de> | 2018-09-20 01:04:17 +0200 |
---|---|---|
committer | Julius Bünger <buenger@mytum.de> | 2018-09-20 01:07:53 +0200 |
commit | 69f439525cabfd0b65d5875e49d306588587cb23 (patch) | |
tree | ba8200ce6dbb264021f42e05f2d119aa9e4917aa /src/rps/rps_api.c | |
parent | c50386476c7a79efd87d4b1b36f9c740d74dd9f8 (diff) |
Be a little bit more consistent in style
Diffstat (limited to 'src/rps/rps_api.c')
-rw-r--r-- | src/rps/rps_api.c | 16 |
1 files changed, 11 insertions, 5 deletions
diff --git a/src/rps/rps_api.c b/src/rps/rps_api.c index 00f817468..7afe21d3a 100644 --- a/src/rps/rps_api.c +++ b/src/rps/rps_api.c @@ -78,7 +78,7 @@ struct GNUNET_RPS_Handle /** - * Handler to single requests from the client. + * Handler for a single request from a client. */ struct GNUNET_RPS_Request_Handle { @@ -95,7 +95,12 @@ struct GNUNET_RPS_Request_Handle /** * The number of requested peers. */ - uint32_t num_peers; + uint32_t num_requests; + + /** + * @brief The Sampler for the client request + */ + struct RPS_Sampler *sampler; /** * The callback to be called when we receive an answer. @@ -131,6 +136,7 @@ struct cb_cls_pack struct GNUNET_CLIENT_Connection *service_conn; }; + /** * @brief Send a request to the service. * @@ -170,7 +176,7 @@ resend_requests_iterator (void *cls, uint32_t key, void *value) const struct GNUNET_RPS_Request_Handle *req_handle = value; (void) key; - send_request (h, req_handle->id, req_handle->num_peers); + send_request (h, req_handle->id, req_handle->num_requests); return GNUNET_YES; /* continue iterating */ } @@ -248,7 +254,7 @@ handle_reply (void *cls, GNUNET_CONTAINER_multihashmap32_contains (h->req_handlers, id)); rh = GNUNET_CONTAINER_multihashmap32_get (h->req_handlers, id); GNUNET_assert (NULL != rh); - GNUNET_assert (rh->num_peers == ntohl (msg->num_peers)); + GNUNET_assert (rh->num_requests == ntohl (msg->num_peers)); GNUNET_CONTAINER_multihashmap32_remove_all (h->req_handlers, id); rh->ready_cb (rh->ready_cb_cls, ntohl (msg->num_peers), @@ -422,7 +428,7 @@ handle_stream_input (void *cls, peers = (struct GNUNET_PeerIdentity *) &msg[1]; GNUNET_assert (NULL != h); GNUNET_assert (NULL != h->stream_input_cb); - h->stream_input_cb (h->stream_input_cb, ntohl (msg->num_peers), peers); + h->stream_input_cb (h->stream_input_cls, ntohl (msg->num_peers), peers); } |