aboutsummaryrefslogtreecommitdiff
path: root/src/rps
diff options
context:
space:
mode:
authorJulius Bünger <buenger@mytum.de>2017-12-28 19:03:51 +0100
committerJulius Bünger <buenger@mytum.de>2017-12-28 19:03:51 +0100
commit62c89d65bc7032f6caa67a5251e2d705c3c3c7de (patch)
tree1333b0f72c5663a4fa7812924e6fa208d3631c83 /src/rps
parentf4f75ed70d46464bf613d87d71552770fab8b6bf (diff)
downloadgnunet-62c89d65bc7032f6caa67a5251e2d705c3c3c7de.tar.gz
gnunet-62c89d65bc7032f6caa67a5251e2d705c3c3c7de.zip
rps: stop destroying mq
Diffstat (limited to 'src/rps')
-rw-r--r--src/rps/gnunet-service-rps.c1
-rw-r--r--src/rps/gnunet-service-rps_peers.c5
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);