xbt_assert(!request->action,
"Cannot (re)start a non-finished communication");
if(request->flags & RECV) {
- #ifdef HAVE_TRACING
- int rank = smpi_process_index();
- if (TRACE_smpi_view_internals()) {
- TRACE_smpi_computing_out(rank);
- TRACE_smpi_ptp_in(rank, 0, rank, __FUNCTION__);
- }
- #endif
print_request("New recv", request);
if (request->size < sg_cfg_get_int("smpi/async_small_thres"))
mailbox = smpi_process_mailbox_small();
} else {
-
-
-
int receiver = smpi_group_index(smpi_comm_group(request->comm), request->dst);
#ifdef HAVE_TRACING
int rank = smpi_process_index();
if (TRACE_smpi_view_internals()) {
- TRACE_smpi_ptp_in(rank, rank, receiver, __FUNCTION__);
TRACE_smpi_send(rank, rank, receiver);
}
#endif
}
smpi_datatype_unuse(datatype);
-#ifdef HAVE_TRACING
- if (TRACE_smpi_view_internals()) {
- int rank = smpi_process_index();
- TRACE_smpi_ptp_out(rank, rank, 0, __FUNCTION__);
- }
-#endif
-
}
#ifdef HAVE_TRACING
if (TRACE_smpi_view_internals()) {
- if(req->flags & RECV)
- {
+ if(req->flags & RECV){
int rank = smpi_process_index();
-
- //the src may not have been known at the beginning of the recv (MPI_ANY_SOURCE)
- TRACE_smpi_ptp_out(rank, 0, rank, __FUNCTION__);
- int src_traced = smpi_group_index(smpi_comm_group(req->comm), req->src);
- TRACE_smpi_recv(rank, src_traced, rank);
- TRACE_smpi_computing_in(rank);
- }
+ int src_traced = smpi_group_index(smpi_comm_group(req->comm), req->src);
+ TRACE_smpi_recv(rank, src_traced, rank);
+ }
}
#endif