MPI_Request detached_sender_;
int refcount_;
MPI_Op op_;
- int cancelled_; // tri-state
std::unique_ptr<smpi_mpi_generalized_request_funcs_t> generalized_funcs;
MPI_Request* nbc_requests_;
int nbc_requests_size_;
int tag() const { return tag_; }
int flags() const { return flags_; }
bool detached() const { return detached_; }
+ std::string name() const override { return std::string("MPI_Request"); }
MPI_Datatype type() const { return old_type_; }
void print_request(const char* message) const;
void start();
static MPI_Request issend(const void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_Comm comm);
static MPI_Request irecv(void* buf, int count, MPI_Datatype datatype, int src, int tag, MPI_Comm comm);
- static void recv(void* buf, int count, MPI_Datatype datatype, int src, int tag, MPI_Comm comm, MPI_Status* status);
+ static int recv(void* buf, int count, MPI_Datatype datatype, int src, int tag, MPI_Comm comm, MPI_Status* status);
static void bsend(const void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_Comm comm);
static void send(const void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_Comm comm);
static void ssend(const void* buf, int count, MPI_Datatype datatype, int dst, int tag, MPI_Comm comm);