Changeset 2562 for XIOS3/trunk/src/transport/p2p_context_server.cpp
- Timestamp:
- 09/12/23 08:52:28 (10 months ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS3/trunk/src/transport/p2p_context_server.cpp
r2560 r2562 104 104 requests_[rank].push_back(new CRequest(interCommMerged_, status)) ; 105 105 // Test 1st request of the list, request treatment must be ordered 106 //while (!requests_[rank].back()->test()) 107 //{ 108 //} 106 109 if (requests_[rank].front()->test()) 107 110 { … … 110 113 requests_[rank].pop_front() ; 111 114 } 115 //CRequest* request = new CRequest(interCommMerged_, status); 116 //processRequest(*request) ; 117 //delete request; 112 118 } 113 119 } … … 134 140 if (it==buffers_.end()) 135 141 { 142 info(logProtocol) << "DBG : Buffer(Hdr) created " << rank << ", of size " << request.getCount() << endl; 136 143 buffers_[rank] = new CP2pServerBuffer(rank, commSelf_, interCommMerged_, pendingEvents_, completedEvents_, request.getBuffer()) ; 137 144 } 138 else 139 {145 else { 146 info(logProtocol) << "DBG : Buffer(Hdr) received " << rank << ", of size " << request.getCount() << endl; 140 147 it->second->receivedRequest(request.getBuffer()) ; 141 148 }
Note: See TracChangeset
for help on using the changeset viewer.