DeleteRequest( RequestId ) ;
sts = _CommInterface.send(buffer, count, datatype, target, MPItag,
*_IntraCommunicator ) ;
+ if ( _Trace )
+ cout << "MPI_Access::Send" << _MyRank << " SendRequestId "
+ << RequestId << " count " << count << " target " << target
+ << " MPItag " << MPItag << endl ;
}
return sts ;
}
if ( OutCount != NULL ) {
*OutCount = outcount ;
}
+ if ( _Trace )
+ cout << "MPI_Access::Recv" << _MyRank << " RecvRequestId "
+ << RequestId << " count " << count << " source " << source
+ << " MPItag " << MPItag << endl ;
DeleteRequest( RequestId ) ;
}
return sts ;
aTimeMsg->tag = MPItag ;
}
MPI_Request *aSendRequest = MPIRequest( RequestId ) ;
+ if ( _Trace ) {
+ cout << "MPI_Access::ISend" << _MyRank << " ISendRequestId "
+ << RequestId << " count " << count << " target " << target
+ << " MPItag " << MPItag << endl ;
+ if ( MPItag == 1 )
+ cout << "MPI_Access::ISend" << _MyRank << " time "
+ << ((TimeMessage *)buffer)->time << " " << ((TimeMessage *)buffer)->deltatime
+ << endl ;
+ }
sts = _CommInterface.Isend(buffer, count, datatype, target, MPItag,
*_IntraCommunicator , aSendRequest) ;
}
_MessageIdent aMethodIdent = MethodId( datatype ) ;
int MPItag = NewRecvTag( datatype, source , aMethodIdent , true , RequestId ) ;
MPI_Request *aRecvRequest = MPIRequest( RequestId ) ;
+ if ( _Trace ) {
+ cout << "MPI_Access::IRecv" << _MyRank << " IRecvRequestId "
+ << RequestId << " count " << count << " source " << source
+ << " MPItag " << MPItag << endl ;
+ if ( MPItag == 1 )
+ cout << "MPI_Access::ISend" << _MyRank << " time "
+ << ((TimeMessage *)buffer)->time << " " << ((TimeMessage *)buffer)->deltatime
+ << endl ;
+ }
sts = _CommInterface.Irecv(buffer, count, datatype, source, MPItag,
*_IntraCommunicator , aRecvRequest) ;
}