mirrors/bitcoin
1
0
Fork 0
mirror of https://github.com/bitcoin/bitcoin.git synced 2024-11-20 10:38:42 +01:00
Code Issues Projects Releases Wiki Activity

net/net_processing: add missing thread safety annotations

Browse Source
This commit is contained in:
Anthony Towns 2022-05-20 05:31:34 +10:00
parent e191fac4f3
commit 06ebdc886f
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/net.h
View File

@ -368,7 +368,7 @@ public:
RecursiveMutex cs_vProcessMsg; RecursiveMutex cs_vProcessMsg;
std::list<CNetMessage> vProcessMsg GUARDED_BY(cs_vProcessMsg); std::list<CNetMessage> vProcessMsg GUARDED_BY(cs_vProcessMsg);
size_t nProcessQueueSize{0}; size_t nProcessQueueSize GUARDED_BY(cs_vProcessMsg){0};
RecursiveMutex cs_sendProcessing; RecursiveMutex cs_sendProcessing;

6
src/net_processing.cpp
View File

@ -289,7 +289,7 @@ struct Peer {
* non-wtxid-relay peers, wtxid for wtxid-relay peers). We use the * non-wtxid-relay peers, wtxid for wtxid-relay peers). We use the
* mempool to sort transactions in dependency order before relay, so * mempool to sort transactions in dependency order before relay, so
* this does not have to be sorted. */ * this does not have to be sorted. */
std::set<uint256> m_tx_inventory_to_send; std::set<uint256> m_tx_inventory_to_send GUARDED_BY(m_tx_inventory_mutex);
/** Whether the peer has requested us to send our complete mempool. Only /** Whether the peer has requested us to send our complete mempool. Only
* permitted if the peer has NetPermissionFlags::Mempool. See BIP35. */ * permitted if the peer has NetPermissionFlags::Mempool. See BIP35. */
bool m_send_mempool GUARDED_BY(m_tx_inventory_mutex){false}; bool m_send_mempool GUARDED_BY(m_tx_inventory_mutex){false};
@ -648,7 +648,7 @@ private:
std::atomic<int> m_best_height{-1}; std::atomic<int> m_best_height{-1};
/** Next time to check for stale tip */ /** Next time to check for stale tip */
std::chrono::seconds m_stale_tip_check_time{0s}; std::chrono::seconds m_stale_tip_check_time GUARDED_BY(cs_main){0s};
/** Whether this node is running in -blocksonly mode */ /** Whether this node is running in -blocksonly mode */
const bool m_ignore_incoming_txs; const bool m_ignore_incoming_txs;
@ -657,7 +657,7 @@ private:
/** Whether we've completed initial sync yet, for determining when to turn /** Whether we've completed initial sync yet, for determining when to turn
* on extra block-relay-only peers. */ * on extra block-relay-only peers. */
bool m_initial_sync_finished{false}; bool m_initial_sync_finished GUARDED_BY(cs_main){false};
/** Protects m_peer_map. This mutex must not be locked while holding a lock /** Protects m_peer_map. This mutex must not be locked while holding a lock
* on any of the mutexes inside a Peer object. */ * on any of the mutexes inside a Peer object. */