resdb::MockCheckPointManager Class Reference

#include <mock_checkpoint_manager.h>

Inheritance diagram for resdb::MockCheckPointManager:

Public Member Functions
	MockCheckPointManager (const ResDBConfig &config, ReplicaCommunicator *communicator, SignatureVerifier *verifier)
	MockCheckPointManager (const std::vector< ReplicaInfo > &replicas)
	MOCK_METHOD (int, SendHeartBeat,(const HeartBeatInfo &),(override))
	MOCK_METHOD (int, SendMessage,(const google::protobuf::Message &),(override))
	MOCK_METHOD (void, BroadCast,(const google::protobuf::Message &),(override))
	MOCK_METHOD (void, SendMessage,(const google::protobuf::Message &, int64_t),(override))
	MOCK_METHOD (int, SendMessage,(const google::protobuf::Message &, const ReplicaInfo &),(override))
Public Member Functions inherited from resdb::CheckPointManager
	CheckPointManager (const ResDBConfig &config, ReplicaCommunicator *replica_communicator, SignatureVerifier *verifier)
virtual	~CheckPointManager ()
ChainState *	GetTxnDB ()
uint64_t	GetMaxTxnSeq ()
void	AddCommitData (std::unique_ptr< Request > request)
int	ProcessCheckPoint (std::unique_ptr< Context > context, std::unique_ptr< Request > request)
uint64_t	GetStableCheckpoint () override
StableCheckPoint	GetStableCheckpointWithVotes ()
bool	IsValidCheckpointProof (const StableCheckPoint &stable_ckpt)
void	SetTimeoutHandler (std::function< void()> timeout_handler)
virtual void	UpdateStableCheckPointCallback (int64_t current_stable_checkpoint)
void	Stop ()
void	TimeoutHandler ()
void	WaitSignal ()
std::unique_ptr< std::pair< uint64_t, std::string > >	PopStableSeqHash ()
void	SetExecutor (TransactionExecutor *executor)
uint64_t	GetHighestPreparedSeq ()
void	SetHighestPreparedSeq (uint64_t seq)
sem_t *	CommitableSeqSignal ()
uint64_t	GetCommittableSeq ()
Public Member Functions inherited from resdb::CheckPoint
	CheckPoint ()=default
virtual	~CheckPoint ()=default

Additional Inherited Members
Protected Attributes inherited from resdb::CheckPointManager
ResDBConfig	config_
ReplicaCommunicator *	replica_communicator_
std::unique_ptr< ChainState >	txn_db_
std::thread	checkpoint_thread_
std::thread	stable_checkpoint_thread_
SignatureVerifier *	verifier_
std::atomic< bool >	stop_
std::map< std::pair< uint64_t, std::string >, std::set< uint32_t > >	sender_ckpt_
std::map< std::pair< uint64_t, std::string >, std::vector< SignatureInfo > >	sign_ckpt_
std::map< std::pair< uint64_t, std::string >, std::vector< std::string > >	hash_ckpt_
std::atomic< uint64_t >	current_stable_seq_
std::mutex	mutex_
LockFreeQueue< Request >	data_queue_
std::mutex	cv_mutex_
std::condition_variable	cv_
std::function< void()>	timeout_handler_
StableCheckPoint	stable_ckpt_
int	new_data_ = 0
LockFreeQueue< std::pair< uint64_t, std::string > >	stable_hash_queue_
std::condition_variable	signal_
ResDBTxnAccessor	txn_accessor_
std::mutex	lt_mutex_
uint64_t	last_seq_ = 0
TransactionExecutor *	executor_
std::atomic< uint64_t >	highest_prepared_seq_
uint64_t	committable_seq_ = 0
std::string	last_hash_
std::string	committable_hash_
sem_t	committable_seq_signal_

Detailed Description

Definition at line 28 of file mock_checkpoint_manager.h.

Constructor & Destructor Documentation

MockCheckPointManager() [1/2]

resdb::MockCheckPointManager::MockCheckPointManager	(	const ResDBConfig &	config,
		ReplicaCommunicator *	communicator,
		SignatureVerifier *	verifier
	)

MockCheckPointManager() [2/2]

resdb::MockCheckPointManager::MockCheckPointManager ( const std::vector< ReplicaInfo > &  replicas )

inline

Definition at line 33 of file mock_checkpoint_manager.h.

Member Function Documentation

MOCK_METHOD() [1/5]

resdb::MockCheckPointManager::MOCK_METHOD	(	int	,
		SendHeartBeat	,
		(const HeartBeatInfo &)	,
		(override)
	)

MOCK_METHOD() [2/5]

resdb::MockCheckPointManager::MOCK_METHOD	(	int	,
		SendMessage	,
		(const google::protobuf::Message &)	,
		(override)
	)

MOCK_METHOD() [3/5]

resdb::MockCheckPointManager::MOCK_METHOD	(	int	,
		SendMessage	,
		(const google::protobuf::Message &, const ReplicaInfo &)	,
		(override)
	)

MOCK_METHOD() [4/5]

resdb::MockCheckPointManager::MOCK_METHOD	(	void	,
		BroadCast	,
		(const google::protobuf::Message &)	,
		(override)
	)

MOCK_METHOD() [5/5]

resdb::MockCheckPointManager::MOCK_METHOD	(	void	,
		SendMessage	,
		(const google::protobuf::Message &, int64_t)	,
		(override)
	)