diff options
author | MarcoFalke <falke.marco@gmail.com> | 2018-11-27 12:43:31 -0500 |
---|---|---|
committer | MarcoFalke <falke.marco@gmail.com> | 2018-11-27 12:43:37 -0500 |
commit | d49103007676b4b857c6c643bad071e1a7305420 (patch) | |
tree | 1ec8fde0b5675aad207b337616b515db84c28ebb | |
parent | a4eaaa6ac53606a1533b56050af77961d8c27dc7 (diff) | |
parent | fa71eb5196fc157213d7b6364071530ab19df724 (diff) |
Merge #14772: refactor: Convert comments to thread safety annotations
fa71eb5196 Convert comments to thread safety annotations (MarcoFalke)
Pull request description:
Convert human-only-readable annotations to human-and-machine-readable annotations.
Tree-SHA512: 98a97b32b50e8ec816626ed853d56c9afb31065eb14f058cda8f22a16ddd2b0c02911f9e30478aa347f466891f972496d89a828eb6e4662fb712d7d9e7643d49
-rw-r--r-- | src/net.cpp | 1 | ||||
-rw-r--r-- | src/net.h | 11 | ||||
-rw-r--r-- | src/validation.cpp | 6 |
3 files changed, 8 insertions, 10 deletions
diff --git a/src/net.cpp b/src/net.cpp index 65a308780a..e065ac0f28 100644 --- a/src/net.cpp +++ b/src/net.cpp @@ -1011,6 +1011,7 @@ bool CConnman::AttemptToEvictConnection() continue; if (node->fDisconnect) continue; + LOCK(node->cs_filter); NodeEvictionCandidate candidate = {node->GetId(), node->nTimeConnected, node->nMinPingUsecTime, node->nLastBlockTime, node->nLastTXTime, HasAllDesirableServiceFlags(node->nServices), @@ -677,10 +677,10 @@ public: // a) it allows us to not relay tx invs before receiving the peer's version message // b) the peer may tell us in its version message that we should not relay tx invs // unless it loads a bloom filter. - bool fRelayTxes; //protected by cs_filter + bool fRelayTxes GUARDED_BY(cs_filter); bool fSentAddr; CSemaphoreGrant grantOutbound; - CCriticalSection cs_filter; + mutable CCriticalSection cs_filter; std::unique_ptr<CBloomFilter> pfilter; std::atomic<int> nRefCount; @@ -718,10 +718,9 @@ public: std::multimap<int64_t, CInv> mapAskFor; int64_t nNextInvSend; // Used for headers announcements - unfiltered blocks to relay - // Also protected by cs_inventory - std::vector<uint256> vBlockHashesToAnnounce; - // Used for BIP35 mempool sending, also protected by cs_inventory - bool fSendMempool; + std::vector<uint256> vBlockHashesToAnnounce GUARDED_BY(cs_inventory); + // Used for BIP35 mempool sending + bool fSendMempool GUARDED_BY(cs_inventory); // Last time a "MEMPOOL" request was serviced. std::atomic<int64_t> timeLastMempoolReq; diff --git a/src/validation.cpp b/src/validation.cpp index 241957878e..6333dd98d2 100644 --- a/src/validation.cpp +++ b/src/validation.cpp @@ -1680,8 +1680,7 @@ void ThreadScriptCheck() { scriptcheckqueue.Thread(); } -// Protected by cs_main -VersionBitsCache versionbitscache; +VersionBitsCache versionbitscache GUARDED_BY(cs_main); int32_t ComputeBlockVersion(const CBlockIndex* pindexPrev, const Consensus::Params& params) { @@ -1722,8 +1721,7 @@ public: } }; -// Protected by cs_main -static ThresholdConditionCache warningcache[VERSIONBITS_NUM_BITS]; +static ThresholdConditionCache warningcache[VERSIONBITS_NUM_BITS] GUARDED_BY(cs_main); // 0.13.0 was shipped with a segwit deployment defined for testnet, but not for // mainnet. We no longer need to support disabling the segwit deployment |