@ -659,7 +659,7 @@ static void UpdatePreferredDownload(const CNode& node, CNodeState* state) EXCLUS
nPreferredDownload + = state - > fPreferredDownload ;
nPreferredDownload + = state - > fPreferredDownload ;
}
}
bool PeerManagerImpl : : MarkBlockAsReceived ( const uint256 & hash ) EXCLUSIVE_LOCKS_REQUIRED ( cs_main )
bool PeerManagerImpl : : MarkBlockAsReceived ( const uint256 & hash )
{
{
std : : map < uint256 , std : : pair < NodeId , std : : list < QueuedBlock > : : iterator > > : : iterator itInFlight = mapBlocksInFlight . find ( hash ) ;
std : : map < uint256 , std : : pair < NodeId , std : : list < QueuedBlock > : : iterator > > : : iterator itInFlight = mapBlocksInFlight . find ( hash ) ;
if ( itInFlight ! = mapBlocksInFlight . end ( ) ) {
if ( itInFlight ! = mapBlocksInFlight . end ( ) ) {
@ -683,7 +683,7 @@ bool PeerManagerImpl::MarkBlockAsReceived(const uint256& hash) EXCLUSIVE_LOCKS_R
return false ;
return false ;
}
}
bool PeerManagerImpl : : MarkBlockAsInFlight ( NodeId nodeid , const uint256 & hash , const CBlockIndex * pindex , std : : list < QueuedBlock > : : iterator * * pit ) EXCLUSIVE_LOCKS_REQUIRED ( cs_main )
bool PeerManagerImpl : : MarkBlockAsInFlight ( NodeId nodeid , const uint256 & hash , const CBlockIndex * pindex , std : : list < QueuedBlock > : : iterator * * pit )
{
{
CNodeState * state = State ( nodeid ) ;
CNodeState * state = State ( nodeid ) ;
assert ( state ! = nullptr ) ;
assert ( state ! = nullptr ) ;
@ -752,7 +752,7 @@ static void UpdateBlockAvailability(NodeId nodeid, const uint256 &hash) EXCLUSIV
}
}
}
}
void PeerManagerImpl : : MaybeSetPeerAsAnnouncingHeaderAndIDs ( NodeId nodeid ) EXCLUSIVE_LOCKS_REQUIRED ( cs_main )
void PeerManagerImpl : : MaybeSetPeerAsAnnouncingHeaderAndIDs ( NodeId nodeid )
{
{
AssertLockHeld ( cs_main ) ;
AssertLockHeld ( cs_main ) ;
CNodeState * nodestate = State ( nodeid ) ;
CNodeState * nodestate = State ( nodeid ) ;
@ -791,7 +791,7 @@ void PeerManagerImpl::MaybeSetPeerAsAnnouncingHeaderAndIDs(NodeId nodeid) EXCLUS
}
}
}
}
bool PeerManagerImpl : : TipMayBeStale ( ) EXCLUSIVE_LOCKS_REQUIRED ( cs_main )
bool PeerManagerImpl : : TipMayBeStale ( )
{
{
AssertLockHeld ( cs_main ) ;
AssertLockHeld ( cs_main ) ;
const Consensus : : Params & consensusParams = m_chainparams . GetConsensus ( ) ;
const Consensus : : Params & consensusParams = m_chainparams . GetConsensus ( ) ;
@ -815,7 +815,7 @@ static bool PeerHasHeader(CNodeState *state, const CBlockIndex *pindex) EXCLUSIV
return false ;
return false ;
}
}
void PeerManagerImpl : : FindNextBlocksToDownload ( NodeId nodeid , unsigned int count , std : : vector < const CBlockIndex * > & vBlocks , NodeId & nodeStaller ) EXCLUSIVE_LOCKS_REQUIRED ( cs_main )
void PeerManagerImpl : : FindNextBlocksToDownload ( NodeId nodeid , unsigned int count , std : : vector < const CBlockIndex * > & vBlocks , NodeId & nodeStaller )
{
{
if ( count = = 0 )
if ( count = = 0 )
return ;
return ;
@ -1616,7 +1616,7 @@ void PeerManagerImpl::BlockChecked(const CBlock& block, const BlockValidationSta
//
//
bool PeerManagerImpl : : AlreadyHaveTx ( const GenTxid & gtxid ) EXCLUSIVE_LOCKS_REQUIRED ( cs_main )
bool PeerManagerImpl : : AlreadyHaveTx ( const GenTxid & gtxid )
{
{
assert ( recentRejects ) ;
assert ( recentRejects ) ;
if ( : : ChainActive ( ) . Tip ( ) - > GetBlockHash ( ) ! = hashRecentRejectsChainTip ) {
if ( : : ChainActive ( ) . Tip ( ) - > GetBlockHash ( ) ! = hashRecentRejectsChainTip ) {
@ -1884,7 +1884,7 @@ void static ProcessGetBlockData(CNode& pfrom, Peer& peer, const CChainParams& ch
}
}
}
}
CTransactionRef PeerManagerImpl : : FindTxForGetData ( const CNode & peer , const GenTxid & gtxid , const std : : chrono : : seconds mempool_req , const std : : chrono : : seconds now ) LOCKS_EXCLUDED ( cs_main )
CTransactionRef PeerManagerImpl : : FindTxForGetData ( const CNode & peer , const GenTxid & gtxid , const std : : chrono : : seconds mempool_req , const std : : chrono : : seconds now )
{
{
auto txinfo = m_mempool . info ( gtxid ) ;
auto txinfo = m_mempool . info ( gtxid ) ;
if ( txinfo . tx ) {
if ( txinfo . tx ) {
@ -1911,7 +1911,7 @@ CTransactionRef PeerManagerImpl::FindTxForGetData(const CNode& peer, const GenTx
return { } ;
return { } ;
}
}
void PeerManagerImpl : : ProcessGetData ( CNode & pfrom , Peer & peer , const std : : atomic < bool > & interruptMsgProc ) EXCLUSIVE_LOCKS_REQUIRED ( ! cs_main , peer . m_getdata_requests_mutex )
void PeerManagerImpl : : ProcessGetData ( CNode & pfrom , Peer & peer , const std : : atomic < bool > & interruptMsgProc )
{
{
AssertLockNotHeld ( cs_main ) ;
AssertLockNotHeld ( cs_main ) ;