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

Add an extra phase to the process of deciding which ripple lines to explore.

Browse Source 
It will make sense shortly.
This commit is contained in:
JoelKatz
2013-04-07 20:56:16 -07:00
parent a47b89422f
commit 03bce70a23
1 changed files with 28 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

48
src/cpp/ripple/Pathfinder.cpp
View File

@@ -409,7 +409,13 @@ bool Pathfinder::findPaths(const unsigned int iMaxSteps, const unsigned int iMax
// True, the cursor requires the next node to be authorized.
bool bRequireAuth = isSetBit(sleEnd->getFieldU32(sfFlags), lsfRequireAuth);
BOOST_FOREACH(AccountItem::ref item, getRippleLines(speEnd.mAccountID).getItems())
AccountItems& rippleLines(getRippleLines(speEnd.mAccountID));
typedef std::pair<int, uint160> candidate_t;
std::vector< std::pair<int, uint160> > candidates;
candidates.reserve(rippleLines.getItems().size());
BOOST_FOREACH(AccountItem::ref item, rippleLines.getItems())
{
RippleState* rspEntry = (RippleState*) item.get();
const uint160& uPeerID = rspEntry->getAccountIDPeer();
@@ -446,27 +452,29 @@ bool Pathfinder::findPaths(const unsigned int iMaxSteps, const unsigned int iMax
);
}
else
{
// Can transmit IOUs and account to the path.
STPath spNew(spPath);
STPathElement speNew(uPeerID, speEnd.mCurrencyID, uPeerID);
spNew.mPath.push_back(speNew);
qspExplore.push(spNew);
bContinued = true;
cLog(lsTRACE) <<
boost::str(boost::format("findPaths: push explore: %s/%s -> %s/%s balance=%s limit=%s limit_peer=%s")
% STAmount::createHumanCurrency(speEnd.mCurrencyID)
% RippleAddress::createHumanAccountID(speEnd.mAccountID)
% STAmount::createHumanCurrency(speEnd.mCurrencyID)
% RippleAddress::createHumanAccountID(uPeerID)
% rspEntry->getBalance().getFullText()
% rspEntry->getLimit().getFullText()
% rspEntry->getLimitPeer().getFullText());
{ // save this candidate
candidates.push_back(std::make_pair(1, uPeerID));
}
}
BOOST_FOREACH(const candidate_t& candidate, candidates)
{
STPath spNew(spPath);
STPathElement speNew(candidate.second, speEnd.mCurrencyID, candidate.second);
spNew.mPath.push_back(speNew);
qspExplore.push(spNew);
bContinued = true;
cLog(lsTRACE) <<
boost::str(boost::format("findPaths: push explore: %s/%s -> %s/%s")
% STAmount::createHumanCurrency(speEnd.mCurrencyID)
% RippleAddress::createHumanAccountID(speEnd.mAccountID)
% STAmount::createHumanCurrency(speEnd.mCurrencyID)
% RippleAddress::createHumanAccountID(candidate.second));
}
}