From cf847c7470937fa160ccec6588acdc3c46c5e202 Mon Sep 17 00:00:00 2001 From: Julius Bünger Date: Wed, 26 Sep 2018 21:15:01 +0200 Subject: Handle cancellation of view updates --- src/rps/rps_api.c | 21 ++++++++++++++++++++- 1 file changed, 20 insertions(+), 1 deletion(-) (limited to 'src/rps/rps_api.c') diff --git a/src/rps/rps_api.c b/src/rps/rps_api.c index 6e124644d..7d0674aff 100644 --- a/src/rps/rps_api.c +++ b/src/rps/rps_api.c @@ -344,6 +344,20 @@ GNUNET_RPS_view_request (struct GNUNET_RPS_Handle *rps_handle, } +void +GNUNET_RPS_view_request_cancel (struct GNUNET_RPS_Handle *rps_handle) +{ + struct GNUNET_MQ_Envelope *ev; + + GNUNET_assert (NULL != rps_handle->view_update_cb); + + rps_handle->view_update_cb = NULL; + + ev = GNUNET_MQ_msg_header (GNUNET_MESSAGE_TYPE_RPS_CS_DEBUG_VIEW_CANCEL); + GNUNET_MQ_send (rps_handle->mq, ev); +} + + /** * Request biased stream of peers that are being put into the sampler * @@ -879,7 +893,12 @@ GNUNET_RPS_disconnect (struct GNUNET_RPS_Handle *h) if (NULL != h->stream_requests_head) { LOG (GNUNET_ERROR_TYPE_WARNING, - "Still waiting for requests\n"); + "Still waiting for replies\n"); + } + if (NULL != h->view_update_cb) + { + LOG (GNUNET_ERROR_TYPE_WARNING, + "Still waiting for view updates\n"); } GNUNET_free (h); } -- cgit v1.2.3