Loading...
Searching...
No Matches
resdb::TransactionCollector Class Reference

#include <transaction_collector.h>

Public Types

typedef std::list< std::unique_ptr< RequestInfo > > CollectorDataType
 

Public Member Functions

 TransactionCollector (uint64_t seq, TransactionExecutor *executor, bool enable_viewchange=false)
 
 ~TransactionCollector ()=default
 
int SetContextList (uint64_t seq, std::vector< std::unique_ptr< Context > > context)
 
bool HasClientContextList (uint64_t seq) const
 
std::vector< std::unique_ptr< Context > > FetchContextList (uint64_t seq)
 
int AddRequest (std::unique_ptr< Request > request, const SignatureInfo &signature, bool is_main_request, std::function< void(const Request &, int received_count, CollectorDataType *data, std::atomic< TransactionStatue > *status, bool force)> call_back)
 
std::vector< RequestInfo > GetPreparedProof ()
 
TransactionStatue GetStatus () const
 
uint64_t Seq ()
 
bool IsPrepared ()
 
std::vector< std::string > GetAllStoredHash ()
 

Detailed Description

Definition at line 79 of file transaction_collector.h.

Member Typedef Documentation

◆ CollectorDataType

typedef std::list<std::unique_ptr<RequestInfo> > resdb::TransactionCollector::CollectorDataType

Definition at line 98 of file transaction_collector.h.

Constructor & Destructor Documentation

◆ TransactionCollector()

resdb::TransactionCollector::TransactionCollector ( uint64_t  seq,
TransactionExecutor *  executor,
bool  enable_viewchange = false 
)
inline

Definition at line 81 of file transaction_collector.h.

◆ ~TransactionCollector()

resdb::TransactionCollector::~TransactionCollector ( )
default

Member Function Documentation

◆ AddRequest()

int resdb::TransactionCollector::AddRequest ( std::unique_ptr< Request >  request,
const SignatureInfo &  signature,
bool  is_main_request,
std::function< void(const Request &, int received_count, CollectorDataType *data, std::atomic< TransactionStatue > *status, bool force)>  call_back 
)

Definition at line 69 of file transaction_collector.cpp.

◆ FetchContextList()

std::vector< std::unique_ptr< Context > > resdb::TransactionCollector::FetchContextList ( uint64_t  seq)

Definition at line 50 of file transaction_collector.cpp.

◆ GetAllStoredHash()

std::vector< std::string > resdb::TransactionCollector::GetAllStoredHash ( )

Definition at line 226 of file transaction_collector.cpp.

◆ GetPreparedProof()

std::vector< RequestInfo > resdb::TransactionCollector::GetPreparedProof ( )

Definition at line 58 of file transaction_collector.cpp.

◆ GetStatus()

TransactionStatue resdb::TransactionCollector::GetStatus ( ) const

Definition at line 32 of file transaction_collector.cpp.

◆ HasClientContextList()

bool resdb::TransactionCollector::HasClientContextList ( uint64_t  seq) const

Definition at line 43 of file transaction_collector.cpp.

◆ IsPrepared()

bool resdb::TransactionCollector::IsPrepared ( )

Definition at line 30 of file transaction_collector.cpp.

◆ Seq()

uint64_t resdb::TransactionCollector::Seq ( )

Definition at line 28 of file transaction_collector.cpp.

◆ SetContextList()

int resdb::TransactionCollector::SetContextList ( uint64_t  seq,
std::vector< std::unique_ptr< Context > >  context 
)

Definition at line 34 of file transaction_collector.cpp.