Skip to content
Closed
Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
36 commits
Select commit Hold shift + click to select a range
b96e626
remove deprecated mca rmaps param
hppritcha Oct 15, 2024
155ee56
sessions: fix some problems with multiple init/fini
hppritcha Oct 17, 2024
95e3323
sessions: add support for ucx more
hppritcha Feb 10, 2022
2f4ba1b
ofi/common: fix code that broke sessions
hppritcha Oct 18, 2024
ccd6415
configury: patch configure to support nvfortran
ggouaillardet Jul 30, 2024
25942c7
Merge pull request #12722 from ggouaillardet/topic/nvfortran
bosilca Oct 23, 2024
ef2cb80
Merge pull request #12723 from hppritcha/topic/ucx_excid_support
hppritcha Oct 23, 2024
47ea155
Merge pull request #12868 from hppritcha/fix_for_issue_12854
hppritcha Oct 23, 2024
b198056
Merge pull request #12862 from hppritcha/adjust_ompi4py_ghub_act
hppritcha Oct 23, 2024
c393881
Merge pull request #12870 from hppritcha/fix_common_ofi_for_sessions
hppritcha Oct 23, 2024
70e51fe
sessions: make sure to only finalize class
hppritcha Oct 28, 2024
cdbf8c6
partitions: make it work with sessions
hppritcha Oct 28, 2024
afc970c
Merge pull request #12888 from hppritcha/beef_up_sessions_smoke_test
hppritcha Oct 29, 2024
6043ac5
fcoll/vulcan: cleanup write_all operations
edgargabriel Oct 7, 2024
4b356be
fcoll/vulcan: minor code reorg
edgargabriel Oct 8, 2024
030ead1
fcoll/vulcan: add read_all implementation
edgargabriel Oct 8, 2024
6cf4dbe
examples: add return 0 to sessions smoke test
hppritcha Oct 30, 2024
ed537c6
Merge pull request #12898 from hppritcha/add_a_return_val_to_sessions…
hppritcha Oct 30, 2024
a9f84cc
Merge pull request #12894 from edgargabriel/topic/vulcan-two-phase-re…
edgargabriel Oct 30, 2024
efce573
Merge pull request #12890 from hppritcha/patch_part_for_sessions
hppritcha Oct 31, 2024
cf4b663
hwloc: move to minimum 2.1.0
hppritcha Nov 1, 2024
4e3e918
Merge pull request #12905 from hppritcha/move_to_hwloc210_min
hppritcha Nov 1, 2024
b5ca31c
prrte: advance sha to 30cadc6746
hppritcha Oct 31, 2024
22bdcd6
pmix: advance sha to 4aea550f6f55
hppritcha Nov 1, 2024
25feb3b
Merge pull request #12901 from hppritcha/advance_prrte_sha_to_30cadc6746
hppritcha Nov 2, 2024
33f8c74
coll tuned dynamic rules file alltoall_algorithm_max_requests
Sep 13, 2024
f6387a4
coll tuned add version identifier to the rules file
Nov 2, 2024
617e89d
fix MCA variable scope in coll ucc
Oct 30, 2024
329ea0e
fix MCA variable scope in coll han
Oct 31, 2024
fdf60ac
fix MCA variable scope in coll adapt
Oct 31, 2024
44e0436
fix MCA variable scope in coll basic
Oct 31, 2024
75befb8
fix MCA variable scope in coll hcoll
Oct 31, 2024
0f68484
Merge pull request #12827 from burlen/dynamic_decision_alltoall_max_r…
bosilca Nov 7, 2024
7b2ac18
Merge pull request #12903 from burlen/coll_mca_var_scope
bosilca Nov 7, 2024
c6a7d45
Allow the dpm to query the server for local peer info
rhc54 Nov 14, 2024
594e29a
Merge pull request #12920 from rhc54/topic/dpm
bosilca Nov 19, 2024
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 0 additions & 1 deletion .github/workflows/ompi_mpi4py.yaml
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,6 @@ jobs:
mkdir -p "$(dirname "$mca_params")"
echo mpi_param_check = true >> "$mca_params"
echo mpi_show_handle_leaks = true >> "$mca_params"
echo rmaps_base_oversubscribe = true >> "$mca_params"
mca_params="$HOME/.prte/mca-params.conf"
mkdir -p "$(dirname "$mca_params")"
echo rmaps_default_mapping_policy = :oversubscribe >> "$mca_params"
Expand Down
2 changes: 1 addition & 1 deletion 3rd-party/openpmix
Submodule openpmix updated 79 files
+3 −3 .github/actions/mlnx/Dockerfile
+4 −5 .github/actions/mlnx/entrypoint.sh
+41 −21 .github/workflows/builds.yaml
+0 −65 .github/workflows/close-stale-issues.yaml
+0 −30 .github/workflows/remove-awaiting-user-info-label.yaml
+1 −1 VERSION
+1 −1 config/oac
+22 −48 config/pmix.m4
+12 −1 config/pmix_check_cflags.m4
+3 −3 config/pmix_mca.m4
+1 −14 config/pmix_setup_hwloc.m4
+0 −106 config/pmix_setup_libev.m4
+5 −2 contrib/Makefile.am
+1 −0 contrib/construct_dictionary.py
+2 −2 contrib/construct_event_strings.py
+19 −1 contrib/make_dist_tarball
+10 −2 docs/Makefile.am
+11 −3 docs/conf.py
+0 −2 docs/developers/frameworks.rst
+ docs/images/compatibility.png
+1 −1 docs/requirements.txt
+17 −0 docs/versions.rst
+1 −3 src/client/pmix_client.c
+7 −7 src/client/pmix_client_pub.c
+138 −162 src/client/pmix_client_spawn.c
+1 −2 src/common/pmix_alloc.c
+4 −53 src/common/pmix_query.c
+1 −2 src/common/pmix_session.c
+3 −104 src/hwloc/pmix_hwloc.c
+1 −24 src/hwloc/pmix_hwloc.h
+2 −2 src/include/pmix_config_bottom.h
+0 −12 src/include/pmix_globals.c
+0 −3 src/include/pmix_globals.h
+1 −8 src/include/pmix_portable_platform.h
+50 −26 src/include/pmix_portable_platform_real.h
+9 −25 src/include/pmix_types.h
+17 −11 src/mca/bfrops/base/bfrop_base_cmp.c
+4 −2 src/mca/bfrops/base/bfrop_base_print.c
+1 −1 src/mca/gds/shmem2/configure.m4
+5 −18 src/mca/pcompress/zlib/configure.m4
+46 −0 src/mca/pcompress/zlibng/Makefile.am
+232 −0 src/mca/pcompress/zlibng/compress_zlibng.c
+43 −0 src/mca/pcompress/zlibng/compress_zlibng.h
+58 −0 src/mca/pcompress/zlibng/compress_zlibng_component.c
+62 −0 src/mca/pcompress/zlibng/configure.m4
+7 −0 src/mca/pcompress/zlibng/owner.txt
+3 −2 src/mca/pfexec/Makefile.am
+3 −56 src/mca/pfexec/base/base.h
+17 −2 src/mca/pfexec/base/pfexec_base_frame.c
+5 −6 src/mca/pfexec/linux/pfexec_linux.c
+3 −4 src/mca/pfexec/pfexec.h
+88 −0 src/mca/pfexec/pfexec_types.h
+3 −1 src/mca/pif/linux_ipv6/configure.m4
+21 −5 src/mca/pmdl/base/pmdl_base_stubs.c
+0 −31 src/mca/pstrg/Makefile.am
+0 −19 src/mca/pstrg/base/Makefile.am
+0 −67 src/mca/pstrg/base/base.h
+0 −106 src/mca/pstrg/base/pstrg_base_frame.c
+0 −107 src/mca/pstrg/base/pstrg_base_select.c
+0 −123 src/mca/pstrg/base/pstrg_base_stubs.c
+0 −60 src/mca/pstrg/lustre/Makefile.am
+0 −45 src/mca/pstrg/lustre/configure.m4
+0 −219 src/mca/pstrg/lustre/pstrg_lustre.c
+0 −31 src/mca/pstrg/lustre/pstrg_lustre.h
+0 −87 src/mca/pstrg/lustre/pstrg_lustre_component.c
+0 −86 src/mca/pstrg/pstrg.h
+0 −60 src/mca/pstrg/vfs/Makefile.am
+0 −136 src/mca/pstrg/vfs/pstrg_vfs.c
+0 −31 src/mca/pstrg/vfs/pstrg_vfs.h
+0 −87 src/mca/pstrg/vfs/pstrg_vfs_component.c
+0 −13 src/runtime/pmix_init.c
+1 −142 src/runtime/pmix_progress_threads.c
+0 −3 src/server/pmix_server.c
+132 −112 src/server/pmix_server_ops.c
+9 −1 src/server/pmix_server_ops.h
+0 −2 src/tool/pmix_tool.c
+12 −10 src/util/pmix_basename.c
+3 −4 src/util/pmix_cmd_line.c
+2 −6 test/util/Makefile.am
2 changes: 1 addition & 1 deletion 3rd-party/prrte
Submodule prrte updated 91 files
+1 −1 VERSION
+2 −2 contrib/scaling/scaling.pl
+0 −1 src/docs/show-help-files/help-prte-hwloc-base.rst
+23 −56 src/hwloc/hwloc-internal.h
+10 −11 src/hwloc/hwloc.c
+160 −260 src/hwloc/hwloc_base_util.c
+5 −70 src/mca/ess/base/ess_base_std_prted.c
+5 −51 src/mca/ess/hnp/ess_hnp_module.c
+3 −2 src/mca/odls/base/Makefile.am
+5 −1 src/mca/odls/base/base.h
+161 −109 src/mca/odls/base/odls_base_bind.c
+0 −4 src/mca/odls/base/odls_base_default_fns.c
+2 −3 src/mca/odls/default/odls_default_module.c
+0 −40 src/mca/oob/Makefile.am
+0 −32 src/mca/oob/base/Makefile.am
+0 −111 src/mca/oob/base/oob_base_frame.c
+0 −161 src/mca/oob/base/oob_base_select.c
+0 −382 src/mca/oob/base/oob_base_stubs.c
+0 −7 src/mca/oob/base/owner.txt
+0 −83 src/mca/oob/oob.h
+0 −63 src/mca/oob/tcp/Makefile.am
+0 −39 src/mca/oob/tcp/configure.m4
+0 −282 src/mca/oob/tcp/oob_tcp.c
+0 −1,293 src/mca/oob/tcp/oob_tcp_component.c
+0 −103 src/mca/oob/tcp/oob_tcp_component.h
+17 −8 src/mca/plm/base/plm_base_launch_support.c
+1 −2 src/mca/plm/slurm/plm_slurm.h
+33 −41 src/mca/plm/slurm/plm_slurm_component.c
+6 −1 src/mca/plm/slurm/plm_slurm_module.c
+2 −5 src/mca/plm/ssh/plm_ssh_module.c
+4 −4 src/mca/ras/base/ras_base_allocate.c
+7 −62 src/mca/rmaps/base/rmaps_base_binding.c
+3 −3 src/mca/rmaps/base/rmaps_base_frame.c
+16 −24 src/mca/rmaps/base/rmaps_base_map_job.c
+5 −5 src/mca/rmaps/base/rmaps_base_ranking.c
+0 −4 src/mca/rmaps/base/rmaps_base_support_fns.c
+2 −13 src/mca/rmaps/ppr/rmaps_ppr.c
+0 −4 src/mca/rmaps/rank_file/rmaps_rank_file.c
+1 −2 src/mca/rmaps/rmaps_types.h
+2 −2 src/mca/rmaps/round_robin/rmaps_rr_mappers.c
+0 −27 src/mca/rtc/Makefile.am
+0 −20 src/mca/rtc/base/Makefile.am
+0 −83 src/mca/rtc/base/base.h
+0 −287 src/mca/rtc/base/help-prte-rtc-base.txt
+0 −7 src/mca/rtc/base/owner.txt
+0 −98 src/mca/rtc/base/rtc_base_frame.c
+0 −123 src/mca/rtc/base/rtc_base_select.c
+0 −138 src/mca/rtc/base/rtc_base_stubs.c
+0 −40 src/mca/rtc/hwloc/Makefile.am
+0 −30 src/mca/rtc/hwloc/help-prte-rtc-hwloc.txt
+0 −7 src/mca/rtc/hwloc/owner.txt
+0 −55 src/mca/rtc/hwloc/rtc_hwloc.h
+0 −98 src/mca/rtc/hwloc/rtc_hwloc_component.c
+0 −108 src/mca/rtc/rtc.h
+3 −1 src/mca/schizo/base/schizo_base_frame.c
+262 −1 src/mca/schizo/ompi/schizo_ompi.c
+25 −0 src/mca/schizo/prte/schizo_prte.c
+0 −4 src/mca/state/dvm/state_dvm.c
+1 −20 src/prted/pmix/pmix_server_queries.c
+0 −4 src/prted/pmix/pmix_server_register_fns.c
+0 −1 src/prted/prted_comm.c
+1 −1 src/prted/prun_common.c
+3 −1 src/rml/Makefile.am
+46 −0 src/rml/oob/Makefile.am
+1 −0 src/rml/oob/help-oob-base.txt
+1 −0 src/rml/oob/help-oob-tcp.txt
+48 −22 src/rml/oob/oob.h
+494 −0 src/rml/oob/oob_base_stubs.c
+813 −0 src/rml/oob/oob_tcp.c
+11 −24 src/rml/oob/oob_tcp.h
+26 −27 src/rml/oob/oob_tcp_common.c
+6 −6 src/rml/oob/oob_tcp_common.h
+266 −0 src/rml/oob/oob_tcp_component.c
+51 −65 src/rml/oob/oob_tcp_connection.c
+11 −11 src/rml/oob/oob_tcp_connection.h
+1 −1 src/rml/oob/oob_tcp_hdr.h
+66 −90 src/rml/oob/oob_tcp_listener.c
+2 −2 src/rml/oob/oob_tcp_listener.h
+3 −3 src/rml/oob/oob_tcp_peer.h
+25 −26 src/rml/oob/oob_tcp_sendrecv.c
+9 −9 src/rml/oob/oob_tcp_sendrecv.h
+0 −0 src/rml/oob/owner.txt
+69 −3 src/rml/rml.c
+3 −2 src/rml/rml.h
+2 −2 src/rml/rml_send.c
+5 −5 src/runtime/data_type_support/prte_dt_print_fns.c
+6 −0 src/runtime/prte_globals.c
+18 −2 src/runtime/prte_init.c
+1 −1 src/tools/prte/prte.c
+1 −0 src/util/proc_info.c
+1 −0 src/util/proc_info.h
2 changes: 1 addition & 1 deletion VERSION
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ mpi_standard_subversion=1
# List in x.y.z format.
pmix_min_version=4.2.0
prte_min_version=3.0.0
hwloc_min_version=1.11.0
hwloc_min_version=2.1.0
event_min_version=2.0.21
automake_min_version=1.13.4
autoconf_min_version=2.69.0
Expand Down
32 changes: 28 additions & 4 deletions autogen.pl
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@
# Copyright (c) 2013 Mellanox Technologies, Inc.
# All rights reserved.
# Copyright (c) 2013-2020 Intel, Inc. All rights reserved.
# Copyright (c) 2015-2021 Research Organization for Information Science
# Copyright (c) 2015-2024 Research Organization for Information Science
# and Technology (RIST). All rights reserved.
# Copyright (c) 2015-2022 IBM Corporation. All rights reserved.
# Copyright (c) 2020 Amazon.com, Inc. or its affiliates.
Expand Down Expand Up @@ -891,9 +891,9 @@ sub patch_autotools_output {
# source tree); we can't fix it. So all we can do is patch the
# resulting configure script. :-(
push(@verbose_out, $indent_str . "Patching configure for Libtool PGI 10 fortran compiler name\n");
$c =~ s/gfortran g95 xlf95 f95 fort ifort ifc efc pgf95 lf95 ftn/gfortran g95 xlf95 f95 fort ifort ifc efc pgfortran pgf95 lf95 ftn/g;
$c =~ s/pgcc\* \| pgf77\* \| pgf90\* \| pgf95\*\)/pgcc* | pgf77* | pgf90* | pgf95* | pgfortran*)/g;
$c =~ s/pgf77\* \| pgf90\* \| pgf95\*\)/pgf77* | pgf90* | pgf95* | pgfortran*)/g;
$c =~ s/gfortran g95 xlf95 f95 fort ifort ifc efc pgf95 lf95 ftn/gfortran g95 xlf95 f95 fort ifort ifc efc pgfortran nvfortran pgf95 lf95 ftn/g;
$c =~ s/pgcc\* \| pgf77\* \| pgf90\* \| pgf95\*\)/pgcc* | pgf77* | pgf90* | pgf95* | pgfortran* | nvfortran*)/g;
$c =~ s/pgf77\* \| pgf90\* \| pgf95\*\)/pgf77* | pgf90* | pgf95* | pgfortran* | nvfortran*)/g;

# Similar issue as above -- the PGI 10 version number broke <=LT
# 2.2.6b's version number checking regexps. Again, we can't fix the
Expand Down Expand Up @@ -1085,6 +1085,30 @@ sub patch_autotools_output {
;;";
$c =~ s/$search_string/$replace_string/g;

$c =~ s/for ac_prog in gfortran f95 fort xlf95 ifort ifc efc pgfortran pgf95 lf95 f90 xlf90 pgf90 epcf90 nagfor/for ac_prog in gfortran f95 fort xlf95 ifort ifc efc pgfortran pgf95 lf95 f90 xlf90 pgf90 epcf90 nagfor nvfortran/g;
foreach my $tag (("", "_FC")) {
$search_string = 'tcc\*\)
# Fabrice Bellard et al\'s Tiny C Compiler
lt_prog_compiler_wl'."${tag}".'=\'-Wl,\'
lt_prog_compiler_pic'."${tag}".'=\'-fPIC\'
lt_prog_compiler_static'."${tag}".'=\'-static\'
;;';
$replace_string = "tcc*)
# Fabrice Bellard et al's Tiny C Compiler
lt_prog_compiler_wl${tag}='-Wl,'
lt_prog_compiler_pic${tag}='-fPIC'
lt_prog_compiler_static${tag}='-static'
;;
nvc* | nvcc* | nvfortran*)
# NVIDIA Fortran compiler
lt_prog_compiler_wl${tag}='-Wl,'
lt_prog_compiler_pic${tag}='-fPIC'
lt_prog_compiler_static${tag}='-Bstatic'
;;";
push(@verbose_out, $indent_str . "Patching configure for NVIDIA Fortran compiler (${tag})\n");
$c =~ s/$search_string/$replace_string/g;
}

# Only write out verbose statements and a new configure if the
# configure content actually changed
return
Expand Down
2 changes: 1 addition & 1 deletion config/ompi_setup_fc.m4
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ AC_DEFUN_ONCE([_OMPI_SETUP_FC_COMPILER],[
# Fortran compilers (excluding the f77 compiler names) from AC's
# default list of compilers and use it here. This is the main
# reason we have an OMPI-ized version of the PROG_FC macro.
AC_PROG_FC([gfortran f95 fort xlf95 ifort ifc efc pgfortran pgf95 lf95 f90 xlf90 pgf90 epcf90 nagfor])
AC_PROG_FC([gfortran f95 fort xlf95 ifort ifc efc pgfortran pgf95 lf95 f90 xlf90 pgf90 epcf90 nagfor nvfortran])
FCFLAGS="$ompi_fcflags_save"
OPAL_VAR_SCOPE_POP
])
Expand Down
7 changes: 2 additions & 5 deletions examples/hello_sessions_c.c
Original file line number Diff line number Diff line change
Expand Up @@ -11,14 +11,11 @@ int main(int argc, char** argv) {
MPI_Info info;
MPI_Session s1, s2;

#if 0
/* need PR https://github.com/open-mpi/ompi/pull/12868 to be merged in
* before this can be uncommented.
*/
MPI_Info_create(&info);
#endif
MPI_Session_init(MPI_INFO_NULL, MPI_ERRORS_RETURN, &s1);
MPI_Session_finalize(&s1);
MPI_Session_init(MPI_INFO_NULL, MPI_ERRORS_RETURN, &s2);
MPI_Session_finalize(&s2);
MPI_Info_free(&info);
return 0;
}
13 changes: 3 additions & 10 deletions ompi/communicator/comm.c
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@
* Copyright (c) 2015 Mellanox Technologies. All rights reserved.
* Copyright (c) 2017-2022 IBM Corporation. All rights reserved.
* Copyright (c) 2021 Nanook Consulting. All rights reserved.
* Copyright (c) 2018-2022 Triad National Security, LLC. All rights
* Copyright (c) 2018-2024 Triad National Security, LLC. All rights
* reserved.
* Copyright (c) 2023 Advanced Micro Devices, Inc. All rights reserved.
* $COPYRIGHT$
Expand Down Expand Up @@ -1738,7 +1738,7 @@ int ompi_intercomm_create_from_groups (ompi_group_t *local_group, int local_lead
ompi_communicator_t **newintercomm)
{
ompi_communicator_t *newcomp = NULL, *local_comm, *leader_comm = MPI_COMM_NULL;
ompi_comm_extended_cid_block_t new_block;
ompi_comm_extended_cid_block_t new_block = {0};
bool i_am_leader = local_leader == local_group->grp_my_rank;
ompi_proc_t **rprocs;
uint64_t data[4];
Expand Down Expand Up @@ -1864,14 +1864,7 @@ int ompi_intercomm_create_from_groups (ompi_group_t *local_group, int local_lead
return rc;
}

/* will be using a communicator ID derived from the bridge communicator to save some time */
new_block.block_cid.cid_base = data[1];
new_block.block_cid.cid_sub.u64 = data[2];
new_block.block_nextsub = 0;
new_block.block_nexttag = 0;
new_block.block_level = (int8_t) data[3];

rc = ompi_comm_nextcid (newcomp, NULL, NULL, (void *) tag, &new_block, false, OMPI_COMM_CID_GROUP_NEW);
rc = ompi_comm_nextcid (newcomp, NULL, NULL, (void *) tag, NULL, false, OMPI_COMM_CID_GROUP_NEW);
if ( OMPI_SUCCESS != rc ) {
OBJ_RELEASE(newcomp);
return rc;
Expand Down
Loading
Loading