#include <message_manager.h>

Public Member Functions
	MessageManager (const ResDBConfig &config, std::unique_ptr< TransactionManager > transaction_manager, CheckPointManager checkpoint_manager, SystemInfo system_info)

	~MessageManager ()

absl::StatusOr< uint64_t >	AssignNextSeq ()

int64_t	GetCurrentPrimary () const

uint64_t	GetMinExecutCandidateSeq ()

void	SetNextSeq (uint64_t seq)

int64_t	GetNextSeq ()

CollectorResultCode	AddConsensusMsg (const SignatureInfo &signature, std::unique_ptr< Request > request)

std::unique_ptr< BatchUserResponse >	GetResponseMsg ()

RequestSet	GetRequestSet (uint64_t min_seq, uint64_t max_seq)

Request *	GetRequest (uint64_t seq)

std::vector< RequestInfo >	GetPreparedProof (uint64_t seq)

TransactionStatue	GetTransactionState (uint64_t seq)

std::vector< ReplicaInfo >	GetReplicas ()

uint64_t	GetCurrentView () const

int	GetReplicaState (ReplicaState *state)

std::unique_ptr< Context >	FetchClientContext (uint64_t seq)

Storage *	GetStorage ()

void	SetLastCommittedTime (uint64_t proxy_id)

uint64_t	GetLastCommittedTime (uint64_t proxy_id)

bool	IsPreapared (uint64_t seq)

uint64_t	GetHighestPreparedSeq ()

void	SetHighestPreparedSeq (uint64_t seq)

void	SetDuplicateManager (DuplicateManager *manager)

void	SendResponse (std::unique_ptr< Request > request)

LockFreeCollectorPool *	GetCollectorPool ()

Detailed Description

Definition at line 44 of file message_manager.h.

Constructor & Destructor Documentation

◆ MessageManager()

resdb::MessageManager::MessageManager	(	const ResDBConfig &	config,
		std::unique_ptr< TransactionManager >	transaction_manager,
		CheckPointManager *	checkpoint_manager,
		SystemInfo *	system_info
	)

Definition at line 28 of file message_manager.cpp.

◆ ~MessageManager()

resdb::MessageManager::~MessageManager ( )

Definition at line 66 of file message_manager.cpp.

Member Function Documentation

◆ AddConsensusMsg()

CollectorResultCode resdb::MessageManager::AddConsensusMsg	(	const SignatureInfo &	signature,
		std::unique_ptr< Request >	request
	)

Definition at line 172 of file message_manager.cpp.

◆ AssignNextSeq()

absl::StatusOr< uint64_t > resdb::MessageManager::AssignNextSeq ( )

Definition at line 91 of file message_manager.cpp.

◆ FetchClientContext()

std::unique_ptr< Context > resdb::MessageManager::FetchClientContext ( uint64_t seq )

◆ GetCollectorPool()

LockFreeCollectorPool * resdb::MessageManager::GetCollectorPool ( )

Definition at line 288 of file message_manager.cpp.

◆ GetCurrentPrimary()

int64_t resdb::MessageManager::GetCurrentPrimary ( ) const

Definition at line 76 of file message_manager.cpp.

◆ GetCurrentView()

uint64_t resdb::MessageManager::GetCurrentView ( ) const

Definition at line 80 of file message_manager.cpp.

◆ GetHighestPreparedSeq()

uint64_t resdb::MessageManager::GetHighestPreparedSeq ( )

Definition at line 261 of file message_manager.cpp.

◆ GetLastCommittedTime()

uint64_t resdb::MessageManager::GetLastCommittedTime ( uint64_t proxy_id )

Definition at line 250 of file message_manager.cpp.

◆ GetMinExecutCandidateSeq()

uint64_t resdb::MessageManager::GetMinExecutCandidateSeq ( )

◆ GetNextSeq()

int64_t resdb::MessageManager::GetNextSeq ( )

Definition at line 89 of file message_manager.cpp.

◆ GetPreparedProof()

std::vector< RequestInfo > resdb::MessageManager::GetPreparedProof ( uint64_t seq )

Definition at line 225 of file message_manager.cpp.

◆ GetReplicas()

std::vector< ReplicaInfo > resdb::MessageManager::GetReplicas ( )

Definition at line 104 of file message_manager.cpp.

◆ GetReplicaState()

int resdb::MessageManager::GetReplicaState ( ReplicaState * state )

Definition at line 233 of file message_manager.cpp.

◆ GetRequest()

Request * resdb::MessageManager::GetRequest ( uint64_t seq )

Definition at line 223 of file message_manager.cpp.

◆ GetRequestSet()

RequestSet resdb::MessageManager::GetRequestSet	(	uint64_t	min_seq,
		uint64_t	max_seq
	)

Definition at line 202 of file message_manager.cpp.

◆ GetResponseMsg()

std::unique_ptr< BatchUserResponse > resdb::MessageManager::GetResponseMsg ( )

Definition at line 72 of file message_manager.cpp.

◆ GetStorage()

Storage * resdb::MessageManager::GetStorage ( )

Definition at line 240 of file message_manager.cpp.

◆ GetTransactionState()

TransactionStatue resdb::MessageManager::GetTransactionState ( uint64_t seq )

Definition at line 229 of file message_manager.cpp.

◆ IsPreapared()

bool resdb::MessageManager::IsPreapared ( uint64_t seq )

Definition at line 257 of file message_manager.cpp.

◆ SendResponse()

void resdb::MessageManager::SendResponse ( std::unique_ptr< Request > request )

Definition at line 273 of file message_manager.cpp.

◆ SetDuplicateManager()

void resdb::MessageManager::SetDuplicateManager ( DuplicateManager * manager )

Definition at line 269 of file message_manager.cpp.

◆ SetHighestPreparedSeq()

void resdb::MessageManager::SetHighestPreparedSeq ( uint64_t seq )

Definition at line 265 of file message_manager.cpp.

◆ SetLastCommittedTime()

void resdb::MessageManager::SetLastCommittedTime ( uint64_t proxy_id )

Definition at line 244 of file message_manager.cpp.

◆ SetNextSeq()

void resdb::MessageManager::SetNextSeq ( uint64_t seq )

Definition at line 84 of file message_manager.cpp.

Public Member Functions