@@ -2715,8 +2715,10 @@ void PeerManagerImpl::ProcessMessage(CNode& pfrom, const std::string& msg_type,
2715
2715
pfrom.m_limited_node = (!(nServices & NODE_NETWORK) && (nServices & NODE_NETWORK_LIMITED));
2716
2716
2717
2717
if (peer->m_tx_relay != nullptr ) {
2718
- LOCK (peer->m_tx_relay ->m_bloom_filter_mutex );
2719
- peer->m_tx_relay ->m_relay_txs = fRelay ; // set to true after we get the first filter* message
2718
+ {
2719
+ LOCK (peer->m_tx_relay ->m_bloom_filter_mutex );
2720
+ peer->m_tx_relay ->m_relay_txs = fRelay ; // set to true after we get the first filter* message
2721
+ }
2720
2722
if (fRelay ) pfrom.m_relays_txs = true ;
2721
2723
}
2722
2724
@@ -4030,10 +4032,12 @@ void PeerManagerImpl::ProcessMessage(CNode& pfrom, const std::string& msg_type,
4030
4032
}
4031
4033
else if (peer->m_tx_relay != nullptr )
4032
4034
{
4033
- LOCK (peer->m_tx_relay ->m_bloom_filter_mutex );
4034
- peer->m_tx_relay ->m_bloom_filter .reset (new CBloomFilter (filter));
4035
+ {
4036
+ LOCK (peer->m_tx_relay ->m_bloom_filter_mutex );
4037
+ peer->m_tx_relay ->m_bloom_filter .reset (new CBloomFilter (filter));
4038
+ peer->m_tx_relay ->m_relay_txs = true ;
4039
+ }
4035
4040
pfrom.m_bloom_filter_loaded = true ;
4036
- peer->m_tx_relay ->m_relay_txs = true ;
4037
4041
pfrom.m_relays_txs = true ;
4038
4042
}
4039
4043
return ;
@@ -4076,10 +4080,13 @@ void PeerManagerImpl::ProcessMessage(CNode& pfrom, const std::string& msg_type,
4076
4080
if (peer->m_tx_relay == nullptr ) {
4077
4081
return ;
4078
4082
}
4079
- LOCK (peer->m_tx_relay ->m_bloom_filter_mutex );
4080
- peer->m_tx_relay ->m_bloom_filter = nullptr ;
4083
+
4084
+ {
4085
+ LOCK (peer->m_tx_relay ->m_bloom_filter_mutex );
4086
+ peer->m_tx_relay ->m_bloom_filter = nullptr ;
4087
+ peer->m_tx_relay ->m_relay_txs = true ;
4088
+ }
4081
4089
pfrom.m_bloom_filter_loaded = false ;
4082
- peer->m_tx_relay ->m_relay_txs = true ;
4083
4090
pfrom.m_relays_txs = true ;
4084
4091
return ;
4085
4092
}
0 commit comments