Loading...
Searching...
No Matches
Public Member Functions | List of all members
resdb::ConsensusManagerGeoPBFT Class Reference

#include <consensus_manager_geo_pbft.h>

Inheritance diagram for resdb::ConsensusManagerGeoPBFT:
resdb::ConsensusManagerPBFT resdb::ConsensusManager resdb::ServiceInterface

Public Member Functions

 ConsensusManagerGeoPBFT (const ResDBConfig &config, std::unique_ptr< GeoTransactionExecutor > local_executor, std::unique_ptr< GeoGlobalExecutor > global_executor)
 
virtual ~ConsensusManagerGeoPBFT ()=default
 
int ConsensusCommit (std::unique_ptr< Context > context, std::unique_ptr< Request > request) override
 
- Public Member Functions inherited from resdb::ConsensusManagerPBFT
 ConsensusManagerPBFT (const ResDBConfig &config, std::unique_ptr< TransactionManager > executor, std::unique_ptr< CustomQuery > query_executor=nullptr)
 
virtual ~ConsensusManagerPBFT ()=default
 
int ConsensusCommit (std::unique_ptr< Context > context, std::unique_ptr< Request > request) override
 
std::vector< ReplicaInfo > GetReplicas () override
 
uint32_t GetPrimary () override
 
uint32_t GetVersion () override
 
void SetPrimary (uint32_t primary, uint64_t version) override
 
void Start () override
 
void SetupPerformanceDataFunc (std::function< std::string()> func)
 
void SetPreVerifyFunc (std::function< bool(const Request &)>)
 
void SetNeedCommitQC (bool need_qc)
 
- Public Member Functions inherited from resdb::ConsensusManager
 ConsensusManager (const ResDBConfig &config)
 
virtual ~ConsensusManager ()
 
virtual int Process (std::unique_ptr< Context > context, std::unique_ptr< DataInfo > request_info)
 
bool IsReady () const
 
void Stop ()
 
- Public Member Functions inherited from resdb::ServiceInterface
 ServiceInterface ()
 
virtual ~ServiceInterface ()=default
 
virtual bool IsRunning () const
 
virtual void SetRunning (bool is_running)
 

Additional Inherited Members

- Protected Member Functions inherited from resdb::ConsensusManagerPBFT
int InternalConsensusCommit (std::unique_ptr< Context > context, std::unique_ptr< Request > request)
 
void AddPendingRequest (std::unique_ptr< Context > context, std::unique_ptr< Request > request)
 
void AddComplainedRequest (std::unique_ptr< Context > context, std::unique_ptr< Request > request)
 
absl::StatusOr< std::pair< std::unique_ptr< Context >, std::unique_ptr< Request > > > PopPendingRequest ()
 
absl::StatusOr< std::pair< std::unique_ptr< Context >, std::unique_ptr< Request > > > PopComplainedRequest ()
 
- Protected Member Functions inherited from resdb::ConsensusManager
virtual void BroadCast (const Request &request)
 
virtual void SendMessage (const google::protobuf::Message &message, int64_t node_id)
 
virtual int Dispatch (std::unique_ptr< Context > context, std::unique_ptr< Request > request)
 
int ProcessClientCert (std::unique_ptr< Context > context, std::unique_ptr< Request > request)
 
int ProcessHeartBeat (std::unique_ptr< Context > context, std::unique_ptr< Request > request)
 
virtual std::unique_ptr< ReplicaCommunicator > GetReplicaClient (const std::vector< ReplicaInfo > &replicas, bool is_use_long_conn=false)
 
std::vector< ReplicaInfo > GetAllReplicas ()
 
virtual std::vector< ReplicaInfo > GetClientReplicas ()
 
virtual void AddNewReplica (const ReplicaInfo &info)
 
void AddNewClient (const ReplicaInfo &info)
 
ReplicaCommunicator * GetBroadCastClient ()
 
void UpdateBroadCastClient ()
 
SignatureVerifier * GetSignatureVerifier ()
 
- Protected Attributes inherited from resdb::ConsensusManagerPBFT
std::unique_ptr< SystemInfo > system_info_
 
std::unique_ptr< CheckPointManager > checkpoint_manager_
 
std::unique_ptr< MessageManager > message_manager_
 
std::unique_ptr< Commitment > commitment_
 
std::unique_ptr< Query > query_
 
std::unique_ptr< ResponseManager > response_manager_
 
std::unique_ptr< PerformanceManager > performance_manager_
 
std::unique_ptr< ViewChangeManager > view_change_manager_
 
std::unique_ptr< Recovery > recovery_
 
Stats * global_stats_
 
std::queue< std::pair< std::unique_ptr< Context >, std::unique_ptr< Request > > > request_pending_
 
std::queue< std::pair< std::unique_ptr< Context >, std::unique_ptr< Request > > > request_complained_
 
std::mutex mutex_
 
- Protected Attributes inherited from resdb::ConsensusManager
ResDBConfig config_
 
std::unique_ptr< SignatureVerifier > verifier_
 

Detailed Description

Definition at line 28 of file consensus_manager_geo_pbft.h.

Constructor & Destructor Documentation

◆ ConsensusManagerGeoPBFT()

resdb::ConsensusManagerGeoPBFT::ConsensusManagerGeoPBFT ( const ResDBConfig &  config,
std::unique_ptr< GeoTransactionExecutor >  local_executor,
std::unique_ptr< GeoGlobalExecutor >  global_executor 
)

Definition at line 24 of file consensus_manager_geo_pbft.cpp.

◆ ~ConsensusManagerGeoPBFT()

virtual resdb::ConsensusManagerGeoPBFT::~ConsensusManagerGeoPBFT ( )
virtualdefault

Member Function Documentation

◆ ConsensusCommit()

int resdb::ConsensusManagerGeoPBFT::ConsensusCommit ( std::unique_ptr< Context >  context,
std::unique_ptr< Request >  request 
)
overridevirtual

Reimplemented from resdb::ConsensusManager.

Definition at line 35 of file consensus_manager_geo_pbft.cpp.