Changeset 1220 for XIOS/dev/branch_openmp/extern/src_ep_dev/ep_test.cpp
- Timestamp:
- 07/20/17 09:18:34 (7 years ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/branch_openmp/extern/src_ep_dev/ep_test.cpp
r1185 r1220 41 41 if(request->type == 2) // irecv message not probed 42 42 { 43 Message_Check(request->comm); 43 Request_Check(); 44 44 45 #pragma omp flush 45 MPI_Message message; 46 MPI_Improbe(request->ep_src, request->ep_tag, request->comm, flag, &message, status); 47 if(*flag) 48 { 49 50 int count; 51 MPI_Get_count(status, request->ep_datatype, &count); 52 MPI_Imrecv(request->buf, count, request->ep_datatype, &message, request); 53 printf("in ep_test, found message src = %d, tag = %d, type = %d\n", request->ep_src, request->ep_tag, request->type); 54 MPI_Test(request, flag, status); 55 } 56 return 0; 46 57 47 } 58 48 … … 62 52 ::MPI_Status mpi_status; 63 53 64 ::MPI_Errhandler_set(MPI_COMM_WORLD_STD, MPI_ERRORS_RETURN); 65 int error_code = ::MPI_Test(mpi_request, flag, &mpi_status); 66 if (error_code != MPI_SUCCESS) { 54 ::MPI_Test(mpi_request, flag, &mpi_status); 67 55 68 char error_string[BUFSIZ];69 int length_of_error_string, error_class;70 71 ::MPI_Error_class(error_code, &error_class);72 ::MPI_Error_string(error_class, error_string, &length_of_error_string);73 printf("%s\n", error_string);74 }75 56 76 57 if(*flag) … … 83 64 //MPI_Get_count(status, request->ep_datatype, &count); 84 65 //check_sum_recv(request->buf, count, request->ep_datatype, request->ep_src, request->ep_tag, request->comm, 2); 85 } 86 87 status->ep_src = request->ep_src; 88 status->ep_tag = request->ep_tag; 89 status->ep_datatype = request->ep_datatype; 90 91 66 } 92 67 93 68 return 0;
Note: See TracChangeset
for help on using the changeset viewer.