OpenM++ runtime library (libopenm)
|
non-blocking receive of packed data More...
#include <msgMpiRecv.h>
Public Member Functions | |
MpiRecvPacked (int i_selfRank, int i_recvFrom, IRowBaseVec &io_resultRowVec, const IPackedAdapter &i_adapter) | |
create receiver for packed data. More... | |
bool | tryReceive (void) |
try to receive and unpack the data, return return true if completed. More... | |
Public Member Functions inherited from openm::IMsgRecvPacked | |
virtual | ~IMsgRecvPacked (void) noexcept=0 |
cleanup message receiver resources. | |
Public Member Functions inherited from openm::IMsgRecv | |
virtual | ~IMsgRecv (void) noexcept=0 |
cleanup message receiver resources. | |
virtual bool | tryReceive (void)=0 |
try to receive the data, return return true if received. More... | |
Additional Inherited Members | |
Static Public Member Functions inherited from openm::IMsgRecvPacked | |
static IMsgRecvPacked * | create (int i_selfRank, int i_recvFrom, IRowBaseVec &io_resultRowVec, const IPackedAdapter &i_adapter) |
create new receiver for packed data. More... | |
non-blocking receive of packed data
|
inline |
create receiver for packed data.
[in] | i_selfRank | receiver (current process MPI rank) |
[in] | i_recvFrom | sender proccess MPI rank |
[in,out] | io_resultRowVec | vector to push back received db rows |
[in] | i_adapter | adapter to unpack db rows |
|
virtual |
try to receive and unpack the data, return return true if completed.
Implements openm::IMsgRecv.