Changeset 1362 for XIOS/dev/branch_openmp/extern/src_ep_dev/ep_recv.cpp

Timestamp:

12/06/17 15:22:17 (6 years ago)

Author:

yushan

Message:

unify type : MPI_Message MPI_Info

File:

• XIOS/dev/branch_openmp/extern/src_ep_dev/ep_recv.cpp (modified) (5 diffs)

XIOS/dev/branch_openmp/extern/src_ep_dev/ep_recv.cpp

@@ -89 +89 @@
     EP_PendingRequests->push_back(request);
 
+
     Request_Check();
 
@@ -101 +102 @@
 
     ::MPI_Request mpi_request;
-    ::MPI_Message mpi_message = static_cast< ::MPI_Message >(message->mpi_message);
-                
-    ::MPI_Imrecv(buf, count, to_mpi_type(datatype), &mpi_message, &mpi_request);
+    //::MPI_Message mpi_message = *(static_cast< ::MPI_Message* >(message->mpi_message));
+    ::MPI_Imrecv(buf, count, to_mpi_type(datatype), static_cast< ::MPI_Message* >(message->mpi_message), &mpi_request);         
+    //::MPI_Imrecv(buf, count, to_mpi_type(datatype), &mpi_message, &mpi_request);
 
     request->mpi_request = mpi_request;
@@ -109 +110 @@
     request->ep_tag = message->ep_tag;
     request->ep_src = message->ep_src;
+    
+    delete message->mpi_message;
 
     return 0;
@@ -119 +122 @@
 
     ::MPI_Status mpi_status;
-    ::MPI_Message mpi_message = static_cast< ::MPI_Message >(message->mpi_message);
-    
-    ::MPI_Mrecv(buf, count, to_mpi_type(datatype), &mpi_message, &mpi_status);
+    //::MPI_Message mpi_message = *(static_cast< ::MPI_Message* >(message->mpi_message));
+    ::MPI_Mrecv(buf, count, to_mpi_type(datatype), static_cast< ::MPI_Message* >(message->mpi_message), &mpi_status);
+    //::MPI_Mrecv(buf, count, to_mpi_type(datatype), &mpi_message, &mpi_status);
 
     status->mpi_status = new ::MPI_Status(mpi_status);
@@ -127 +130 @@
     status->ep_datatype = datatype;
     status->ep_tag = message->ep_tag;
+
+    delete message->mpi_message;
 
     //check_sum_recv(buf, count, datatype, message->ep_src, message->ep_tag);