Merge branch 'faster_clientops' into develop

Conflicts:
	src/cpp/ripple/LedgerEntrySet.cpp
This commit is contained in:
JoelKatz
2013-05-14 16:02:10 -07:00
11 changed files with 91 additions and 79 deletions

View File

@@ -49,12 +49,11 @@ void ALTransaction::buildJson()
if (!mAffected.empty()) if (!mAffected.empty())
{ {
Json::Value affected(Json::arrayValue); Json::Value& affected = (mJson["affected"] = Json::arrayValue);
BOOST_FOREACH(const RippleAddress& ra, mAffected) BOOST_FOREACH(const RippleAddress& ra, mAffected)
{ {
affected.append(ra.humanAccountID()); affected.append(ra.humanAccountID());
} }
mJson["affected"] = affected;
} }
} }
@@ -64,7 +63,7 @@ AcceptedLedger::AcceptedLedger(Ledger::ref ledger) : mLedger(ledger)
for (SHAMapItem::pointer item = txSet.peekFirstItem(); !!item; item = txSet.peekNextItem(item->getTag())) for (SHAMapItem::pointer item = txSet.peekFirstItem(); !!item; item = txSet.peekNextItem(item->getTag()))
{ {
SerializerIterator sit(item->peekSerializer()); SerializerIterator sit(item->peekSerializer());
insert(ALTransaction(ledger->getLedgerSeq(), sit)); insert(boost::make_shared<ALTransaction>(ledger->getLedgerSeq(), sit));
} }
} }
@@ -78,16 +77,16 @@ AcceptedLedger::pointer AcceptedLedger::makeAcceptedLedger(Ledger::ref ledger)
return ret; return ret;
} }
void AcceptedLedger::insert(const ALTransaction& at) void AcceptedLedger::insert(ALTransaction::ref at)
{ {
assert(mMap.find(at.getIndex()) == mMap.end()); assert(mMap.find(at->getIndex()) == mMap.end());
mMap.insert(std::make_pair(at.getIndex(), at)); mMap.insert(std::make_pair(at->getIndex(), at));
} }
const ALTransaction* AcceptedLedger::getTxn(int i) const ALTransaction::pointer AcceptedLedger::getTxn(int i) const
{ {
map_t::const_iterator it = mMap.find(i); map_t::const_iterator it = mMap.find(i);
if (it == mMap.end()) if (it == mMap.end())
return NULL; return ALTransaction::pointer();
return &it->second; return it->second;
} }

View File

@@ -19,6 +19,8 @@ protected:
void buildJson(); void buildJson();
public: public:
typedef boost::shared_ptr<ALTransaction> pointer;
typedef const pointer& ref;
ALTransaction(uint32 ledgerSeq, SerializerIterator& sit); ALTransaction(uint32 ledgerSeq, SerializerIterator& sit);
ALTransaction(SerializedTransaction::ref, TransactionMetaSet::ref); ALTransaction(SerializedTransaction::ref, TransactionMetaSet::ref);
@@ -42,17 +44,17 @@ public:
class AcceptedLedger class AcceptedLedger
{ {
public: public:
typedef boost::shared_ptr<AcceptedLedger> pointer; typedef boost::shared_ptr<AcceptedLedger> pointer;
typedef const pointer& ret; typedef const pointer& ret;
typedef std::map<int, ALTransaction> map_t; // Must be an ordered map! typedef std::map<int, ALTransaction::pointer> map_t; // Must be an ordered map!
typedef map_t::value_type value_type; typedef map_t::value_type value_type;
typedef map_t::const_iterator const_iterator; typedef map_t::const_iterator const_iterator;
protected: protected:
Ledger::pointer mLedger; Ledger::pointer mLedger;
map_t mMap; map_t mMap;
void insert(const ALTransaction&); void insert(ALTransaction::ref);
static TaggedCache<uint256, AcceptedLedger> ALCache; static TaggedCache<uint256, AcceptedLedger> ALCache;
AcceptedLedger(Ledger::ref ledger); AcceptedLedger(Ledger::ref ledger);
@@ -68,7 +70,7 @@ public:
int getLedgerSeq() const { return mLedger->getLedgerSeq(); } int getLedgerSeq() const { return mLedger->getLedgerSeq(); }
int getTxnCount() const { return mMap.size(); } int getTxnCount() const { return mMap.size(); }
const ALTransaction* getTxn(int) const; ALTransaction::pointer getTxn(int) const;
}; };
#endif #endif

View File

@@ -1223,9 +1223,9 @@ void STAmount::roundSelf()
} }
} }
Json::Value STAmount::getJson(int) const void STAmount::setJson(Json::Value& elem) const
{ {
Json::Value elem(Json::objectValue); elem = Json::objectValue;
if (!mIsNative) if (!mIsNative)
{ {
@@ -1237,9 +1237,14 @@ Json::Value STAmount::getJson(int) const
} }
else else
{ {
elem=getText(); elem = getText();
} }
}
Json::Value STAmount::getJson(int) const
{
Json::Value elem;
setJson(elem);
return elem; return elem;
} }

View File

@@ -471,12 +471,12 @@ void Ledger::saveAcceptedLedger(Job&, bool fromConsensus)
BOOST_FOREACH(const AcceptedLedger::value_type& vt, aLedger->getMap()) BOOST_FOREACH(const AcceptedLedger::value_type& vt, aLedger->getMap())
{ {
uint256 txID = vt.second.getTransactionID(); uint256 txID = vt.second->getTransactionID();
theApp->getMasterTransaction().inLedger(txID, mLedgerSeq); theApp->getMasterTransaction().inLedger(txID, mLedgerSeq);
db->executeSQL(boost::str(deleteAcctTrans % txID.GetHex())); db->executeSQL(boost::str(deleteAcctTrans % txID.GetHex()));
const std::vector<RippleAddress>& accts = vt.second.getAffected(); const std::vector<RippleAddress>& accts = vt.second->getAffected();
if (!accts.empty()) if (!accts.empty())
{ {
std::string sql = "INSERT INTO AccountTransactions (TransID, Account, LedgerSeq, TxnSeq) VALUES "; std::string sql = "INSERT INTO AccountTransactions (TransID, Account, LedgerSeq, TxnSeq) VALUES ";
@@ -496,7 +496,7 @@ void Ledger::saveAcceptedLedger(Job&, bool fromConsensus)
sql += "',"; sql += "',";
sql += boost::lexical_cast<std::string>(getLedgerSeq()); sql += boost::lexical_cast<std::string>(getLedgerSeq());
sql += ","; sql += ",";
sql += boost::lexical_cast<std::string>(vt.second.getTxnSeq()); sql += boost::lexical_cast<std::string>(vt.second->getTxnSeq());
sql += ")"; sql += ")";
} }
sql += ";"; sql += ";";
@@ -507,7 +507,7 @@ void Ledger::saveAcceptedLedger(Job&, bool fromConsensus)
cLog(lsWARNING) << "Transaction in ledger " << mLedgerSeq << " affects no accounts"; cLog(lsWARNING) << "Transaction in ledger " << mLedgerSeq << " affects no accounts";
db->executeSQL(SerializedTransaction::getMetaSQLInsertReplaceHeader() + db->executeSQL(SerializedTransaction::getMetaSQLInsertReplaceHeader() +
vt.second.getTxn()->getMetaSQL(getLedgerSeq(), vt.second.getEscMeta()) + ";"); vt.second->getTxn()->getMetaSQL(getLedgerSeq(), vt.second->getEscMeta()) + ";");
} }
db->executeSQL("COMMIT TRANSACTION;"); db->executeSQL("COMMIT TRANSACTION;");
} }

View File

@@ -1439,8 +1439,8 @@ void NetworkOPs::pubLedger(Ledger::ref accepted)
{ {
BOOST_FOREACH(const AcceptedLedger::value_type& vt, alpAccepted->getMap()) BOOST_FOREACH(const AcceptedLedger::value_type& vt, alpAccepted->getMap())
{ {
cLog(lsTRACE) << "pubAccepted: " << vt.second.getJson(); cLog(lsTRACE) << "pubAccepted: " << vt.second->getJson();
pubValidatedTransaction(lpAccepted, vt.second); pubValidatedTransaction(lpAccepted, *vt.second);
} }
} }
} }
@@ -1841,8 +1841,9 @@ InfoSub::pointer NetworkOPs::addRpcSub(const std::string& strUrl, InfoSub::ref r
// FIXME : support iLimit. // FIXME : support iLimit.
void NetworkOPs::getBookPage(Ledger::pointer lpLedger, const uint160& uTakerPaysCurrencyID, const uint160& uTakerPaysIssuerID, const uint160& uTakerGetsCurrencyID, const uint160& uTakerGetsIssuerID, const uint160& uTakerID, const bool bProof, const unsigned int iLimit, const Json::Value& jvMarker, Json::Value& jvResult) void NetworkOPs::getBookPage(Ledger::pointer lpLedger, const uint160& uTakerPaysCurrencyID, const uint160& uTakerPaysIssuerID, const uint160& uTakerGetsCurrencyID, const uint160& uTakerGetsIssuerID, const uint160& uTakerID, const bool bProof, const unsigned int iLimit, const Json::Value& jvMarker, Json::Value& jvResult)
{ {
boost::unordered_map<uint160, STAmount> umBalance; Json::Value& jvOffers = (jvResult["offers"] = Json::Value(Json::arrayValue));
Json::Value jvOffers = Json::Value(Json::arrayValue);
std::map<uint160, STAmount> umBalance;
const uint256 uBookBase = Ledger::getBookBase(uTakerPaysCurrencyID, uTakerPaysIssuerID, uTakerGetsCurrencyID, uTakerGetsIssuerID); const uint256 uBookBase = Ledger::getBookBase(uTakerPaysCurrencyID, uTakerPaysIssuerID, uTakerGetsCurrencyID, uTakerGetsIssuerID);
const uint256 uBookEnd = Ledger::getQualityNext(uBookBase); const uint256 uBookEnd = Ledger::getQualityNext(uBookBase);
uint256 uTipIndex = uBookBase; uint256 uTipIndex = uBookBase;
@@ -1863,20 +1864,22 @@ void NetworkOPs::getBookPage(Ledger::pointer lpLedger, const uint160& uTakerPays
unsigned int uBookEntry; unsigned int uBookEntry;
STAmount saDirRate; STAmount saDirRate;
// unsigned int iLeft = iLimit; unsigned int iLeft = iLimit;
if ((iLeft == 0) || (iLeft > 300))
iLeft = 300;
uint32 uTransferRate = lesActive.rippleTransferRate(uTakerGetsIssuerID); uint32 uTransferRate = lesActive.rippleTransferRate(uTakerGetsIssuerID);
while (!bDone) { while (!bDone && (iLeft > 0)) {
if (bDirectAdvance) { if (bDirectAdvance) {
bDirectAdvance = false; bDirectAdvance = false;
cLog(lsTRACE) << boost::str(boost::format("getBookPage: bDirectAdvance")); cLog(lsTRACE) << "getBookPage: bDirectAdvance";
sleOfferDir = lesActive.entryCache(ltDIR_NODE, lpLedger->getNextLedgerIndex(uTipIndex, uBookEnd)); sleOfferDir = lesActive.entryCache(ltDIR_NODE, lpLedger->getNextLedgerIndex(uTipIndex, uBookEnd));
if (!sleOfferDir) if (!sleOfferDir)
{ {
cLog(lsTRACE) << boost::str(boost::format("getBookPage: bDone")); cLog(lsTRACE) << "getBookPage: bDone";
bDone = true; bDone = true;
} }
else else
@@ -1895,9 +1898,9 @@ void NetworkOPs::getBookPage(Ledger::pointer lpLedger, const uint160& uTakerPays
if (!bDone) if (!bDone)
{ {
SLE::pointer sleOffer = lesActive.entryCache(ltOFFER, uOfferIndex); SLE::pointer sleOffer = lesActive.entryCache(ltOFFER, uOfferIndex);
const uint160 uOfferOwnerID = sleOffer->getFieldAccount(sfAccount).getAccountID(); const uint160 uOfferOwnerID = sleOffer->getFieldAccount160(sfAccount);
STAmount saTakerGets = sleOffer->getFieldAmount(sfTakerGets); const STAmount& saTakerGets = sleOffer->getFieldAmount(sfTakerGets);
STAmount saTakerPays = sleOffer->getFieldAmount(sfTakerPays); const STAmount& saTakerPays = sleOffer->getFieldAmount(sfTakerPays);
STAmount saOwnerFunds; STAmount saOwnerFunds;
if (uTakerGetsIssuerID == uOfferOwnerID) if (uTakerGetsIssuerID == uOfferOwnerID)
@@ -1907,7 +1910,7 @@ void NetworkOPs::getBookPage(Ledger::pointer lpLedger, const uint160& uTakerPays
} }
else else
{ {
boost::unordered_map<uint160, STAmount>::const_iterator umBalanceEntry = umBalance.find(uOfferOwnerID); std::map<uint160, STAmount>::const_iterator umBalanceEntry = umBalance.find(uOfferOwnerID);
if (umBalanceEntry != umBalance.end()) if (umBalanceEntry != umBalance.end())
{ {
@@ -1964,30 +1967,27 @@ void NetworkOPs::getBookPage(Ledger::pointer lpLedger, const uint160& uTakerPays
// cLog(lsINFO) << boost::str(boost::format("getBookPage: saDirRate=%s") % saDirRate.getText()); // cLog(lsINFO) << boost::str(boost::format("getBookPage: saDirRate=%s") % saDirRate.getText());
// cLog(lsINFO) << boost::str(boost::format("getBookPage: multiply=%s") % STAmount::multiply(saTakerGetsFunded, saDirRate).getFullText()); // cLog(lsINFO) << boost::str(boost::format("getBookPage: multiply=%s") % STAmount::multiply(saTakerGetsFunded, saDirRate).getFullText());
// cLog(lsINFO) << boost::str(boost::format("getBookPage: multiply=%s") % STAmount::multiply(saTakerGetsFunded, saDirRate, saTakerPays).getFullText()); // cLog(lsINFO) << boost::str(boost::format("getBookPage: multiply=%s") % STAmount::multiply(saTakerGetsFunded, saDirRate, saTakerPays).getFullText());
STAmount saTakerPaysFunded;
saTakerGetsFunded = saOwnerFundsLimit;
saTakerPaysFunded = std::min(saTakerPays, STAmount::multiply(saTakerGetsFunded, saDirRate, saTakerPays));
// Only provide, if not fully funded. // Only provide, if not fully funded.
jvOffer["taker_gets_funded"] = saTakerGetsFunded.getJson(0);
jvOffer["taker_pays_funded"] = saTakerPaysFunded.getJson(0); saTakerGetsFunded = saOwnerFundsLimit;
saTakerGetsFunded.setJson(jvOffer["taker_gets_funded"]);
std::min(saTakerPays, STAmount::multiply(saTakerGetsFunded, saDirRate, saTakerPays)).setJson(jvOffer["taker_pays_funded"]);
} }
STAmount saOwnerPays = QUALITY_ONE == uOfferRate STAmount saOwnerPays = (QUALITY_ONE == uOfferRate)
? saTakerGetsFunded ? saTakerGetsFunded
: std::min(saOwnerFunds, STAmount::multiply(saTakerGetsFunded, STAmount(CURRENCY_ONE, ACCOUNT_ONE, uOfferRate, -9))); : std::min(saOwnerFunds, STAmount::multiply(saTakerGetsFunded, STAmount(CURRENCY_ONE, ACCOUNT_ONE, uOfferRate, -9)));
STAmount saOwnerBalance = saOwnerFunds-saOwnerPays; umBalance[uOfferOwnerID] = saOwnerFunds - saOwnerPays;
umBalance[uOfferOwnerID] = saOwnerBalance;
if (!saOwnerFunds.isZero() || uOfferOwnerID == uTakerID) if (!saOwnerFunds.isZero() || uOfferOwnerID == uTakerID)
{ {
// Only provide funded offers and offers of the taker. // Only provide funded offers and offers of the taker.
jvOffer["quality"] = saDirRate.getText(); Json::Value& jvOf = jvOffers.append(jvOffer);
jvOf["quality"] = saDirRate.getText();
jvOffers.append(jvOffer); --iLeft;
} }
if (!lesActive.dirNext(uTipIndex, sleOfferDir, uBookEntry, uOfferIndex)) if (!lesActive.dirNext(uTipIndex, sleOfferDir, uBookEntry, uOfferIndex))
@@ -2001,7 +2001,6 @@ void NetworkOPs::getBookPage(Ledger::pointer lpLedger, const uint160& uTakerPays
} }
} }
jvResult["offers"] = jvOffers;
// jvResult["marker"] = Json::Value(Json::arrayValue); // jvResult["marker"] = Json::Value(Json::arrayValue);
// jvResult["nodes"] = Json::Value(Json::arrayValue); // jvResult["nodes"] = Json::Value(Json::arrayValue);
} }

View File

@@ -212,7 +212,7 @@ TER OfferCreateTransactor::takeOffers(
cLog(lsDEBUG) << "takeOffers: considering offer : " << sleOffer->getJson(0); cLog(lsDEBUG) << "takeOffers: considering offer : " << sleOffer->getJson(0);
const uint160 uOfferOwnerID = sleOffer->getFieldAccount(sfAccount).getAccountID(); const uint160 uOfferOwnerID = sleOffer->getFieldAccount160(sfAccount);
STAmount saOfferPays = sleOffer->getFieldAmount(sfTakerGets); STAmount saOfferPays = sleOffer->getFieldAmount(sfTakerGets);
STAmount saOfferGets = sleOffer->getFieldAmount(sfTakerPays); STAmount saOfferGets = sleOffer->getFieldAmount(sfTakerPays);

View File

@@ -1064,12 +1064,12 @@ Json::Value RPCHandler::doAccountLines(Json::Value jvRequest, int& cost, ScopedL
} }
AccountState::pointer as = mNetOps->getAccountState(lpLedger, raAccount); AccountState::pointer as = mNetOps->getAccountState(lpLedger, raAccount);
MasterLockHolder.unlock();
if (lpLedger->isImmutable())
MasterLockHolder.unlock();
if (as) if (as)
{ {
Json::Value jsonLines(Json::arrayValue);
jvResult["account"] = raAccount.humanAccountID(); jvResult["account"] = raAccount.humanAccountID();
// XXX This is wrong, we do access the current ledger and do need to worry about changes. // XXX This is wrong, we do access the current ledger and do need to worry about changes.
@@ -1077,6 +1077,7 @@ Json::Value RPCHandler::doAccountLines(Json::Value jvRequest, int& cost, ScopedL
AccountItems rippleLines(raAccount.getAccountID(), lpLedger, AccountItem::pointer(new RippleState())); AccountItems rippleLines(raAccount.getAccountID(), lpLedger, AccountItem::pointer(new RippleState()));
Json::Value& jsonLines = (jvResult["lines"] = Json::arrayValue);
BOOST_FOREACH(AccountItem::ref item, rippleLines.getItems()) BOOST_FOREACH(AccountItem::ref item, rippleLines.getItems())
{ {
RippleState* line=(RippleState*)item.get(); RippleState* line=(RippleState*)item.get();
@@ -1087,7 +1088,7 @@ Json::Value RPCHandler::doAccountLines(Json::Value jvRequest, int& cost, ScopedL
STAmount saLimit = line->getLimit(); STAmount saLimit = line->getLimit();
STAmount saLimitPeer = line->getLimitPeer(); STAmount saLimitPeer = line->getLimitPeer();
Json::Value jPeer = Json::Value(Json::objectValue); Json::Value& jPeer = jsonLines.append(Json::objectValue);
jPeer["account"] = RippleAddress::createHumanAccountID(line->getAccountIDPeer()); jPeer["account"] = RippleAddress::createHumanAccountID(line->getAccountIDPeer());
// Amount reported is positive if current account holds other account's IOUs. // Amount reported is positive if current account holds other account's IOUs.
@@ -1098,11 +1099,8 @@ Json::Value RPCHandler::doAccountLines(Json::Value jvRequest, int& cost, ScopedL
jPeer["limit_peer"] = saLimitPeer.getText(); jPeer["limit_peer"] = saLimitPeer.getText();
jPeer["quality_in"] = static_cast<Json::UInt>(line->getQualityIn()); jPeer["quality_in"] = static_cast<Json::UInt>(line->getQualityIn());
jPeer["quality_out"] = static_cast<Json::UInt>(line->getQualityOut()); jPeer["quality_out"] = static_cast<Json::UInt>(line->getQualityOut());
jsonLines.append(jPeer);
} }
} }
jvResult["lines"] = jsonLines;
} }
else else
{ {
@@ -1147,11 +1145,14 @@ Json::Value RPCHandler::doAccountOffers(Json::Value jvRequest, int& cost, Scoped
jvResult["account_index"] = iIndex; jvResult["account_index"] = iIndex;
AccountState::pointer as = mNetOps->getAccountState(lpLedger, raAccount); AccountState::pointer as = mNetOps->getAccountState(lpLedger, raAccount);
MasterLockHolder.unlock();
if (lpLedger->isImmutable())
MasterLockHolder.unlock();
if (as) if (as)
{ {
Json::Value jsonLines(Json::arrayValue); Json::Value& jsonLines = jvResult["offers"];
jsonLines = Json::arrayValue;
AccountItems offers(raAccount.getAccountID(), lpLedger, AccountItem::pointer(new Offer())); AccountItems offers(raAccount.getAccountID(), lpLedger, AccountItem::pointer(new Offer()));
BOOST_FOREACH(AccountItem::ref item, offers.getItems()) BOOST_FOREACH(AccountItem::ref item, offers.getItems())
@@ -1162,16 +1163,15 @@ Json::Value RPCHandler::doAccountOffers(Json::Value jvRequest, int& cost, Scoped
STAmount takerGets = offer->getTakerGets(); STAmount takerGets = offer->getTakerGets();
//RippleAddress account = offer->getAccount(); //RippleAddress account = offer->getAccount();
Json::Value obj = Json::Value(Json::objectValue); Json::Value& obj = jsonLines.append(obj);
obj = Json::Value(Json::objectValue);
//obj["account"] = account.humanAccountID(); //obj["account"] = account.humanAccountID();
obj["taker_pays"] = takerPays.getJson(0); takerPays.setJson(obj["taker_pays"]);
obj["taker_gets"] = takerGets.getJson(0); takerGets.setJson(obj["taker_gets"]);
obj["seq"] = offer->getSeq(); obj["seq"] = offer->getSeq();
jsonLines.append(obj);
} }
jvResult["offers"] = jsonLines;
} }
else else
{ {
@@ -1868,10 +1868,16 @@ Json::Value RPCHandler::doLedger(Json::Value jvRequest, int& cost, ScopedLock& M
| (bTransactions ? LEDGER_JSON_DUMP_TXRP : 0) | (bTransactions ? LEDGER_JSON_DUMP_TXRP : 0)
| (bAccounts ? LEDGER_JSON_DUMP_STATE : 0); | (bAccounts ? LEDGER_JSON_DUMP_STATE : 0);
Json::Value ret(Json::objectValue); if ((bFull || bAccounts) && !lpLedger->isImmutable())
{ // For full or accounts, it's cheaper to snapshot
lpLedger = boost::make_shared<Ledger>(*lpLedger, false);
assert(lpLedger->isImmutable());
}
if (lpLedger->isClosed()) if (lpLedger->isImmutable())
MasterLockHolder.unlock(); MasterLockHolder.unlock();
Json::Value ret(Json::objectValue);
lpLedger->addJson(ret, iOptions); lpLedger->addJson(ret, iOptions);
return ret; return ret;
@@ -1957,7 +1963,7 @@ Json::Value RPCHandler::doAccountTransactions(Json::Value jvRequest, int& cost,
Json::Value ret(Json::objectValue); Json::Value ret(Json::objectValue);
ret["account"] = raAccount.humanAccountID(); ret["account"] = raAccount.humanAccountID();
ret["transactions"] = Json::arrayValue; Json::Value& jvTxns = (ret["transactions"] = Json::arrayValue);
if (bBinary) if (bBinary)
{ {
@@ -1967,15 +1973,14 @@ Json::Value RPCHandler::doAccountTransactions(Json::Value jvRequest, int& cost,
for (std::vector<NetworkOPs::txnMetaLedgerType>::const_iterator it = txns.begin(), end = txns.end(); for (std::vector<NetworkOPs::txnMetaLedgerType>::const_iterator it = txns.begin(), end = txns.end();
it != end; ++it) it != end; ++it)
{ {
Json::Value jvObj(Json::objectValue); Json::Value& jvObj = jvTxns.append(Json::objectValue);
uint32 uLedgerIndex = it->get<2>();
uint32 uLedgerIndex = it->get<2>();
jvObj["tx_blob"] = it->get<0>(); jvObj["tx_blob"] = it->get<0>();
jvObj["meta"] = it->get<1>(); jvObj["meta"] = it->get<1>();
jvObj["ledger_index"] = uLedgerIndex; jvObj["ledger_index"] = uLedgerIndex;
jvObj["validated"] = bValidated && uValidatedMin <= uLedgerIndex && uValidatedMax >= uLedgerIndex; jvObj["validated"] = bValidated && uValidatedMin <= uLedgerIndex && uValidatedMax >= uLedgerIndex;
ret["transactions"].append(jvObj);
} }
} }
else else
@@ -1984,7 +1989,7 @@ Json::Value RPCHandler::doAccountTransactions(Json::Value jvRequest, int& cost,
for (std::vector< std::pair<Transaction::pointer, TransactionMetaSet::pointer> >::iterator it = txns.begin(), end = txns.end(); it != end; ++it) for (std::vector< std::pair<Transaction::pointer, TransactionMetaSet::pointer> >::iterator it = txns.begin(), end = txns.end(); it != end; ++it)
{ {
Json::Value jvObj(Json::objectValue); Json::Value& jvObj = jvTxns.append(Json::objectValue);
if (it->first) if (it->first)
jvObj["tx"] = it->first->getJson(1); jvObj["tx"] = it->first->getJson(1);
@@ -1997,7 +2002,6 @@ Json::Value RPCHandler::doAccountTransactions(Json::Value jvRequest, int& cost,
jvObj["validated"] = bValidated && uValidatedMin <= uLedgerIndex && uValidatedMax >= uLedgerIndex; jvObj["validated"] = bValidated && uValidatedMin <= uLedgerIndex && uValidatedMax >= uLedgerIndex;
} }
ret["transactions"].append(jvObj);
} }
} }
@@ -2174,6 +2178,8 @@ Json::Value RPCHandler::doLogRotate(Json::Value, int& cost, ScopedLock& MasterLo
// } // }
Json::Value RPCHandler::doWalletPropose(Json::Value jvRequest, int& cost, ScopedLock& MasterLockHolder) Json::Value RPCHandler::doWalletPropose(Json::Value jvRequest, int& cost, ScopedLock& MasterLockHolder)
{ {
MasterLockHolder.unlock();
RippleAddress naSeed; RippleAddress naSeed;
RippleAddress naAccount; RippleAddress naAccount;
@@ -2672,7 +2678,8 @@ Json::Value RPCHandler::doLedgerEntry(Json::Value jvRequest, int& cost, ScopedLo
if (!lpLedger) if (!lpLedger)
return jvResult; return jvResult;
if (lpLedger->isClosed())
if (lpLedger->isImmutable())
MasterLockHolder.unlock(); MasterLockHolder.unlock();
uint256 uNodeIndex; uint256 uNodeIndex;
@@ -2840,7 +2847,7 @@ Json::Value RPCHandler::doLedgerEntry(Json::Value jvRequest, int& cost, ScopedLo
jvResult["error"] = "unknownOption"; jvResult["error"] = "unknownOption";
} }
if (!!uNodeIndex) if (uNodeIndex.isNonZero())
{ {
SLE::pointer sleNode = mNetOps->getSLEi(lpLedger, uNodeIndex); SLE::pointer sleNode = mNetOps->getSLEi(lpLedger, uNodeIndex);

View File

@@ -978,7 +978,7 @@ TER RippleCalc::calcNodeAdvance(
{ {
// Got a new offer. // Got a new offer.
sleOffer = lesActive.entryCache(ltOFFER, uOfferIndex); sleOffer = lesActive.entryCache(ltOFFER, uOfferIndex);
uOfrOwnerID = sleOffer->getFieldAccount(sfAccount).getAccountID(); uOfrOwnerID = sleOffer->getFieldAccount160(sfAccount);
saTakerPays = sleOffer->getFieldAmount(sfTakerPays); saTakerPays = sleOffer->getFieldAmount(sfTakerPays);
saTakerGets = sleOffer->getFieldAmount(sfTakerGets); saTakerGets = sleOffer->getFieldAmount(sfTakerGets);
@@ -3136,7 +3136,7 @@ void TransactionEngine::calcOfferBridgeNext(
SLE::pointer sleOffer = entryCache(ltOFFER, uOfferIndex); SLE::pointer sleOffer = entryCache(ltOFFER, uOfferIndex);
uint160 uOfferOwnerID = sleOffer->getFieldAccount(sfAccount).getAccountID(); uint160 uOfferOwnerID = sleOffer->getFieldAccount160(sfAccount);
STAmount saOfferPays = sleOffer->getFieldAmount(sfTakerGets); STAmount saOfferPays = sleOffer->getFieldAmount(sfTakerGets);
STAmount saOfferGets = sleOffer->getFieldAmount(sfTakerPays); STAmount saOfferGets = sleOffer->getFieldAmount(sfTakerPays);

View File

@@ -473,6 +473,7 @@ public:
static bool issuerFromString(uint160& uDstIssuer, const std::string& sIssuer); static bool issuerFromString(uint160& uDstIssuer, const std::string& sIssuer);
Json::Value getJson(int) const; Json::Value getJson(int) const;
void setJson(Json::Value&) const;
STAmount getRound() const; STAmount getRound() const;
void roundSelf(); void roundSelf();

View File

@@ -9,12 +9,11 @@ SETUP_LOG();
bool TransactionEngine::checkInvariants(TER result, const SerializedTransaction& txn, TransactionEngineParams params) bool TransactionEngine::checkInvariants(TER result, const SerializedTransaction& txn, TransactionEngineParams params)
{ {
#if 0 #if 0
RippleAddress srcAccount = txn.getFieldAccount(sfAccount);
uint32 txnSeq = txn.getFieldU32(sfSequence); uint32 txnSeq = txn.getFieldU32(sfSequence);
LedgerEntryAction leaAction; LedgerEntryAction leaAction;
uint256 srcActId = Ledger::getAccountRootIndex(srcAccount.getAccountID()); uint256 srcActId = Ledger::getAccountRootIndex(txn.getFieldAccount(sfAccount));
SLE::pointer origSrcAct = mLedger->getSLE(srcActId); SLE::pointer origSrcAct = mLedger->getSLE(srcActId);
SLE::pointer newSrcAct = mNodes.getEntry(srcActId, leaAction); SLE::pointer newSrcAct = mNodes.getEntry(srcActId, leaAction);

View File

@@ -97,7 +97,7 @@ TER Transactor::checkSig()
{ {
// Consistency: Check signature // Consistency: Check signature
// Verify the transaction's signing public key is the key authorized for signing. // Verify the transaction's signing public key is the key authorized for signing.
if (mHasAuthKey && mSigningPubKey.getAccountID() == mTxnAccount->getFieldAccount(sfRegularKey).getAccountID()) if (mHasAuthKey && mSigningPubKey.getAccountID() == mTxnAccount->getFieldAccount160(sfRegularKey))
{ {
// Authorized to continue. // Authorized to continue.
nothing(); nothing();