Channels() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inline |
channels_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
comm_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
comm_spec_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
default_msg_send_block_capacity (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | privatestatic |
default_msg_send_block_size (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | privatestatic |
fid_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
Finalize() override | grape::ParallelMessageManagerOpt | inlinevirtual |
FinishARound() override | grape::ParallelMessageManagerOpt | inlinevirtual |
finishMsgFilling() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inlineprivate |
fnum_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
force_continue_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
force_terminate_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
ForceContinue() override | grape::ParallelMessageManagerOpt | inlinevirtual |
ForceTerminate(const std::string &terminate_info) override | grape::ParallelMessageManagerOpt | inlinevirtual |
GetMessageInBuffer(MessageInBuffer &buf) | grape::ParallelMessageManagerOpt | inline |
GetMsgSize() const override | grape::ParallelMessageManagerOpt | inlinevirtual |
GetPool() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inline |
GetTerminateInfo() const override | grape::ParallelMessageManagerOpt | inlinevirtual |
Init(MPI_Comm comm) override | grape::ParallelMessageManagerOpt | inlinevirtual |
InitChannels(int channel_num=1, size_t block_size=default_msg_send_block_size, size_t block_cap=default_msg_send_block_capacity) | grape::ParallelMessageManagerOpt | inline |
MessageManagerBase() (defined in grape::MessageManagerBase) | grape::MessageManagerBase | inline |
ParallelMessageManagerOpt() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inline |
ParallelProcess(int thread_num, const GRAPH_T &frag, const FUNC_T &func) | grape::ParallelMessageManagerOpt | inline |
ParallelProcess(int thread_num, const FUNC_T &func) | grape::ParallelMessageManagerOpt | inline |
ParallelProcessCount(int thread_num, const GRAPH_T &frag, const FUNC_T &func) (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inline |
pool_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
probeAllIncomingMessages() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inlineprivate |
probeIncomingMessages() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inlineprivate |
recv_bufs_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
recv_bufs_loc_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
recv_bufs_stash_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
recv_queues_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
recv_thread_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
resetRecvQueue() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inlineprivate |
round_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
send_thread_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
sending_queue_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
SendMicroBufferByFid(fid_t fid, MicroBuffer &&arc) | grape::ParallelMessageManagerOpt | inline |
SendMsgThroughEdges(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg, int channel_id=0) | grape::ParallelMessageManagerOpt | inline |
SendMsgThroughIEdges(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg, int channel_id=0) | grape::ParallelMessageManagerOpt | inline |
SendMsgThroughOEdges(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg, int channel_id=0) | grape::ParallelMessageManagerOpt | inline |
SendToFragment(fid_t dst_fid, const MESSAGE_T &msg, int channel_id=0) | grape::ParallelMessageManagerOpt | inline |
sent_size_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
Start() override | grape::ParallelMessageManagerOpt | inlinevirtual |
StartARound() override | grape::ParallelMessageManagerOpt | inlinevirtual |
startRecvThread() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inlineprivate |
startSendThread() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inlineprivate |
stopRecvThread() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inlineprivate |
SyncStateOnOuterVertex(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, const MESSAGE_T &msg, int channel_id=0) | grape::ParallelMessageManagerOpt | inline |
SyncStateOnOuterVertex(const GRAPH_T &frag, const typename GRAPH_T::vertex_t &v, int channel_id=0) (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inline |
terminate_info_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
to_self_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
total_sent_size_ (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | private |
ToTerminate() override | grape::ParallelMessageManagerOpt | inlinevirtual |
waitSend() (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inlineprivate |
~MessageManagerBase() (defined in grape::MessageManagerBase) | grape::MessageManagerBase | inlinevirtual |
~ParallelMessageManagerOpt() override (defined in grape::ParallelMessageManagerOpt) | grape::ParallelMessageManagerOpt | inline |