aboutsummaryrefslogtreecommitdiff
path: root/src
diff options
context:
space:
mode:
authorJulius Bünger <buenger@mytum.de>2018-09-26 21:37:58 +0200
committerJulius Bünger <buenger@mytum.de>2018-09-26 21:37:58 +0200
commit1d44c1e60ef16c747e02bff9ee5bd682e6f89569 (patch)
tree22a6ece3cbd6de1287a43855d63860d021f621c7 /src
parent1e01cd7bfaad25ef9bc4f3329f4637e0b76e95f5 (diff)
downloadgnunet-1d44c1e60ef16c747e02bff9ee5bd682e6f89569.tar.gz
gnunet-1d44c1e60ef16c747e02bff9ee5bd682e6f89569.zip
Fix details and style
Diffstat (limited to 'src')
-rw-r--r--src/rps/gnunet-service-rps.c20
1 files changed, 12 insertions, 8 deletions
diff --git a/src/rps/gnunet-service-rps.c b/src/rps/gnunet-service-rps.c
index aa5d8af13..64cb5ac98 100644
--- a/src/rps/gnunet-service-rps.c
+++ b/src/rps/gnunet-service-rps.c
@@ -2733,24 +2733,29 @@ handle_client_view_request (void *cls,
2733} 2733}
2734 2734
2735 2735
2736/**
2737 * @brief Handle the cancellation of the view updates.
2738 *
2739 * @param cls The client context
2740 * @param msg Unused
2741 */
2736static void 2742static void
2737handle_client_view_request_cancel (void *cls, 2743handle_client_view_cancel (void *cls,
2738 const struct GNUNET_MessageHeader *msg) 2744 const struct GNUNET_MessageHeader *msg)
2739{ 2745{
2740 struct ClientContext *cli_ctx = cls; 2746 struct ClientContext *cli_ctx = cls;
2741 uint64_t num_updates; 2747 (void) msg;
2742 2748
2743 LOG (GNUNET_ERROR_TYPE_DEBUG, 2749 LOG (GNUNET_ERROR_TYPE_DEBUG,
2744 "Client does not want to receive updates of view any more.\n", 2750 "Client does not want to receive updates of view any more.\n");
2745 num_updates);
2746 2751
2747 GNUNET_assert (NULL != cli_ctx); 2752 GNUNET_assert (NULL != cli_ctx);
2748 cli_ctx->view_updates_left = 0; 2753 cli_ctx->view_updates_left = 0;
2754 GNUNET_SERVICE_client_continue (cli_ctx->client);
2749 if (GNUNET_YES == cli_ctx->stream_update) 2755 if (GNUNET_YES == cli_ctx->stream_update)
2750 { 2756 {
2751 destroy_cli_ctx (cli_ctx); 2757 destroy_cli_ctx (cli_ctx);
2752 } 2758 }
2753 GNUNET_SERVICE_client_continue (cli_ctx->client);
2754} 2759}
2755 2760
2756 2761
@@ -3777,7 +3782,6 @@ static void
3777shutdown_task (void *cls) 3782shutdown_task (void *cls)
3778{ 3783{
3779 struct ClientContext *client_ctx; 3784 struct ClientContext *client_ctx;
3780 struct ReplyCls *reply_cls;
3781 (void) cls; 3785 (void) cls;
3782 3786
3783 in_shutdown = GNUNET_YES; 3787 in_shutdown = GNUNET_YES;
@@ -4100,7 +4104,7 @@ GNUNET_SERVICE_MAIN
4100 GNUNET_MESSAGE_TYPE_RPS_CS_DEBUG_VIEW_REQUEST, 4104 GNUNET_MESSAGE_TYPE_RPS_CS_DEBUG_VIEW_REQUEST,
4101 struct GNUNET_RPS_CS_DEBUG_ViewRequest, 4105 struct GNUNET_RPS_CS_DEBUG_ViewRequest,
4102 NULL), 4106 NULL),
4103 GNUNET_MQ_hd_fixed_size (client_view_request_cancel, 4107 GNUNET_MQ_hd_fixed_size (client_view_cancel,
4104 GNUNET_MESSAGE_TYPE_RPS_CS_DEBUG_VIEW_CANCEL, 4108 GNUNET_MESSAGE_TYPE_RPS_CS_DEBUG_VIEW_CANCEL,
4105 struct GNUNET_MessageHeader, 4109 struct GNUNET_MessageHeader,
4106 NULL), 4110 NULL),