ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-12-06 17:27:55 +00:00
Code Issues Packages Projects Releases Wiki Activity

Replace a lock with an atomic in new pathfinding

Browse Source
This commit is contained in:
JoelKatz
2014-01-22 22:44:39 -08:00
parent 07d16f280c
commit 815659b898
2 changed files with 26 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

37
src/ripple_app/paths/PathRequest.cpp
View File

@@ -76,20 +76,31 @@ bool PathRequest::isValid ()
bool PathRequest::needsUpdate (bool newOnly, LedgerIndex index)
{
ScopedLockType sl (mLock, __FILE__, __LINE__);
if (newOnly)
{ // we only want to handle new requests
if (iLastIndex != 0)
return false;
iLastIndex = 1;
return true;
}
else
LedgerIndex lastIndex = iLastIndex.load();
for (;;)
{
if (iLastIndex >= index)
return false;
iLastIndex = index;
return true;
if (newOnly)
{
// Is this request new
if (lastIndex != 0)
return false;
// This thread marks this request handled
if (iLastIndex.compare_exchange_weak (lastIndex, 1,
std::memory_order_release, std::memory_order_relaxed))
return true;
}
else
{
// Has the request already been handled?
if (lastIndex >= index)
return false;
// This thread marks this request handled
if (iLastIndex.compare_exchange_weak (lastIndex, index,
std::memory_order_release, std::memory_order_relaxed))
return true;
}
}
}