ARCHIVE/rippled
1
0
Fork 0
mirror of https://github.com/XRPLF/rippled.git synced 2025-11-26 22:15:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

Process batch during OpenLedger::modify

Browse Source
This commit is contained in:
JoelKatz
2015-10-15 15:26:08 -07:00
committed by Vinnie Falco
parent 3e8e2c2fee
commit 0622e4fd44
1 changed files with 17 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
src/ripple/app/misc/NetworkOPs.cpp
View File

@@ -832,25 +832,25 @@ void NetworkOPsImp::apply (std::unique_lock<std::mutex>& batchLock)
std::lock_guard <std::recursive_mutex> lock ( std::lock_guard <std::recursive_mutex> lock (
m_ledgerMaster.peekMutex()); m_ledgerMaster.peekMutex());
for (TransactionStatus& e : transactions)
{
ApplyFlags flags = tapNONE;
// All code paths to this point are gated by validity checks.
flags = flags | tapNO_CHECK_SIGN;
if (e.admin)
flags = flags | tapADMIN;
// VFALCO Should do the loop inside modify()
app_.openLedger().modify( app_.openLedger().modify(
[&](OpenView& view, beast::Journal j) [&](OpenView& view, beast::Journal j)
{ {
bool changed = false;
for (TransactionStatus& e : transactions)
{
// we check before addingto the batch
ApplyFlags flags = tapNO_CHECK_SIGN;
if (e.admin)
flags = flags | tapADMIN;
auto const result = ripple::apply(app_, view, auto const result = ripple::apply(app_, view,
*e.transaction->getSTransaction(), flags, j); *e.transaction->getSTransaction(), flags, j);
e.result = result.first; e.result = result.first;
e.applied = result.second; e.applied = result.second;
return result.second; changed = changed || result.second;
});
} }
return changed;
});
} }
auto newOL = app_.openLedger().current(); auto newOL = app_.openLedger().current();