libgrape-lite
A C++ library for parallel graph processing
Loading...
Searching...
No Matches
Public Member Functions | Private Member Functions | Private Attributes | List of all members
grape::ShuffleOut< TYPES > Class Template Reference

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_