|
@@ -370,6 +370,7 @@ static int mod_child_init(int rank)
|
|
if(pid==0){
|
|
if(pid==0){
|
|
if (cfg_child_init()) return -1;
|
|
if (cfg_child_init()) return -1;
|
|
close(kz_worker_pipes_fds[i*2+1]);
|
|
close(kz_worker_pipes_fds[i*2+1]);
|
|
|
|
+ cfg_update();
|
|
return(kz_amqp_consumer_worker_proc(kz_worker_pipes_fds[i*2]));
|
|
return(kz_amqp_consumer_worker_proc(kz_worker_pipes_fds[i*2]));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -383,6 +384,7 @@ static int mod_child_init(int rank)
|
|
return -1; /* error */
|
|
return -1; /* error */
|
|
if(pid==0){
|
|
if(pid==0){
|
|
if (cfg_child_init()) return -1;
|
|
if (cfg_child_init()) return -1;
|
|
|
|
+ cfg_update();
|
|
return(kz_amqp_consumer_proc(s));
|
|
return(kz_amqp_consumer_proc(s));
|
|
}
|
|
}
|
|
}
|
|
}
|
|
@@ -395,6 +397,7 @@ static int mod_child_init(int rank)
|
|
if(pid==0){
|
|
if(pid==0){
|
|
if (cfg_child_init()) return -1;
|
|
if (cfg_child_init()) return -1;
|
|
close(kz_cmd_pipe_fds[1]);
|
|
close(kz_cmd_pipe_fds[1]);
|
|
|
|
+ cfg_update();
|
|
kz_amqp_publisher_proc(kz_cmd_pipe_fds[0]);
|
|
kz_amqp_publisher_proc(kz_cmd_pipe_fds[0]);
|
|
}
|
|
}
|
|
return 0;
|
|
return 0;
|