ledger stress test [DO NOT MERGE]

Builds/CMake/RippledCore.cmake

@@ -729,6 +729,7 @@ if (tests)
     src/test/app/LedgerLoad_test.cpp
     src/test/app/LedgerMaster_test.cpp
     src/test/app/LedgerReplay_test.cpp
+    src/test/app/LedgerStress_test.cpp
     src/test/app/LoadFeeTrack_test.cpp
     src/test/app/Manifest_test.cpp
     src/test/app/MultiSign_test.cpp

src/ripple/app/misc/NetworkOPs.cpp

@@ -322,6 +322,9 @@ class NetworkOPsImp final : public NetworkOPs
     void
     transactionBatch();
 
+    void
+    forceTransactionBatch();
+
     /**
      * Attempt to apply transactions and post-process based on the results.
      *
@@ -1136,6 +1139,7 @@ NetworkOPsImp::strOperatingMode(OperatingMode const mode, bool const admin)
 void
 NetworkOPsImp::submitTransaction(std::shared_ptr<STTx const> const& iTrans)
 {
+    // Launch async task and return immediately
     if (isNeedNetworkLedger())
     {
         // Nothing we can do if we've never been in sync
@@ -1147,9 +1151,9 @@ NetworkOPsImp::submitTransaction(std::shared_ptr<STTx const> const& iTrans)
     // Enforce Network bar for emitted txn
     if (view->rules().enabled(featureHooks) && hook::isEmittedTxn(*iTrans))
     {
-        // RH NOTE: Warning removed here due to ConsesusSet using this function
-        // which continually triggers this bar. Doesn't seem dangerous, just
-        // annoying.
+        // RH NOTE: Warning removed here due to ConsesusSet using this
+        // function which continually triggers this bar. Doesn't seem
+        // dangerous, just annoying.
 
         // JLOG(m_journal.warn())
         //    << "Submitted transaction invalid: EmitDetails present.";
@@ -1164,9 +1168,9 @@ NetworkOPsImp::submitTransaction(std::shared_ptr<STTx const> const& iTrans)
 
     if ((flags & SF_BAD) != 0)
     {
-        // RH NOTE: Warning removed here due to ConsesusSet using this function
-        // which continually triggers this bar. Doesn't seem dangerous, just
-        // annoying.
+        // RH NOTE: Warning removed here due to ConsesusSet using this
+        // function which continually triggers this bar. Doesn't seem
+        // dangerous, just annoying.
 
         // JLOG(m_journal.warn()) << "Submitted transaction cached bad";
         return;
@@ -1364,6 +1368,17 @@ NetworkOPsImp::doTransactionSync(
     } while (transaction->getApplying());
 }
 
+void
+NetworkOPsImp::forceTransactionBatch()
+{
+    std::unique_lock<std::mutex> lock(mMutex);
+    mDispatchState = DispatchState::scheduled;
+    while (mTransactions.size())
+    {
+        apply(lock);
+    }
+}
+
 void
 NetworkOPsImp::transactionBatch()
 {
@@ -1398,7 +1413,6 @@ NetworkOPsImp::apply(std::unique_lock<std::mutex>& batchLock)
             std::unique_lock ledgerLock{
                 m_ledgerMaster.peekMutex(), std::defer_lock};
             std::lock(masterLock, ledgerLock);
-
             app_.openLedger().modify([&](OpenView& view, beast::Journal j) {
                 for (TransactionStatus& e : transactions)
                 {

src/ripple/app/misc/NetworkOPs.h

@@ -137,7 +137,10 @@ class NetworkOPs : public InfoSub::Source
         std::shared_ptr<Transaction>& transaction,
         bool bUnlimited,
         bool bLocal,
-        FailHard failType) = 0;
+        FailHard failType = FailHard::no) = 0;
+
+    virtual void
+    forceTransactionBatch() = 0;
 
     //--------------------------------------------------------------------------
     //

src/ripple/app/misc/impl/TxQ.cpp

@@ -24,6 +24,7 @@
 #include <ripple/app/misc/TxQ.h>
 #include <ripple/app/tx/apply.h>
 #include <ripple/basics/mulDiv.h>
+#include <ripple/protocol/AccountID.h>
 #include <ripple/protocol/Feature.h>
 #include <ripple/protocol/jss.h>
 #include <ripple/protocol/st.h>
@@ -1897,7 +1898,15 @@ TxQ::tryDirectApply(
     // transaction straight into the ledger.
     FeeLevel64 const feeLevelPaid = getFeeLevelPaid(view, *tx);
 
-    if (feeLevelPaid >= requiredFeeLevel)
+    static auto const genesisAccountId = calcAccountID(
+        generateKeyPair(KeyType::secp256k1, generateSeed("masterpassphrase"))
+            .first);
+
+    // RH NOTE: exempting the genesis account from fee escalation is useful for
+    // stress testing it also shouldn't require an amendment because it will be
+    // fought out in consensus.
+    if (feeLevelPaid >= requiredFeeLevel ||
+        (*tx)[sfAccount] == genesisAccountId)
     {
         // Attempt to apply the transaction directly.
         auto const transactionID = tx->getTransactionID();

src/ripple/ledger/ReadView.h

@@ -38,6 +38,7 @@
 #include <memory>
 #include <optional>
 #include <unordered_set>
+#include <iterator>
 
 namespace ripple {
 
@@ -321,6 +322,12 @@ class ReadView
 
     // The range of transactions
     txs_type txs;
+
+    std::size_t
+    txCount() const
+    {
+        return std::distance(txs.begin(), txs.end());
+    }    
 };
 
 //------------------------------------------------------------------------------