Changeset 1220 for XIOS/dev/branch_openmp/extern/src_ep_dev/ep_recv.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_recv.cpp
r1196 r1220 88 88 { 89 89 EP_PendingRequests = new std::list< MPI_Request* >; 90 //printf("proc %d(%d) : EP_PendingRequests allocated, add = %p\n", dest_rank, world_rank, EP_PendingRequests);91 90 } 92 91 … … 95 94 96 95 Request_Check(); 97 //printf("proc %d(%d) : EP_PendingRequests insert one request, src = %d(%d), tag = %d(%d), size = %d; request add = %p\n",98 // dest_rank, world_rank, EP_PendingRequests->back()->ep_src, request->ep_src,99 // EP_PendingRequests->back()->ep_tag, request->ep_tag,100 // EP_PendingRequests->size(), request);101 102 // check all EP_PendingRequests103 //for(std::list<MPI_Request* >::iterator it = EP_PendingRequests->begin(); it!=EP_PendingRequests->end(); )104 //{105 //if((*it)->type == 3)106 //{107 // EP_PendingRequests->erase(it);108 // it = EP_PendingRequests->begin();109 // continue;110 // }111 112 //int probed = false;113 //MPI_Message pending_message;114 //MPI_Status pending_status;115 116 //MPI_Improbe((*it)->ep_src, (*it)->ep_tag, (*it)->comm, &probed, &pending_message, &pending_status);117 118 //if(probed)119 //{120 //int count;121 //MPI_Get_count(&pending_status, (*it)->ep_datatype, &count);122 //MPI_Imrecv((*it)->buf, count, (*it)->ep_datatype, &pending_message, *it);123 96 124 //EP_PendingRequests->erase(it);125 //if(EP_PendingRequests->empty()) return 0;126 127 //it = EP_PendingRequests->begin();128 //continue;129 // }130 131 //it++;132 // }133 134 97 return 0; 135 98 }
Note: See TracChangeset
for help on using the changeset viewer.