aboutsummaryrefslogtreecommitdiff
path: root/src/rps/gnunet-service-rps.c
diff options
context:
space:
mode:
authorJulius Bünger <buenger@mytum.de>2019-02-26 13:49:28 +0100
committerJulius Bünger <buenger@mytum.de>2019-02-26 13:49:28 +0100
commit8fc9e63f885e4cdcfeddb28336f71adcfa9f9e3d (patch)
tree6692fe8e7991fb97d6cb75797d69abbbf226249a /src/rps/gnunet-service-rps.c
parent4b90044d7f5716e7b299b53b37491712d43c815e (diff)
downloadgnunet-8fc9e63f885e4cdcfeddb28336f71adcfa9f9e3d.tar.gz
gnunet-8fc9e63f885e4cdcfeddb28336f71adcfa9f9e3d.zip
RPS: Fix checking of properties for peer removal
Diffstat (limited to 'src/rps/gnunet-service-rps.c')
-rw-r--r--src/rps/gnunet-service-rps.c6
1 files changed, 3 insertions, 3 deletions
diff --git a/src/rps/gnunet-service-rps.c b/src/rps/gnunet-service-rps.c
index 4758478c1..8c50cf9d5 100644
--- a/src/rps/gnunet-service-rps.c
+++ b/src/rps/gnunet-service-rps.c
@@ -1796,7 +1796,7 @@ check_removable (const struct PeerContext *peer_ctx)
1796 1796
1797 if ( (NULL != peer_ctx->recv_channel_ctx) || 1797 if ( (NULL != peer_ctx->recv_channel_ctx) ||
1798 (NULL != peer_ctx->pending_messages_head) || 1798 (NULL != peer_ctx->pending_messages_head) ||
1799 (GNUNET_NO == check_peer_flag_set (peer_ctx, Peers_PULL_REPLY_PENDING)) ) 1799 (GNUNET_YES == check_peer_flag_set (peer_ctx, Peers_PULL_REPLY_PENDING)) )
1800 { 1800 {
1801 return GNUNET_NO; 1801 return GNUNET_NO;
1802 } 1802 }
@@ -2758,8 +2758,8 @@ clean_peer (struct Sub *sub,
2758 (GNUNET_NO == View_contains_peer (sub->view, peer)) && 2758 (GNUNET_NO == View_contains_peer (sub->view, peer)) &&
2759 (GNUNET_NO == CustomPeerMap_contains_peer (sub->push_map, peer)) && 2759 (GNUNET_NO == CustomPeerMap_contains_peer (sub->push_map, peer)) &&
2760 (GNUNET_NO == CustomPeerMap_contains_peer (sub->push_map, peer)) && 2760 (GNUNET_NO == CustomPeerMap_contains_peer (sub->push_map, peer)) &&
2761 (0 == RPS_sampler_count_id (sub->sampler, peer)) && 2761 (0 == RPS_sampler_count_id (sub->sampler, peer)) &&
2762 (GNUNET_NO != check_removable (get_peer_ctx (sub->peer_map, peer))) ) 2762 (GNUNET_YES == check_removable (get_peer_ctx (sub->peer_map, peer))) )
2763 { /* We can safely remove this peer */ 2763 { /* We can safely remove this peer */
2764 LOG (GNUNET_ERROR_TYPE_DEBUG, 2764 LOG (GNUNET_ERROR_TYPE_DEBUG,
2765 "Going to remove peer %s\n", 2765 "Going to remove peer %s\n",