module Fluent::DetachMultiProcessMixin
def configure(conf)
def configure(conf) super if detach_process = conf['detach_process'] b3v = Config.bool_value(detach_process) case b3v when nil num = detach_process.to_i if num > 0 @detach_process = true @detach_process_num = num elsif detach_process =~ /0+/ @detach_process = false else @detach_process = true end when true @detach_process = true when false @detach_process = false end end end
def detach_multi_process(&block)
def detach_multi_process(&block) if @detach_process detach_process_impl(@detach_process_num, &block) else block.call end end
def initialize
def initialize @detach_process_num = 2 super end