Fix a memory bug in ompid...helps if you load all the new process status fields.
This commit was SVN r3779.
Этот коммит содержится в:
родитель
8a496b63ee
Коммит
5727a88632
@ -87,20 +87,19 @@ int main(int argc, char *argv[])
|
|||||||
enviro_val = getenv("OMPI_daemon_debug");
|
enviro_val = getenv("OMPI_daemon_debug");
|
||||||
if (NULL != enviro_val) { /* flag was set */
|
if (NULL != enviro_val) { /* flag was set */
|
||||||
ompi_daemon_debug = true;
|
ompi_daemon_debug = true;
|
||||||
ompi_output(0, "ompid: entered daemon");
|
ompi_output(0, "ompid: entered debug mode");
|
||||||
} else {
|
} else {
|
||||||
ompi_daemon_debug = false;
|
ompi_daemon_debug = false;
|
||||||
}
|
}
|
||||||
|
|
||||||
ompi_daemon_debug = true; /**** DEBUGGING PURPOSES */
|
|
||||||
|
|
||||||
if (ompi_daemon_debug) {
|
|
||||||
ompi_output(0, "ompid: daemonizing");
|
|
||||||
}
|
|
||||||
|
|
||||||
/* daemonize myself */
|
/* daemonize myself */
|
||||||
#ifndef WIN32
|
#ifndef WIN32
|
||||||
ompi_daemon_init(NULL);
|
if (!ompi_daemon_debug) {
|
||||||
|
ompi_output(0, "ompid: daemonizing");
|
||||||
|
ompi_daemon_init(NULL);
|
||||||
|
} else {
|
||||||
|
ompi_output(0, "ompid: debug mode - not daemonizing");
|
||||||
|
}
|
||||||
#endif
|
#endif
|
||||||
|
|
||||||
/* setup the thread lock and condition variable */
|
/* setup the thread lock and condition variable */
|
||||||
@ -205,6 +204,8 @@ int main(int argc, char *argv[])
|
|||||||
ompi_registry.assign_ownership(segment, ompi_name_server.get_jobid(ompi_rte_get_self()));
|
ompi_registry.assign_ownership(segment, ompi_name_server.get_jobid(ompi_rte_get_self()));
|
||||||
free(segment);
|
free(segment);
|
||||||
|
|
||||||
|
my_status.rank = ompi_name_server.get_vpid(ompi_rte_get_self());
|
||||||
|
my_status.nodename = strdup(ompi_system_info.nodename);
|
||||||
my_status.status_key = OMPI_PROC_STARTING;
|
my_status.status_key = OMPI_PROC_STARTING;
|
||||||
my_status.exit_code = 0;
|
my_status.exit_code = 0;
|
||||||
if (OMPI_SUCCESS != (ret = ompi_rte_set_process_status(&my_status, ompi_rte_get_self()))) {
|
if (OMPI_SUCCESS != (ret = ompi_rte_set_process_status(&my_status, ompi_rte_get_self()))) {
|
||||||
|
Загрузка…
Ссылка в новой задаче
Block a user