lib/fusuma/plugin/inputs/input.rb in fusuma-2.0.0.pre2 vs lib/fusuma/plugin/inputs/input.rb in fusuma-2.0.0
- old
+ new
@@ -23,9 +23,10 @@
line = io.readline_nonblock("\n").chomp
rescue EOFError => e
warn "#{input.class.name}: #{e}"
warn 'Send SIGKILL to fusuma processes'
inputs.reject { |i| i == input }.each do |i|
+ warn "stop process: #{i.class.name.underscore}"
Process.kill(:SIGKILL, i.pid)
end
exit 1
rescue StandardError => e
warn "#{input.class.name}: #{e}"