Merge pull request #2321 from fluent/add-worker-id-to-process-name

system: Add worker_id to process_name when workers is larger than 1
fluent · Mar 12, 2019 · eae8611 · eae8611
2 parents da3affc + 4bf14fd
commit eae8611
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/lib/fluent/supervisor.rb b/lib/fluent/supervisor.rb
@@ -716,7 +716,13 @@ def logging_with_console_output
     end
 
     def main_process(&block)
-      Process.setproctitle("worker:#{@process_name}") if @process_name
+      if @process_name
+        if @workers > 1
+          Process.setproctitle("worker:#{@process_name}#{ENV['SERVERENGINE_WORKER_ID']}")
+        else
+          Process.setproctitle("worker:#{@process_name}")
+        end
+      end
 
       unrecoverable_error = false