diff options
author | Julius Bünger <buenger@mytum.de> | 2017-12-28 19:03:51 +0100 |
---|---|---|
committer | Julius Bünger <buenger@mytum.de> | 2017-12-28 19:03:51 +0100 |
commit | 62c89d65bc7032f6caa67a5251e2d705c3c3c7de (patch) | |
tree | 1333b0f72c5663a4fa7812924e6fa208d3631c83 /src/rps | |
parent | f4f75ed70d46464bf613d87d71552770fab8b6bf (diff) | |
download | gnunet-62c89d65bc7032f6caa67a5251e2d705c3c3c7de.tar.gz gnunet-62c89d65bc7032f6caa67a5251e2d705c3c3c7de.zip |
rps: stop destroying mq
Diffstat (limited to 'src/rps')
-rw-r--r-- | src/rps/gnunet-service-rps.c | 1 | ||||
-rw-r--r-- | src/rps/gnunet-service-rps_peers.c | 5 |
2 files changed, 0 insertions, 6 deletions
diff --git a/src/rps/gnunet-service-rps.c b/src/rps/gnunet-service-rps.c index d3d642ee0..124b82b72 100644 --- a/src/rps/gnunet-service-rps.c +++ b/src/rps/gnunet-service-rps.c | |||
@@ -2129,7 +2129,6 @@ shutdown_task (void *cls) | |||
2129 | reply_cls); | 2129 | reply_cls); |
2130 | GNUNET_free (reply_cls); | 2130 | GNUNET_free (reply_cls); |
2131 | } | 2131 | } |
2132 | GNUNET_MQ_destroy (client_ctx->mq); | ||
2133 | GNUNET_CONTAINER_DLL_remove (cli_ctx_head, cli_ctx_tail, client_ctx); | 2132 | GNUNET_CONTAINER_DLL_remove (cli_ctx_head, cli_ctx_tail, client_ctx); |
2134 | GNUNET_free (client_ctx); | 2133 | GNUNET_free (client_ctx); |
2135 | } | 2134 | } |
diff --git a/src/rps/gnunet-service-rps_peers.c b/src/rps/gnunet-service-rps_peers.c index 26881518f..9cc4d3228 100644 --- a/src/rps/gnunet-service-rps_peers.c +++ b/src/rps/gnunet-service-rps_peers.c | |||
@@ -1182,11 +1182,6 @@ Peers_remove_peer (const struct GNUNET_PeerIdentity *peer) | |||
1182 | GNUNET_CADET_channel_destroy (peer_ctx->recv_channel); | 1182 | GNUNET_CADET_channel_destroy (peer_ctx->recv_channel); |
1183 | peer_ctx->recv_channel = NULL; | 1183 | peer_ctx->recv_channel = NULL; |
1184 | } | 1184 | } |
1185 | if (NULL != peer_ctx->mq) | ||
1186 | { | ||
1187 | GNUNET_MQ_destroy (peer_ctx->mq); | ||
1188 | peer_ctx->mq = NULL; | ||
1189 | } | ||
1190 | 1185 | ||
1191 | GNUNET_free (peer_ctx->send_channel_flags); | 1186 | GNUNET_free (peer_ctx->send_channel_flags); |
1192 | GNUNET_free (peer_ctx->recv_channel_flags); | 1187 | GNUNET_free (peer_ctx->recv_channel_flags); |