Default message manager. More...

#include <default_message_manager.h>

Inheritance diagram for grape::DefaultMessageManager:

Public Member Functions
void	Init (MPI_Comm comm) override
	Inherit.

void	Start () override
	Inherit.

void	StartARound () override
	Inherit.

void	FinishARound () override
	Inherit.

bool	ToTerminate () override
	Inherit.

void	Finalize () override
	Inherit.

size_t	GetMsgSize () const override
	Inherit.

void	ForceContinue () override
	Inherit.

void	ForceTerminate (const std::string &terminate_info) override
	Inherit.

const TerminateInfo &	GetTerminateInfo () const override
	Inherit.

template<typename MESSAGE_T >
void	SendToFragment (fid_t dst_fid, const MESSAGE_T &msg)
	Send message to a fragment.

template<typename GRAPH_T , typename MESSAGE_T >
void	SyncStateOnOuterVertex (const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg)
	Communication by synchronizing the status on outer vertices, for edge-cut fragments.

template<typename GRAPH_T , typename MESSAGE_T >
void	SendMsgThroughIEdges (const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg)
	Communication via a crossing edge a<-c. It sends message from a to c.

template<typename GRAPH_T , typename MESSAGE_T >
void	SendMsgThroughOEdges (const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg)
	Communication via a crossing edge a->b. It sends message from a to b.

template<typename GRAPH_T , typename MESSAGE_T >
void	SendMsgThroughEdges (const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg)
	Communication via crossing edges a->b and a<-c. It sends message from a to b and c.

template<typename MESSAGE_T >
bool	GetMessage (MESSAGE_T &msg)
	Get a message from message buffer.

template<typename GRAPH_T , typename MESSAGE_T >
bool	GetMessage (const GRAPH_T &frag, typename GRAPH_T::vertex_t &v, MESSAGE_T &msg)
	Get a message and its target vertex from message buffer.

Protected Member Functions
fid_t	fid () const

fid_t	fnum () const

Protected Attributes
std::vector< InArchive >	to_send_

Private Member Functions
bool	syncLengths ()

Private Attributes
std::vector< OutArchive >	to_recv_

fid_t	cur_

std::vector< size_t >	lengths_out_

std::vector< size_t >	lengths_in_

std::vector< MPI_Request >	reqs_

MPI_Comm	comm_

fid_t	fid_

fid_t	fnum_

CommSpec	comm_spec_

size_t	sent_size_

bool	to_terminate_

bool	force_continue_

bool	force_terminate_

TerminateInfo	terminate_info_

Detailed Description

Default message manager.

The send and recv methods are not thread-safe.

Member Function Documentation

◆ Finalize()

void grape::DefaultMessageManager::Finalize ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

◆ FinishARound()

void grape::DefaultMessageManager::FinishARound ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

◆ ForceContinue()

void grape::DefaultMessageManager::ForceContinue ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

◆ ForceTerminate()

void grape::DefaultMessageManager::ForceTerminate ( const std::string & terminate_info )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

◆ GetMessage() [1/2]

template<typename GRAPH_T , typename MESSAGE_T >

bool grape::DefaultMessageManager::GetMessage	(	const GRAPH_T &	frag,
		typename GRAPH_T::vertex_t &	v,
		MESSAGE_T &	msg
	)

inline

Get a message and its target vertex from message buffer.

Template Parameters

GRAPH_T
MESSAGE_T

Parameters

frag
v
msg

Returns: Return true if got a message, and false if no message left.

◆ GetMessage() [2/2]

template<typename MESSAGE_T >

bool grape::DefaultMessageManager::GetMessage ( MESSAGE_T & msg )

inline

Get a message from message buffer.

Template Parameters

MESSAGE_T

Parameters

msg

Returns: Return true if got a message, and false if no message left.

◆ GetMsgSize()

size_t grape::DefaultMessageManager::GetMsgSize ( ) const

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

◆ GetTerminateInfo()

const TerminateInfo & grape::DefaultMessageManager::GetTerminateInfo ( ) const

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

◆ Init()

void grape::DefaultMessageManager::Init ( MPI_Comm comm )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

◆ SendMsgThroughEdges()

template<typename GRAPH_T , typename MESSAGE_T >

void grape::DefaultMessageManager::SendMsgThroughEdges	(	const GRAPH_T &	frag,
		const typename GRAPH_T::vertex_t &	v,
		const MESSAGE_T &	msg
	)

inline

Communication via crossing edges a->b and a<-c. It sends message from a to b and c.

Template Parameters

GRAPH_T
MESSAGE_T

Parameters

frag
v	a
msg

◆ SendMsgThroughIEdges()

template<typename GRAPH_T , typename MESSAGE_T >

void grape::DefaultMessageManager::SendMsgThroughIEdges	(	const GRAPH_T &	frag,
		const typename GRAPH_T::vertex_t &	v,
		const MESSAGE_T &	msg
	)

inline

Communication via a crossing edge a<-c. It sends message from a to c.

Template Parameters

GRAPH_T
MESSAGE_T

Parameters

frag
v	a
msg

◆ SendMsgThroughOEdges()

template<typename GRAPH_T , typename MESSAGE_T >

void grape::DefaultMessageManager::SendMsgThroughOEdges	(	const GRAPH_T &	frag,
		const typename GRAPH_T::vertex_t &	v,
		const MESSAGE_T &	msg
	)

inline

Communication via a crossing edge a->b. It sends message from a to b.

Template Parameters

GRAPH_T
MESSAGE_T

Parameters

frag
v	a
msg

◆ SendToFragment()

template<typename MESSAGE_T >

void grape::DefaultMessageManager::SendToFragment	(	fid_t	dst_fid,
		const MESSAGE_T &	msg
	)

inline

Send message to a fragment.

Template Parameters

MESSAGE_T Message type.

Parameters

dst_fid	Destination fragment id.
msg

◆ Start()

void grape::DefaultMessageManager::Start ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

◆ StartARound()

void grape::DefaultMessageManager::StartARound ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

◆ SyncStateOnOuterVertex()

template<typename GRAPH_T , typename MESSAGE_T >

void grape::DefaultMessageManager::SyncStateOnOuterVertex	(	const GRAPH_T &	frag,
		const typename GRAPH_T::vertex_t &	v,
		const MESSAGE_T &	msg
	)

inline

Communication by synchronizing the status on outer vertices, for edge-cut fragments.

Assume a fragment F_1, a crossing edge a->b' in F_1 and a is an inner vertex in F_1. This function invoked on F_1 send status on b' to b on F_2, where b is an inner vertex.

Template Parameters

GRAPH_T
MESSAGE_T

Parameters

frag
v	a
msg

◆ ToTerminate()

bool grape::DefaultMessageManager::ToTerminate ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

Public Member Functions

Protected Member Functions

Protected Attributes

Private Member Functions

Private Attributes

Detailed Description

Member Function Documentation

◆ Finalize()

◆ FinishARound()

◆ ForceContinue()

◆ ForceTerminate()

◆ GetMessage() [1/2]

◆ GetMessage() [2/2]

◆ GetMsgSize()

◆ GetTerminateInfo()

◆ Init()

◆ SendMsgThroughEdges()

◆ SendMsgThroughIEdges()

◆ SendMsgThroughOEdges()

◆ SendToFragment()

◆ Start()

◆ StartARound()

◆ SyncStateOnOuterVertex()

◆ ToTerminate()