|
@@ -212,6 +212,12 @@ void _starpu_mpi_coop_send(starpu_data_handle_t data_handle, struct _starpu_mpi_
|
|
|
}
|
|
|
coop_sends = mpi_data->coop_sends;
|
|
|
_STARPU_MPI_DEBUG(0, "%p: add to cooperative sends %p, dest %d\n", data_handle, coop_sends, req->node_tag.node.rank);
|
|
|
+
|
|
|
+ /* Get the pre_sync_jobid of the first send request, to build a coherent DAG in the traces: */
|
|
|
+ struct _starpu_mpi_req *firstreq;
|
|
|
+ firstreq = _starpu_mpi_req_multilist_begin_coop_sends(&coop_sends->reqs);
|
|
|
+ req->pre_sync_jobid = firstreq->pre_sync_jobid;
|
|
|
+
|
|
|
_starpu_mpi_req_multilist_push_back_coop_sends(&coop_sends->reqs, req);
|
|
|
coop_sends->n++;
|
|
|
req->coop_sends_head = coop_sends;
|