Added pthread_atfork call

src/slurmd/elan_interconnect.c

@@ -29,6 +29,7 @@ static int do_env(int nodeid, int nnodes, int procid, int nprocs) ;
 /*launch_tasks should really be named launch_job_step*/
 int launch_tasks ( launch_tasks_request_msg_t * launch_msg )
 {
+	pthread_atfork ( NULL , NULL , pthread_fork_child_after ) ;
 	return interconnect_init ( launch_msg );
 }
 

src/slurmd/no_interconnect.c

@@ -6,6 +6,7 @@
 /*launch_tasks should really be named launch_job_step*/
 int launch_tasks ( launch_tasks_request_msg_t * launch_msg )
 {
+	pthread_atfork ( NULL , NULL , pthread_fork_child_after ) ;
 	return interconnect_init ( launch_msg );
 }
 

src/slurmd/task_mgr.c

@@ -319,3 +319,18 @@ int reattach_tasks_streams ( reattach_tasks_streams_msg_t * req_msg )
 	}
 	return error_code ;
 }
+
+void pthread_fork_before ( void )
+{
+}
+
+void pthread_fork_parent_after ( void )
+{
+}
+
+void pthread_fork_child_after ( void )
+{
+	log_options_t log_opts_def = LOG_OPTS_STDERR_ONLY ;
+	log_init( "slurmd", log_opts_def, SYSLOG_FACILITY_DAEMON, NULL);
+}
+

src/slurmd/task_mgr.h

@@ -52,6 +52,10 @@ int reattach_tasks_streams ( reattach_tasks_streams_msg_t * req_msg ) ;
 
 void * task_exec_thread ( void * arg ) ;
 
+void pthread_fork_before ( void );
+void pthread_fork_parent_after ( void );
+void pthread_fork_child_after ( void );
+
 typedef struct task_start
 {
 	/*task control thread id*/