Skip to content

Commit 0b03d91

Browse files
committed
Mempool syncer: check peer for necessary service flag when adding it dynamically
1 parent 918a0a3 commit 0b03d91

1 file changed

Lines changed: 6 additions & 1 deletion

File tree

mempool/src/sync/mod.rs

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -22,6 +22,7 @@ use nimiq_consensus::{sync::syncer::SyncEvent, ConsensusProxy};
2222
use nimiq_hash::{Blake2bHash, Hash};
2323
use nimiq_network_interface::{
2424
network::Network,
25+
peer_info::Services,
2526
request::{request_handler, RequestError},
2627
};
2728
use nimiq_time::sleep_until;
@@ -193,7 +194,11 @@ impl<N: Network> MempoolSyncer<N> {
193194

194195
/// Add peer to discover its mempool
195196
fn add_peer(&mut self, peer_id: N::PeerId) {
196-
if self.peers.contains(&peer_id) {
197+
if self.peers.contains(&peer_id)
198+
|| !self
199+
.network
200+
.peer_provides_services(peer_id, Services::MEMPOOL)
201+
{
197202
return;
198203
}
199204

0 commit comments

Comments
 (0)