communicatorrequest.cc

/*
 * @file:   communicatorrequest.cc
 * @author: Jordan P. Lefebvre, lefebvrejp@ornl.gov
 *
 * Created on July 3, 2013, 12:14 PM
 */

#include "communicatorrequest.hh"
namespace radix {
namespace Private {
#ifdef USE_MPI

MPICommRequest::MPICommRequest()
    : d_request(NULL)
    , d_source(0)
    , d_tag(0) {}

MPICommRequest::MPICommRequest(MPI_Request *request, int nsource, int ntag,
                               MPI_Datatype ntype)
    : d_request(request)
    , d_source(nsource)
    , d_tag(ntag)
    , d_type(ntype) {}

MPICommRequest::~MPICommRequest() {
  if (d_request != NULL) {
    MPI_Request_free(d_request);
  }
}  // destructor

CommunicatorStatus MPICommRequest::wait() {
  MPI_Status status;
  int error = MPI_Wait(d_request, &status);
  CommunicatorStatus xstatus(
      MPICommStatus(status, d_source, d_tag, error, d_type));

  return xstatus;
}  // wait

void MPICommRequest::cancel() { MPI_Cancel(d_request); }  // cancel
#endif                                                    /** ifdef USE_MPI **/

SerialCommRequest::SerialCommRequest() {}

SerialCommRequest::~SerialCommRequest() {}  // destructor

CommunicatorStatus SerialCommRequest::wait() {
  CommunicatorStatus cstatus;

  return cstatus;
}  // wait

void SerialCommRequest::cancel() {}  // cancel

}  // namespace Private
}  // namespace radix