Merge pull request #1683 from fluent/clear-worker-pid-after-kill

supervisor: Clear previous worker pids when receives kill signals. ref #1674
fluent · Sep 6, 2017 · d14ea82 · d14ea82
2 parents 187d5de + 6dac783
commit d14ea82
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/lib/fluent/supervisor.rb b/lib/fluent/supervisor.rb
@@ -173,7 +173,9 @@ def supervisor_sigusr1_handler
 
     def kill_worker
       if config[:worker_pid]
-        config[:worker_pid].each do |pid|
+        pids = config[:worker_pid].clone
+        config[:worker_pid].clear
+        pids.each do |pid|
           if Fluent.windows?
             Process.kill :KILL, pid
           else