Skip to content
Snippets Groups Projects
Commit 928b1efd authored by Morris Jette's avatar Morris Jette
Browse files

Call mpi_fini() on slurmstepd shutdown

Required to remove stale PMI2 sockets from /tmp
parent 42c85ad8
No related branches found
No related tags found
No related merge requests found
...@@ -49,6 +49,8 @@ ...@@ -49,6 +49,8 @@
#include "src/common/cpu_frequency.h" #include "src/common/cpu_frequency.h"
#include "src/common/gres.h" #include "src/common/gres.h"
#include "src/common/mpi.h"
#include "src/common/node_select.h"
#include "src/common/slurm_jobacct_gather.h" #include "src/common/slurm_jobacct_gather.h"
#include "src/common/slurm_acct_gather_profile.h" #include "src/common/slurm_acct_gather_profile.h"
#include "src/common/slurm_rlimits_info.h" #include "src/common/slurm_rlimits_info.h"
...@@ -57,7 +59,6 @@ ...@@ -57,7 +59,6 @@
#include "src/common/xmalloc.h" #include "src/common/xmalloc.h"
#include "src/common/xsignal.h" #include "src/common/xsignal.h"
#include "src/common/plugstack.h" #include "src/common/plugstack.h"
#include "src/common/node_select.h"
#include "src/slurmd/common/core_spec_plugin.h" #include "src/slurmd/common/core_spec_plugin.h"
#include "src/slurmd/common/slurmstepd_init.h" #include "src/slurmd/common/slurmstepd_init.h"
...@@ -163,6 +164,7 @@ main (int argc, char *argv[]) ...@@ -163,6 +164,7 @@ main (int argc, char *argv[])
pthread_join(job->msgid, NULL); pthread_join(job->msgid, NULL);
ending: ending:
mpi_fini(); /* Remove stale PMI2 sockets */
#ifdef MEMORY_LEAK_DEBUG #ifdef MEMORY_LEAK_DEBUG
acct_gather_conf_destroy(); acct_gather_conf_destroy();
(void) core_spec_g_fini(); (void) core_spec_g_fini();
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment