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_ |