Change NetOps processTransaction to use ref param

This commit is contained in:
Miguel Portilla
2015-07-09 13:24:29 -04:00
committed by Mark Travis
parent 6374aad9bc
commit 6d60f19d73
6 changed files with 14 additions and 23 deletions

View File

@@ -238,7 +238,7 @@ public:
void submitTransaction (Job&, STTx::pointer) override;
void processTransaction (
Transaction::pointer transaction,
Transaction::pointer& transaction,
bool bAdmin, bool bLocal, FailHard failType) override;
/**
@@ -989,7 +989,7 @@ void NetworkOPsImp::submitTransaction (Job&, STTx::pointer iTrans)
FailHard::no));
}
void NetworkOPsImp::processTransaction (Transaction::pointer transaction,
void NetworkOPsImp::processTransaction (Transaction::pointer& transaction,
bool bAdmin, bool bLocal, FailHard failType)
{
auto ev = m_job_queue.getLoadEventAP (jtTXN_PROC, "ProcessTXN");
@@ -1168,7 +1168,6 @@ void NetworkOPsImp::apply (std::unique_lock<std::mutex>& lock)
// transaction should be held
m_journal.debug << "Transaction should be held: " << e.result;
e.transaction->setStatus (HELD);
getApp().getMasterTransaction().canonicalize (&e.transaction);
m_ledgerMaster.addHeldTransaction (e.transaction);
}
}

View File

@@ -168,7 +168,7 @@ public:
* @param bLocal Client submission.
* @param failType fail_hard setting from transaction submission.
*/
virtual void processTransaction (Transaction::pointer transaction,
virtual void processTransaction (Transaction::pointer& transaction,
bool bAdmin, bool bLocal, FailHard failType) = 0;
virtual Transaction::pointer findTransactionByID (uint256 const& transactionID) = 0;
virtual int findTransactionsByDestination (std::list<Transaction::pointer>&,

View File

@@ -39,7 +39,7 @@ public:
// return value: true = we had the transaction already
bool inLedger (uint256 const& hash, std::uint32_t ledger);
bool canonicalize (Transaction::pointer* pTransaction);
void canonicalize (Transaction::pointer* pTransaction);
void sweep (void);
TaggedCache <uint256, Transaction>& getCache();

View File

@@ -95,25 +95,17 @@ STTx::pointer TransactionMaster::fetch (std::shared_ptr<SHAMapItem> const& item,
return txn;
}
bool TransactionMaster::canonicalize (Transaction::pointer* pTransaction)
void
TransactionMaster::canonicalize(Transaction::pointer* pTransaction)
{
Transaction::pointer txn (*pTransaction);
uint256 tid = txn->getID ();
if (!tid)
return false;
// VFALCO NOTE canonicalize can change the value of txn!
if (mCache.canonicalize (tid, txn))
uint256 const tid = (*pTransaction)->getID();
if (tid != zero)
{
Transaction::pointer txn(*pTransaction);
// VFALCO NOTE canonicalize can change the value of txn!
mCache.canonicalize(tid, txn);
*pTransaction = txn;
return true;
}
// VFALCO NOTE I am unsure if this is necessary but better safe than sorry.
*pTransaction = txn;
return false;
}
void TransactionMaster::sweep (void)

View File

@@ -133,7 +133,7 @@ std::uint32_t TxnSignApiFacade::getSeq () const
}
void TxnSignApiFacade::processTransaction (
Transaction::ref tpTrans,
Transaction::pointer& transaction,
bool bAdmin,
bool bLocal,
NetworkOPs::FailHard failType)
@@ -141,7 +141,7 @@ void TxnSignApiFacade::processTransaction (
if (!netOPs_) // Unit testing.
return;
netOPs_->processTransaction (tpTrans, bAdmin, bLocal, failType);
netOPs_->processTransaction(transaction, bAdmin, bLocal, failType);
}
bool TxnSignApiFacade::findPathsForOneIssuer (

View File

@@ -75,7 +75,7 @@ public:
STPath& fullLiquidityPath) const;
void processTransaction (
Transaction::ref tpTrans,
Transaction::pointer& transaction,
bool bAdmin,
bool bLocal,
NetworkOPs::FailHard failType);