mirror of
https://github.com/Xahau/xahaud.git
synced 2025-12-06 17:27:52 +00:00
6f2e4b8172
and closes the ledger, opening a new one. The sequence number of the new open ledger is returned.
84 lines
2.2 KiB
C++
84 lines
2.2 KiB
C++
#ifndef __LEDGERMASTER__
|
|
#define __LEDGERMASTER__
|
|
|
|
#include "Ledger.h"
|
|
#include "LedgerHistory.h"
|
|
#include "Peer.h"
|
|
#include "types.h"
|
|
#include "Transaction.h"
|
|
#include "TransactionEngine.h"
|
|
|
|
// Tracks the current ledger and any ledgers in the process of closing
|
|
// Tracks ledger history
|
|
// Tracks held transactions
|
|
|
|
class LedgerMaster
|
|
{
|
|
boost::recursive_mutex mLock;
|
|
|
|
TransactionEngine mEngine;
|
|
|
|
Ledger::pointer mCurrentLedger; // The ledger we are currently processiong
|
|
Ledger::pointer mFinalizedLedger; // The ledger that most recently closed
|
|
|
|
LedgerHistory mLedgerHistory;
|
|
|
|
std::map<uint256, Transaction::pointer> mHeldTransactionsByID;
|
|
|
|
void applyFutureTransactions(uint32 ledgerIndex);
|
|
bool isValidTransaction(const Transaction::pointer& trans);
|
|
bool isTransactionOnFutureList(const Transaction::pointer& trans);
|
|
|
|
public:
|
|
|
|
LedgerMaster() { ; }
|
|
|
|
uint32 getCurrentLedgerIndex();
|
|
|
|
ScopedLock getLock() { return ScopedLock(mLock); }
|
|
|
|
// The current ledger is the ledger we believe new transactions should go in
|
|
Ledger::pointer getCurrentLedger() { return mCurrentLedger; }
|
|
|
|
// The finalized ledger is the last closed/accepted ledger
|
|
Ledger::pointer getClosedLedger() { return mFinalizedLedger; }
|
|
|
|
TER doTransaction(const SerializedTransaction& txn, TransactionEngineParams params);
|
|
|
|
void pushLedger(Ledger::ref newLedger);
|
|
void pushLedger(Ledger::ref newLCL, Ledger::ref newOL);
|
|
void storeLedger(Ledger::ref);
|
|
|
|
void switchLedgers(Ledger::ref lastClosed, Ledger::ref newCurrent);
|
|
|
|
Ledger::pointer closeLedger();
|
|
|
|
Ledger::pointer getLedgerBySeq(uint32 index)
|
|
{
|
|
if (mCurrentLedger && (mCurrentLedger->getLedgerSeq() == index))
|
|
return mCurrentLedger;
|
|
if (mFinalizedLedger && (mFinalizedLedger->getLedgerSeq() == index))
|
|
return mFinalizedLedger;
|
|
return mLedgerHistory.getLedgerBySeq(index);
|
|
}
|
|
|
|
Ledger::pointer getLedgerByHash(const uint256& hash)
|
|
{
|
|
if (!hash)
|
|
return mCurrentLedger;
|
|
|
|
if (mCurrentLedger && (mCurrentLedger->getHash() == hash))
|
|
return mCurrentLedger;
|
|
|
|
if (mFinalizedLedger && (mFinalizedLedger->getHash() == hash))
|
|
return mFinalizedLedger;
|
|
|
|
return mLedgerHistory.getLedgerByHash(hash);
|
|
}
|
|
|
|
bool addHeldTransaction(const Transaction::pointer& trans);
|
|
};
|
|
|
|
#endif
|
|
// vim:ts=4
|