File tree Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Expand file tree Collapse file tree 1 file changed +9
-0
lines changed Original file line number Diff line number Diff line change 11/*
22 * Copyright (c) 2024 Amazon.com, Inc. or its affiliates. All Rights Reserved.
33 *
4+ * Copyright (c) 2025 Barcelona Supercomputing Center (BSC-CNS). All Rights Reserved.
5+ *
46 * Additional copyrights may follow
57 *
68 * $HEADER$
@@ -369,6 +371,13 @@ int mca_coll_han_alltoall_using_smsc(
369371 ompi_request_wait_all (inter_recv_count , inter_recv_reqs , MPI_STATUS_IGNORE );
370372
371373cleanup :
374+
375+ /* we may still have neighbors reading directly from our buffer, so we must ensure it is not modified */
376+ if (!ii_push_data )
377+ {
378+ low_comm -> c_coll -> coll_barrier (low_comm , low_comm -> c_coll -> coll_barrier_module );
379+ }
380+
372381 for (int jlow = 0 ; jlow < low_size ; jlow ++ ) {
373382 if (jlow != low_rank ) {
374383 mca_smsc -> unmap_peer_region (sbuf_map_ctx [jlow ]);
You can’t perform that action at this time.
0 commit comments