Changeset 1146 for XIOS/dev/branch_yushan_merged/extern/src_ep_dev
- Timestamp:
- 05/24/17 16:59:40 (7 years ago)
- Location:
- XIOS/dev/branch_yushan_merged/extern/src_ep_dev
- Files:
-
- 2 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS/dev/branch_yushan_merged/extern/src_ep_dev/ep_alltoall.cpp
r1134 r1146 10 10 int MPI_Alltoall(const void *sendbuf, int sendcount, MPI_Datatype sendtype, void *recvbuf, int recvcount, MPI_Datatype recvtype, MPI_Comm comm) 11 11 { 12 assert(static_cast< ::MPI_Datatype>(sendtype) == static_cast< ::MPI_Datatype>(recvtype)); 12 13 ::MPI_Aint typesize, llb; 13 14 ::MPI_Type_get_extent(static_cast< ::MPI_Datatype>(sendtype), &llb, &typesize); 15 16 int ep_size; 17 MPI_Comm_size(comm, &ep_size); 14 18 15 for(int i=0; i< comm.ep_comm_ptr->size_rank_info[0].second; i++)19 for(int i=0; i<ep_size; i++) 16 20 { 17 MPI_Gather( (char*)sendbuf+i*sendcount*typesize, sendcount, sendtype, recvbuf, recvcount, recvtype, i, comm);21 MPI_Gather(sendbuf+i*sendcount*typesize, sendcount, sendtype, recvbuf, recvcount, recvtype, i, comm); 18 22 } 19 23 -
XIOS/dev/branch_yushan_merged/extern/src_ep_dev/ep_wait.cpp
r1138 r1146 86 86 87 87 int finished = 0; 88 boolfinished_index[count];88 int finished_index[count]; 89 89 90 90 for(int i=0; i<count; i++) … … 97 97 for(int i=0; i<count; i++) 98 98 { 99 //MPI_Test(&array_of_requests[i], &finished_index[i], &array_of_statuses[i]); 99 100 if(finished_index[i] == false) // this request has not been tested. 100 101 { … … 102 103 { 103 104 MPI_Wait(&array_of_requests[i], &array_of_statuses[i]); 104 if(array_of_requests[i].type == 3)105 {106 //int check_count;107 //MPI_Get_count(&array_of_statuses[i], array_of_requests[i].ep_datatype, &check_count);108 //check_sum_recv(array_of_requests[i].buf, count, array_of_requests[i].ep_datatype, array_of_requests[i].ep_src, array_of_requests[i].ep_tag, array_of_requests[i].comm, 2);109 }110 105 finished++; 111 106 finished_index[i] = true;
Note: See TracChangeset
for help on using the changeset viewer.