Changeset 2563 for XIOS3/trunk/src/transport/p2p_client_buffer.cpp
- Timestamp:
- 09/12/23 08:58:14 (10 months ago)
- File:
-
- 1 edited
Legend:
- Unmodified
- Added
- Removed
-
XIOS3/trunk/src/transport/p2p_client_buffer.cpp
r2562 r2563 229 229 if (flag==true) 230 230 { 231 info(logProtocol) << "DBG : Send req deleted to " << intraServerRank_ << ", of size " << request.buffer->count() << endl;232 231 delete request.buffer ; 233 232 requests_.pop_front() ; … … 301 300 } 302 301 if (info.isActive(logProtocol)) CTimer::get("sendTimelineEvent : MPI_Isend").resume() ; 303 info(logProtocol) << "DBG : Send Hdr to " << intraServerRank_ << ", of size " << request.buffer->count() << endl;304 302 MPI_Isend(request.buffer->start(),request.buffer->count(), MPI_CHAR, intraServerRank_, 20, interCommMerged_, &request.mpiRequest ) ; 305 //MPI_Send(request.buffer->start(),request.buffer->count(), MPI_CHAR, intraServerRank_, 20, interCommMerged_ ) ;306 //delete request.buffer ;307 303 if (info.isActive(logProtocol)) CTimer::get("sendTimelineEvent : MPI_Isend").suspend() ; 308 304 info(logProtocol)<<outStr.str()<<endl ; … … 315 311 request.buffer = new CBufferOut(sizeof(EVENT_BUFFER_RESIZE)+sizeof(timeline)+sizeof(size)) ; 316 312 *(request.buffer)<<EVENT_BUFFER_RESIZE<<timeline<<size ; 317 info(logProtocol) << "DBG : Send Hdr RESIZE to " << intraServerRank_ << ", of size " << request.buffer->count() << endl;318 313 MPI_Isend(request.buffer->start(),request.buffer->count(), MPI_CHAR, intraServerRank_, 20, interCommMerged_, &request.mpiRequest ) ; 319 //MPI_Send(request.buffer->start(),request.buffer->count(), MPI_CHAR, intraServerRank_, 20, interCommMerged_ ) ;320 //delete request.buffer ;321 314 requests_.push_back(request) ; 322 315 }
Note: See TracChangeset
for help on using the changeset viewer.