Skip to content

Commit 61fc6bd

Browse files
authored
Merge pull request #11227 from rhc54/cmr50/sing
v5.0: Fix singleton operations
2 parents 39e379c + 641e809 commit 61fc6bd

File tree

3 files changed

+15
-16
lines changed

3 files changed

+15
-16
lines changed

3rd-party/openpmix

Submodule openpmix updated 167 files

3rd-party/prrte

Submodule prrte updated 110 files

ompi/dpm/dpm.c

Lines changed: 13 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
* Copyright (c) 2014-2020 Research Organization for Information Science
2121
* and Technology (RIST). All rights reserved.
2222
* Copyright (c) 2018 Amazon.com, Inc. or its affiliates. All Rights reserved.
23-
* Copyright (c) 2021 Nanook Consulting. All rights reserved.
23+
* Copyright (c) 2021-2022 Nanook Consulting. All rights reserved.
2424
* Copyright (c) 2018-2022 Triad National Security, LLC. All rights
2525
* reserved.
2626
* Copyright (c) 2022 IBM Corporation. All rights reserved.
@@ -1596,18 +1596,6 @@ int ompi_dpm_spawn(int count, const char *array_of_commands[],
15961596
opal_list_append(&job_info, &info->super);
15971597
}
15981598

1599-
/* spawn procs */
1600-
ninfo = opal_list_get_size(&job_info);
1601-
if (0 < ninfo) {
1602-
PMIX_INFO_CREATE(pinfo, ninfo);
1603-
n = 0;
1604-
OPAL_LIST_FOREACH(info, &job_info, opal_info_item_t) {
1605-
PMIX_INFO_XFER(&pinfo[n], &info->info);
1606-
++n;
1607-
}
1608-
}
1609-
OPAL_LIST_DESTRUCT(&job_info);
1610-
16111599
if (opal_process_info.is_singleton) {
16121600
/* The GDS 'hash' component is known to work for singleton, so
16131601
* recommend it. The user may set this envar to override the setting.
@@ -1646,6 +1634,18 @@ int ompi_dpm_spawn(int count, const char *array_of_commands[],
16461634
opal_argv_free(dash_host);
16471635
}
16481636

1637+
/* spawn procs */
1638+
ninfo = opal_list_get_size(&job_info);
1639+
if (0 < ninfo) {
1640+
PMIX_INFO_CREATE(pinfo, ninfo);
1641+
n = 0;
1642+
OPAL_LIST_FOREACH(info, &job_info, opal_info_item_t) {
1643+
PMIX_INFO_XFER(&pinfo[n], &info->info);
1644+
++n;
1645+
}
1646+
}
1647+
OPAL_LIST_DESTRUCT(&job_info);
1648+
16491649
pret = PMIx_Spawn(pinfo, ninfo, apps, count, nspace);
16501650
rc = opal_pmix_convert_status(pret);
16511651
if (NULL != pinfo) {
@@ -2047,7 +2047,6 @@ static int start_dvm(char **hostfiles, char **dash_host)
20472047
opal_asprintf(&tmp, "%d", death_pipe[0]);
20482048
opal_argv_append_nosize(&args, tmp);
20492049
free(tmp);
2050-
opal_argv_append_nosize(&args, "--daemonize");
20512050

20522051
/* Fork off the child */
20532052
pid = fork();

0 commit comments

Comments
 (0)