@@ -213,12 +213,12 @@ struct Peer {
213
213
std::atomic<bool > m_ping_queued{false };
214
214
215
215
/* * A vector of addresses to send to the peer, limited to MAX_ADDR_TO_SEND. */
216
- std::vector<CAddress> vAddrToSend ;
216
+ std::vector<CAddress> m_addrs_to_send ;
217
217
/* * Probabilistic filter of addresses that this peer already knows.
218
218
* Used to avoid relaying addresses to this peer more than once. */
219
219
const std::unique_ptr<CRollingBloomFilter> m_addr_known;
220
220
/* * Whether a getaddr request to this peer is outstanding. */
221
- bool fGetAddr {false };
221
+ bool m_getaddr_sent {false };
222
222
/* * Guards address sending timers. */
223
223
mutable Mutex m_addr_send_times_mutex;
224
224
/* * Time point to send the next ADDR message to this peer. */
@@ -229,7 +229,7 @@ struct Peer {
229
229
* messages, indicating a preference to receive ADDRv2 instead of ADDR ones. */
230
230
std::atomic_bool m_wants_addrv2{false };
231
231
/* * Whether this peer has already sent us a getaddr message. */
232
- bool fSentAddr {false };
232
+ bool m_getaddr_recvd {false };
233
233
234
234
/* * Set of txids to reconsider once their parent transactions have been accepted **/
235
235
std::set<uint256> m_orphan_work_set GUARDED_BY (g_cs_orphans);
@@ -678,10 +678,10 @@ static void PushAddress(Peer& peer, const CAddress& addr, FastRandomContext& ins
678
678
// added after addresses were pushed.
679
679
assert (peer.m_addr_known );
680
680
if (addr.IsValid () && !peer.m_addr_known ->contains (addr.GetKey ()) && IsAddrCompatible (peer, addr)) {
681
- if (peer.vAddrToSend .size () >= MAX_ADDR_TO_SEND) {
682
- peer.vAddrToSend [insecure_rand.randrange (peer.vAddrToSend .size ())] = addr;
681
+ if (peer.m_addrs_to_send .size () >= MAX_ADDR_TO_SEND) {
682
+ peer.m_addrs_to_send [insecure_rand.randrange (peer.m_addrs_to_send .size ())] = addr;
683
683
} else {
684
- peer.vAddrToSend .push_back (addr);
684
+ peer.m_addrs_to_send .push_back (addr);
685
685
}
686
686
}
687
687
}
@@ -2527,7 +2527,7 @@ void PeerManagerImpl::ProcessMessage(CNode& pfrom, const std::string& msg_type,
2527
2527
2528
2528
// Get recent addresses
2529
2529
m_connman.PushMessage (&pfrom, CNetMsgMaker (greatest_common_version).Make (NetMsgType::GETADDR));
2530
- peer->fGetAddr = true ;
2530
+ peer->m_getaddr_sent = true ;
2531
2531
}
2532
2532
2533
2533
if (!pfrom.IsInboundConn ()) {
@@ -2741,7 +2741,7 @@ void PeerManagerImpl::ProcessMessage(CNode& pfrom, const std::string& msg_type,
2741
2741
continue ;
2742
2742
}
2743
2743
bool fReachable = IsReachable (addr);
2744
- if (addr.nTime > nSince && !peer->fGetAddr && vAddr.size () <= 10 && addr.IsRoutable ()) {
2744
+ if (addr.nTime > nSince && !peer->m_getaddr_sent && vAddr.size () <= 10 && addr.IsRoutable ()) {
2745
2745
// Relay to a limited number of other nodes
2746
2746
RelayAddress (pfrom.GetId (), addr, fReachable );
2747
2747
}
@@ -2750,7 +2750,7 @@ void PeerManagerImpl::ProcessMessage(CNode& pfrom, const std::string& msg_type,
2750
2750
vAddrOk.push_back (addr);
2751
2751
}
2752
2752
m_addrman.Add (vAddrOk, pfrom.addr , 2 * 60 * 60 );
2753
- if (vAddr.size () < 1000 ) peer->fGetAddr = false ;
2753
+ if (vAddr.size () < 1000 ) peer->m_getaddr_sent = false ;
2754
2754
if (pfrom.IsAddrFetchConn ()) {
2755
2755
LogPrint (BCLog::NET, " addrfetch connection completed peer=%d; disconnecting\n " , pfrom.GetId ());
2756
2756
pfrom.fDisconnect = true ;
@@ -3632,13 +3632,13 @@ void PeerManagerImpl::ProcessMessage(CNode& pfrom, const std::string& msg_type,
3632
3632
3633
3633
// Only send one GetAddr response per connection to reduce resource waste
3634
3634
// and discourage addr stamping of INV announcements.
3635
- if (peer->fSentAddr ) {
3635
+ if (peer->m_getaddr_recvd ) {
3636
3636
LogPrint (BCLog::NET, " Ignoring repeated \" getaddr\" . peer=%d\n " , pfrom.GetId ());
3637
3637
return ;
3638
3638
}
3639
- peer->fSentAddr = true ;
3639
+ peer->m_getaddr_recvd = true ;
3640
3640
3641
- peer->vAddrToSend .clear ();
3641
+ peer->m_addrs_to_send .clear ();
3642
3642
std::vector<CAddress> vAddr;
3643
3643
if (pfrom.HasPermission (PF_ADDR)) {
3644
3644
vAddr = m_connman.GetAddresses (MAX_ADDR_TO_SEND, MAX_PCT_ADDR_TO_SEND);
@@ -4235,10 +4235,10 @@ void PeerManagerImpl::MaybeSendAddr(CNode& node, Peer& peer, std::chrono::micros
4235
4235
4236
4236
peer.m_next_addr_send = PoissonNextSend (current_time, AVG_ADDRESS_BROADCAST_INTERVAL);
4237
4237
4238
- if (!Assume (peer.vAddrToSend .size () <= MAX_ADDR_TO_SEND)) {
4238
+ if (!Assume (peer.m_addrs_to_send .size () <= MAX_ADDR_TO_SEND)) {
4239
4239
// Should be impossible since we always check size before adding to
4240
- // vAddrToSend . Recover by trimming the vector.
4241
- peer.vAddrToSend .resize (MAX_ADDR_TO_SEND);
4240
+ // m_addrs_to_send . Recover by trimming the vector.
4241
+ peer.m_addrs_to_send .resize (MAX_ADDR_TO_SEND);
4242
4242
}
4243
4243
4244
4244
// Remove addr records that the peer already knows about, and add new
@@ -4248,11 +4248,11 @@ void PeerManagerImpl::MaybeSendAddr(CNode& node, Peer& peer, std::chrono::micros
4248
4248
if (!ret) peer.m_addr_known ->insert (addr.GetKey ());
4249
4249
return ret;
4250
4250
};
4251
- peer.vAddrToSend .erase (std::remove_if (peer.vAddrToSend .begin (), peer.vAddrToSend .end (), addr_already_known),
4252
- peer.vAddrToSend .end ());
4251
+ peer.m_addrs_to_send .erase (std::remove_if (peer.m_addrs_to_send .begin (), peer.m_addrs_to_send .end (), addr_already_known),
4252
+ peer.m_addrs_to_send .end ());
4253
4253
4254
4254
// No addr messages to send
4255
- if (peer.vAddrToSend .empty ()) return ;
4255
+ if (peer.m_addrs_to_send .empty ()) return ;
4256
4256
4257
4257
const char * msg_type;
4258
4258
int make_flags;
@@ -4263,12 +4263,12 @@ void PeerManagerImpl::MaybeSendAddr(CNode& node, Peer& peer, std::chrono::micros
4263
4263
msg_type = NetMsgType::ADDR;
4264
4264
make_flags = 0 ;
4265
4265
}
4266
- m_connman.PushMessage (&node, CNetMsgMaker (node.GetCommonVersion ()).Make (make_flags, msg_type, peer.vAddrToSend ));
4267
- peer.vAddrToSend .clear ();
4266
+ m_connman.PushMessage (&node, CNetMsgMaker (node.GetCommonVersion ()).Make (make_flags, msg_type, peer.m_addrs_to_send ));
4267
+ peer.m_addrs_to_send .clear ();
4268
4268
4269
4269
// we only send the big addr message once
4270
- if (peer.vAddrToSend .capacity () > 40 ) {
4271
- peer.vAddrToSend .shrink_to_fit ();
4270
+ if (peer.m_addrs_to_send .capacity () > 40 ) {
4271
+ peer.m_addrs_to_send .shrink_to_fit ();
4272
4272
}
4273
4273
}
4274
4274
0 commit comments