supervisor: Clear previous worker pids when receives kill signals. ref …

…#1674
fluent · Sep 5, 2017 · 6dac783 · 6dac783
1 parent 43a594c
commit 6dac783
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