libgrape-lite
A C++ library for parallel graph processing
grape::ParallelMessageManager Member List

This is the complete list of members for grape::ParallelMessageManager, including all inherited members.

Channels() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinline
channels_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
comm_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
comm_spec_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
default_msg_send_block_capacity (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivatestatic
default_msg_send_block_size (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivatestatic
fid_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
Finalize() overridegrape::ParallelMessageManagerinlinevirtual
FinishARound() overridegrape::ParallelMessageManagerinlinevirtual
finishMsgFilling() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinlineprivate
fnum_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
force_continue_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
force_terminate_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
ForceContinue() overridegrape::ParallelMessageManagerinlinevirtual
ForceTerminate(const std::string &terminate_info) overridegrape::ParallelMessageManagerinlinevirtual
GetMessageInBuffer(MessageInBuffer &buf)grape::ParallelMessageManagerinline
GetMsgSize() const overridegrape::ParallelMessageManagerinlinevirtual
GetTerminateInfo() const overridegrape::ParallelMessageManagerinlinevirtual
Init(MPI_Comm comm) overridegrape::ParallelMessageManagerinlinevirtual
InitChannels(int channel_num=1, size_t block_size=default_msg_send_block_size, size_t block_cap=default_msg_send_block_capacity)grape::ParallelMessageManagerinline
MessageManagerBase() (defined in grape::MessageManagerBase)grape::MessageManagerBaseinline
ParallelMessageManager() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinline
ParallelProcess(int thread_num, const GRAPH_T &frag, const FUNC_T &func)grape::ParallelMessageManagerinline
ParallelProcess(int thread_num, const FUNC_T &func)grape::ParallelMessageManagerinline
probeAllIncomingMessages() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinlineprivate
probeIncomingMessages() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinlineprivate
recv_queues_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
recv_thread_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
resetRecvQueue() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinlineprivate
round_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
send_thread_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
sending_queue_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
SendMsgThroughEdges(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg, int channel_id=0)grape::ParallelMessageManagerinline
SendMsgThroughIEdges(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg, int channel_id=0)grape::ParallelMessageManagerinline
SendMsgThroughOEdges(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg, int channel_id=0)grape::ParallelMessageManagerinline
SendRawMsgByFid(fid_t fid, InArchive &&arc)grape::ParallelMessageManagerinline
SendToFragment(fid_t dst_fid, const MESSAGE_T &msg, int channel_id=0)grape::ParallelMessageManagerinline
sent_size_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
Start() overridegrape::ParallelMessageManagerinlinevirtual
StartARound() overridegrape::ParallelMessageManagerinlinevirtual
startRecvThread() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinlineprivate
startSendThread() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinlineprivate
stopRecvThread() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinlineprivate
SyncStateOnOuterVertex(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg, int channel_id=0)grape::ParallelMessageManagerinline
SyncStateOnOuterVertex(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, int channel_id=0) (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinline
terminate_info_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
to_others_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
to_self_ (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerprivate
ToTerminate() overridegrape::ParallelMessageManagerinlinevirtual
waitSend() (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinlineprivate
~MessageManagerBase() (defined in grape::MessageManagerBase)grape::MessageManagerBaseinlinevirtual
~ParallelMessageManager() override (defined in grape::ParallelMessageManager)grape::ParallelMessageManagerinline