diff options
author | Julius Bünger <buenger@mytum.de> | 2019-02-26 13:49:28 +0100 |
---|---|---|
committer | Julius Bünger <buenger@mytum.de> | 2019-02-26 13:49:28 +0100 |
commit | 8fc9e63f885e4cdcfeddb28336f71adcfa9f9e3d (patch) | |
tree | 6692fe8e7991fb97d6cb75797d69abbbf226249a /src/rps | |
parent | 4b90044d7f5716e7b299b53b37491712d43c815e (diff) | |
download | gnunet-8fc9e63f885e4cdcfeddb28336f71adcfa9f9e3d.tar.gz gnunet-8fc9e63f885e4cdcfeddb28336f71adcfa9f9e3d.zip |
RPS: Fix checking of properties for peer removal
Diffstat (limited to 'src/rps')
-rw-r--r-- | src/rps/gnunet-service-rps.c | 6 |
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", |