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

Prepare for PathState:createCanonical.

Browse Source
This commit is contained in:
Arthur Britto
2012-11-24 14:51:39 -08:00
parent 2af33273a5
commit 553d55b5db
2 changed files with 536 additions and 491 deletions
Download Patch File Download Diff File Expand all files Collapse all files

985
src/cpp/ripple/RippleCalc.cpp
View File

File diff suppressed because it is too large Load Diff

42
src/cpp/ripple/RippleCalc.h
View File

@@ -101,20 +101,32 @@ public:
STAmount saOutPass; // <-- Amount actually sent. STAmount saOutPass; // <-- Amount actually sent.
bool bConsumed; // If true, use consumes full liquidity. False, may or may not. bool bConsumed; // If true, use consumes full liquidity. False, may or may not.
PathState* setIndex(const int iIndex) {
mIndex = iIndex;
return this;
}
PathState( PathState(
const int iIndex, const STAmount& saSend,
const STAmount& saSendMax,
const Ledger::ref lrLedger = Ledger::pointer()
) : mLedger(lrLedger), saInReq(saSendMax), saOutReq(saSend) { ; }
void setExpanded(
const LedgerEntrySet& lesSource, const LedgerEntrySet& lesSource,
const STPath& spSourcePath, const STPath& spSourcePath,
const uint160& uReceiverID, const uint160& uReceiverID,
const uint160& uSenderID, const uint160& uSenderID
const STAmount& saSend, );
const STAmount& saSendMax
void setCanonical(
PathState::ref pspExpanded
); );
Json::Value getJson() const; Json::Value getJson() const;
static PathState::pointer createPathState( static PathState::pointer createExpanded(
const int iIndex,
const LedgerEntrySet& lesSource, const LedgerEntrySet& lesSource,
const STPath& spSourcePath, const STPath& spSourcePath,
const uint160& uReceiverID, const uint160& uReceiverID,
@@ -123,7 +135,22 @@ public:
const STAmount& saSendMax const STAmount& saSendMax
) )
{ {
return boost::make_shared<PathState>(iIndex, lesSource, spSourcePath, uReceiverID, uSenderID, saSend, saSendMax); PathState::pointer pspNew = boost::make_shared<PathState>(saSend, saSendMax, lesSource.getLedgerRef());
pspNew->setExpanded(lesSource, spSourcePath, uReceiverID, uSenderID);
return pspNew;
}
static PathState::pointer createCanonical(
PathState::ref pspExpanded
)
{
PathState::pointer pspNew = boost::make_shared<PathState>(pspExpanded->saOutAct, pspExpanded->saInAct);
pspNew->setCanonical(pspExpanded);
return pspNew;
} }
static bool lessPriority(PathState::ref lhs, PathState::ref rhs); static bool lessPriority(PathState::ref lhs, PathState::ref rhs);
@@ -141,7 +168,6 @@ public:
// If the transaction fails to meet some constraint, still need to delete unfunded offers. // If the transaction fails to meet some constraint, still need to delete unfunded offers.
boost::unordered_set<uint256> musUnfundedFound; // Offers that were found unfunded. boost::unordered_set<uint256> musUnfundedFound; // Offers that were found unfunded.
PathState::pointer pathCreate(const STPath& spPath);
void pathNext(PathState::ref pspCur, const int iPaths, const LedgerEntrySet& lesCheckpoint, LedgerEntrySet& lesCurrent); void pathNext(PathState::ref pspCur, const int iPaths, const LedgerEntrySet& lesCheckpoint, LedgerEntrySet& lesCurrent);
TER calcNode(const unsigned int uNode, PathState::ref pspCur, const bool bMultiQuality); TER calcNode(const unsigned int uNode, PathState::ref pspCur, const bool bMultiQuality);
TER calcNodeRev(const unsigned int uNode, PathState::ref pspCur, const bool bMultiQuality); TER calcNodeRev(const unsigned int uNode, PathState::ref pspCur, const bool bMultiQuality);