Public Member Functions
	ThreadLocalMessageBufferOpt (ThreadLocalMessageBufferOpt &&rhs)

void	Init (fid_t fid, fid_t fnum, MM_T mm, MessageBufferPool pool)
	Initialize thread local message buffer. More...

void	SetBlockSize (size_t block_size)

void	Prepare ()

template<typename GRAPH_T , typename MESSAGE_T >
std::enable_if< std::is_pod< MESSAGE_T >::value, void >::type	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. More...

template<typename GRAPH_T , typename MESSAGE_T >
std::enable_if<!std::is_pod< MESSAGE_T >::value, void >::type	SyncStateOnOuterVertex (const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg)

template<typename GRAPH_T >
void	SyncStateOnOuterVertex (const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v)

template<typename GRAPH_T , typename MESSAGE_T >
std::enable_if< std::is_pod< MESSAGE_T >::value, void >::type	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. More...

template<typename GRAPH_T , typename MESSAGE_T >
std::enable_if<!std::is_pod< MESSAGE_T >::value, void >::type	SendMsgThroughIEdges (const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg)

template<typename GRAPH_T , typename MESSAGE_T >
std::enable_if< std::is_pod< MESSAGE_T >::value, void >::type	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. More...

template<typename GRAPH_T , typename MESSAGE_T >
std::enable_if<!std::is_pod< MESSAGE_T >::value, void >::type	SendMsgThroughOEdges (const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg)

template<typename GRAPH_T , typename MESSAGE_T >
std::enable_if< std::is_pod< MESSAGE_T >::value, void >::type	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. More...

template<typename GRAPH_T , typename MESSAGE_T >
std::enable_if<!std::is_pod< MESSAGE_T >::value, void >::type	SendMsgThroughEdges (const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg)

template<typename MESSAGE_T >
std::enable_if< std::is_pod< MESSAGE_T >::value, void >::type	SendToFragment (fid_t dst_fid, const MESSAGE_T &msg)
	Send message to a fragment. More...

template<typename MESSAGE_T >
std::enable_if<!std::is_pod< MESSAGE_T >::value, void >::type	SendToFragment (fid_t dst_fid, const MESSAGE_T &msg)

void	FlushMessages ()
	Flush messages to message manager.

size_t	SentMsgSize () const

void	Reset ()

Private Member Functions
void	flushLocalBuffer (fid_t fid)

Private Attributes
std::vector< FixedInArchive >	to_send_

MM_T *	mm_

fid_t	fid_

fid_t	fnum_

size_t	sent_size_

size_t	block_size_

std::deque< MessageBuffer >	last_round_to_self_

std::deque< MessageBuffer >	this_round_to_self_

std::deque< MessageBuffer >	this_round_to_others_

MessageBufferPool *	pool_

Member Function Documentation

◆ Init()

template<typename MM_T >

void grape::ThreadLocalMessageBufferOpt< MM_T >::Init	(	fid_t	fid,
		fid_t	fnum,
		MM_T *	mm,
		MessageBufferPool *	pool
	)

inline

Initialize thread local message buffer.

Parameters

fnum	Number of fragments.
mm	MessageManager pointer.
block_size	Size of thread local message buffer.
block_cap	Capacity of thread local message buffer.

◆ SendMsgThroughEdges()

template<typename MM_T >

template<typename GRAPH_T , typename MESSAGE_T >

std::enable_if<std::is_pod<MESSAGE_T>::value, void>::type grape::ThreadLocalMessageBufferOpt< MM_T >::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	Graph type.
MESSAGE_T	Message type.

Parameters

frag	Source fragment.
v	a
msg

◆ SendMsgThroughIEdges()

template<typename MM_T >

template<typename GRAPH_T , typename MESSAGE_T >

std::enable_if<std::is_pod<MESSAGE_T>::value, void>::type grape::ThreadLocalMessageBufferOpt< MM_T >::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	Graph type.
MESSAGE_T	Message type,

Parameters

frag	Source fragment.
v	a
msg

◆ SendMsgThroughOEdges()

template<typename MM_T >

template<typename GRAPH_T , typename MESSAGE_T >

std::enable_if<std::is_pod<MESSAGE_T>::value, void>::type grape::ThreadLocalMessageBufferOpt< MM_T >::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	Graph type.
MESSAGE_T	Message type.

Parameters

frag	Source fragment.
v	a
msg

◆ SendToFragment()

template<typename MM_T >

template<typename MESSAGE_T >

std::enable_if<std::is_pod<MESSAGE_T>::value, void>::type grape::ThreadLocalMessageBufferOpt< MM_T >::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

◆ SyncStateOnOuterVertex()

template<typename MM_T >

template<typename GRAPH_T , typename MESSAGE_T >

std::enable_if<std::is_pod<MESSAGE_T>::value, void>::type grape::ThreadLocalMessageBufferOpt< MM_T >::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	Graph type.
MESSAGE_T	Message type,

Parameters

frag	Source fragment.
v	a
msg

Public Member Functions

Private Member Functions

Private Attributes

Member Function Documentation

◆ Init()

◆ SendMsgThroughEdges()

◆ SendMsgThroughIEdges()

◆ SendMsgThroughOEdges()

◆ SendToFragment()

◆ SyncStateOnOuterVertex()