def detach_process_impl(num, forward_interval, &block)
children = []
num.times do |i|
pid, forward_thread = DetachProcessManager.instance.fork(forward_interval, self)
if pid
$log.info "detached process", class: self.class, pid: pid
children << [pid, forward_thread]
next
end
begin
on_detach_process(i)
block.call
Engine.define_singleton_method(:stop) do
end
fin = FinishWait.new
trap :INT do
fin.stop
end
trap :TERM do
fin.stop
end
fin.wait
on_exit_process(i)
exit! 0
ensure
$log.error "unknown error while shutting down this child process", error: $!.to_s, pid: Process.pid
$log.error_backtrace
end
exit! 1
end
define_singleton_method(:shutdown) do
children.each {|pair|
begin
pid = pair[0]
forward_thread = pair[1]
if pid
Process.kill(:TERM, pid)
forward_thread.join
Process.waitpid(pid)
pair[0] = nil
end
rescue
$log.error "unknown error while shutting down remote child process", error: $!.to_s
$log.error_backtrace
end
}
end
forwarders = children.map {|pair| pair[1].forwarder }
if forwarders.length > 1
fwd = DetachProcessManager::MultiForwarder.new(forwarders)
else
fwd = forwarders[0]
end
define_singleton_method(:emit) do |tag,es,chain|
chain.next
fwd.emit(tag, es)
end
end