|
libgrape-lite
A C++ library for parallel graph processing
|
Public Member Functions | |
| void | Init (MPI_Comm comm, int tag=0, size_t cs=4096) |
| void | DisableComm () |
| void | SetDestination (int dst_worker_id, fid_t dst_frag_id) |
| void | Clear () |
| void | Emplace (const TYPES &... rest) |
| void | AppendBuffers (const typename ShuffleBuffer< TYPES >::type &... bx) |
| void | AppendBuffers (typename ShuffleBuffer< TYPES >::type &&... bx) |
| void | Flush () |
| ShuffleBufferTuple< TYPES... > & | buffers () |
| const ShuffleBufferTuple< TYPES... > & | buffers () const |
Private Member Functions | |
| void | issue () |
Private Attributes | |
| ShuffleBufferTuple< TYPES... > | buffers_ |
| size_t | chunk_size_ |
| size_t | current_size_ |
| int | dst_worker_id_ |
| fid_t | dst_frag_id_ |
| int | tag_ |
| bool | comm_disabled_ |
| MPI_Comm | comm_ |