From 1b4cf422c27cbae5e2b37044c982396d89f82168 Mon Sep 17 00:00:00 2001 From: Kidd_9561 Date: Fri, 17 Oct 2025 08:32:53 +0000 Subject: [PATCH 1/2] =?UTF-8?q?update=20c/mpi/one-sided/osu=5Ffop=5Flatenc?= =?UTF-8?q?y.c.=20=E4=BF=AE=E5=A4=8Dfop=20-c=E6=8A=A5=E9=94=99?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Kidd_9561 --- c/mpi/one-sided/osu_fop_latency.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/c/mpi/one-sided/osu_fop_latency.c b/c/mpi/one-sided/osu_fop_latency.c index 30b1673..c3a2c4b 100644 --- a/c/mpi/one-sided/osu_fop_latency.c +++ b/c/mpi/one-sided/osu_fop_latency.c @@ -372,6 +372,7 @@ void run_fop_with_flush(int rank, enum WINDOW win_type, MPI_Datatype data_type, tbuf, options.max_message_size, 0, 1, &validation_error_flag); MPI_CHECK(MPI_Barrier(omb_comm)); + MPI_CHECK(MPI_Barrier(omb_comm)); } } t_end = MPI_Wtime(); @@ -381,6 +382,7 @@ void run_fop_with_flush(int rank, enum WINDOW win_type, MPI_Datatype data_type, atomic_data_validation_check(data_type, op, rank, win_base, tbuf, options.max_message_size, 1, 0, &validation_error_flag); + MPI_CHECK(MPI_Barrier(omb_comm)); } MPI_CHECK(MPI_Barrier(omb_comm)); -- Gitee From 2cfb8d5fdc287d260b4a80fe1f0a388385c87cf0 Mon Sep 17 00:00:00 2001 From: Kidd_9561 Date: Mon, 20 Oct 2025 01:03:49 +0000 Subject: [PATCH 2/2] =?UTF-8?q?update=20c/mpi/pt2pt/standard/osu=5Flatency?= =?UTF-8?q?=5Fmt.c.=20=E4=BF=AE=E5=A4=8Dmt=E6=B5=8B=E8=AF=95=E5=B0=BE?= =?UTF-8?q?=E9=83=A8=E6=B2=A1=E6=9C=89finalize=E6=8A=A5=E9=94=99=E9=97=AE?= =?UTF-8?q?=E9=A2=98?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Kidd_9561 --- c/mpi/pt2pt/standard/osu_latency_mt.c | 6 ++++-- 1 file changed, 4 insertions(+), 2 deletions(-) diff --git a/c/mpi/pt2pt/standard/osu_latency_mt.c b/c/mpi/pt2pt/standard/osu_latency_mt.c index a0aa30f..d6f15d5 100644 --- a/c/mpi/pt2pt/standard/osu_latency_mt.c +++ b/c/mpi/pt2pt/standard/osu_latency_mt.c @@ -574,11 +574,13 @@ omb_mpi_init_data omb_lat_mt_get_comm() void omb_lat_mt_session_finalize(omb_mpi_init_data omb_session_h) { - if (1 == options.omb_enable_session) { #ifdef _ENABLE_MPI4_ + if (1 == options.omb_enable_session) { MPI_CHECK(MPI_Comm_free(&omb_session_h.omb_comm)); MPI_CHECK(MPI_Session_finalize(&omb_session_h.omb_shandle)); -#endif } +#else + MPI_CHECK(MPI_Finalize()); +#endif } /* vi: set sw=4 sts=4 tw=80: */ -- Gitee