|
void | Init (const grape::CommSpec &comm_spec) |
| Initialize message manager.
|
|
void | Start () |
| This function will be called before Init step of applications.
|
|
void | StartARound () |
| This function will be called before each evaluation step of applications.
|
|
void | FinishARound () |
| This function will be called after each evaluation step of applications.
|
|
void | Finalize () const |
| This function will be called after the evaluation of applications.
|
|
template<typename GRAPH_T , typename DATA_T > |
void | SyncInnerVertices (const GRAPH_T &h_frag, VertexArray< DATA_T, typename GRAPH_T::vid_t > &h_data) |
| Synchronize the inner vertices' data of a vertex array to their mirrors. The data_out and data_in are the same vertex array.
|
|
bool | ToTerminate () const |
| This function will be called by worker after a step to determine whether evaluation is terminated.
|
|
size_t | GetMsgSize () const |
| Get size of messages sent by this message manager instance. The return value is valid only after FinishARound is called. StartARound will reset the value to zero.
|
|
void | ForceContinue () |
| Force continue to evaluate one more round even if all workers stop sending message.
|
|
Stream & | stream () |
|
ncclComm_t | nccl_comm () |
|
double | GetAccumulatedCommTime () const |
|