module Fluent::ServerModule

def supervisor_sigusr1_handler
  if log = config[:logger_initializer]
    # Creating new thread due to mutex can't lock
    # in main thread during trap context
    Thread.new {
      log.reopen!
    }.run
  end
  if config[:worker_pid]
    config[:worker_pid].each_value do |pid|
      Process.kill(:USR1, pid)
      # don't rescue Errno::ESRCH here (invalid status)
    end
  end
end