ARCHIVE/xahaud
3
0
Fork 0
mirror of https://github.com/Xahau/xahaud.git synced 2025-12-06 17:27:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Release the InboundLedger lock during getMissingNodes

Browse Source
This commit is contained in:
David Schwartz
2014-02-26 13:29:10 -08:00
committed by Vinnie Falco
parent 2f7ac98e34
commit 2c515636cb
1 changed files with 40 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files

72
src/ripple_app/ledger/InboundLedger.cpp
View File

@@ -546,47 +546,55 @@ void InboundLedger::trigger (Peer::ref peer)
nodeIDs.reserve (256);
nodeHashes.reserve (256);
AccountStateSF filter (mSeq);
// Release the lock while we process the large state map
sl.unlock();
mLedger->peekAccountStateMap ()->getMissingNodes (
nodeIDs, nodeHashes, 256, &filter);
sl.lock();
if (nodeIDs.empty ())
// Make sure nothing happened while we released the lock
if (!mFailed && !mComplete && !mHaveState)
{
if (!mLedger->peekAccountStateMap ()->isValid ())
mFailed = true;
else
if (nodeIDs.empty ())
{
mHaveState = true;
if (mHaveTransactions)
mComplete = true;
}
}
else
{
// VFALCO Why 128? Make this a constant
if (!mAggressive)
filterNodes (nodeIDs, nodeHashes, mRecentASNodes,
128, !isProgress ());
if (!nodeIDs.empty ())
{
tmGL.set_itype (protocol::liAS_NODE);
BOOST_FOREACH (SHAMapNode const& it, nodeIDs)
if (!mLedger->peekAccountStateMap ()->isValid ())
mFailed = true;
else
{
* (tmGL.add_nodeids ()) = it.getRawString ();
mHaveState = true;
if (mHaveTransactions)
mComplete = true;
}
if (m_journal.trace) m_journal.trace <<
"Sending AS node " << nodeIDs.size () <<
" request to " << (
peer ? "selected peer" : "all peers");
if (nodeIDs.size () == 1 && m_journal.trace) m_journal.trace <<
"AS node: " << nodeIDs[0];
sendRequest (tmGL, peer);
return;
}
else
if (m_journal.trace) m_journal.trace <<
"All AS nodes filtered";
{
// VFALCO Why 128? Make this a constant
if (!mAggressive)
filterNodes (nodeIDs, nodeHashes, mRecentASNodes,
128, !isProgress ());
if (!nodeIDs.empty ())
{
tmGL.set_itype (protocol::liAS_NODE);
BOOST_FOREACH (SHAMapNode const& it, nodeIDs)
{
* (tmGL.add_nodeids ()) = it.getRawString ();
}
if (m_journal.trace) m_journal.trace <<
"Sending AS node " << nodeIDs.size () <<
" request to " << (
peer ? "selected peer" : "all peers");
if (nodeIDs.size () == 1 && m_journal.trace) m_journal.trace <<
"AS node: " << nodeIDs[0];
sendRequest (tmGL, peer);
return;
}
else
if (m_journal.trace) m_journal.trace <<
"All AS nodes filtered";
}
}
}
}