grape::AutoParallelMessageManager< FRAG_T > Class Template Reference

A kind of message manager supporting auto parallelism. More...

#include <auto_parallel_message_manager.h>

Inheritance diagram for grape::AutoParallelMessageManager< FRAG_T >:

Classes
struct	ap_event

Public Member Functions
void	StartARound () override
	Inherit.
void	FinishARound () override
	Inherit.
void	RegisterSyncBuffer (const FRAG_T &frag, ISyncBuffer *buffer, MessageStrategy strategy)
	Register a buffer to be sync automatically between rounds.
void	Init (MPI_Comm comm) override
	Inherit.
void	Start () override
	Inherit.
bool	ToTerminate () override
	Inherit.
void	Finalize () override
	Inherit.
size_t	GetMsgSize () const override
	Inherit.
void	ForceContinue () override
	Inherit.
Public Member Functions inherited from grape::DefaultMessageManager
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.

Private Types
using	Base = DefaultMessageManager
using	vid_t = typename FRAG_T::vid_t

Private Member Functions
void	aggregateAutoMessages ()
void	generateAutoMessages ()
template<typename T >
void	syncOnInnerVertexSend (const FRAG_T &frag, ISyncBuffer *buffer, int event_id, MessageStrategy message_strategy)
template<typename T >
void	syncOnOuterVertexSend (const FRAG_T &frag, ISyncBuffer *buffer, int event_id)
template<typename T >
void	syncOnVertexRecv (const FRAG_T &frag, ISyncBuffer *buffer)

Private Attributes
std::vector< ap_event >	auto_parallel_events_

Additional Inherited Members
Protected Member Functions inherited from grape::DefaultMessageManager
fid_t	fid () const
fid_t	fnum () const
Protected Attributes inherited from grape::DefaultMessageManager
std::vector< InArchive >	to_send_

Detailed Description

template<typename FRAG_T>
class grape::AutoParallelMessageManager< FRAG_T >

A kind of message manager supporting auto parallelism.

After registering the vertex array and message strategy as a sync buffer, message generation and ingestion can be applied by message manager automatically.

Member Function Documentation

Finalize()

template<typename FRAG_T >

void grape::DefaultMessageManager::Finalize ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

FinishARound()

template<typename FRAG_T >

void grape::AutoParallelMessageManager< FRAG_T >::FinishARound ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

ForceContinue()

template<typename FRAG_T >

void grape::DefaultMessageManager::ForceContinue ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

GetMsgSize()

template<typename FRAG_T >

size_t grape::DefaultMessageManager::GetMsgSize ( ) const

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

Init()

template<typename FRAG_T >

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

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

RegisterSyncBuffer()

template<typename FRAG_T >

void grape::AutoParallelMessageManager< FRAG_T >::RegisterSyncBuffer ( const FRAG_T &  frag, ISyncBuffer *  buffer, MessageStrategy  strategy  )

inline

Register a buffer to be sync automatically between rounds.

Parameters

frag
buffer
strategy

Start()

template<typename FRAG_T >

void grape::DefaultMessageManager::Start ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

StartARound()

template<typename FRAG_T >

void grape::AutoParallelMessageManager< FRAG_T >::StartARound ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.

ToTerminate()

template<typename FRAG_T >

bool grape::DefaultMessageManager::ToTerminate ( )

inlineoverridevirtual

Inherit.

Implements grape::MessageManagerBase.