# File lib/fluent/plugin/out_exec_filter.rb, line 258 def kill_child(join_wait) begin Process.kill(:TERM, @pid) rescue #Errno::ECHILD, Errno::ESRCH, Errno::EPERM # Errno::ESRCH 'No such process', ignore # child process killed by signal chained from fluentd process end if @thread.join(join_wait) # @thread successfully shutdown return end begin Process.kill(:KILL, @pid) rescue #Errno::ECHILD, Errno::ESRCH, Errno::EPERM # ignore if successfully killed by :TERM end @thread.join end
# File lib/fluent/plugin/out_exec_filter.rb, line 316 def run @parser.call(@io) rescue @log.error "exec_filter thread unexpectedly failed with an error.", :command=>@command, :error=>$!.to_s @log.warn_backtrace $!.backtrace ensure pid, stat = Process.waitpid2(@pid) unless @finished @log.error "exec_filter process unexpectedly exited.", :command=>@command, :ecode=>stat.to_i unless @respawns == 0 @log.warn "exec_filter child process will respawn for next input data (respawns #{@respawns})." end end end
# File lib/fluent/plugin/out_exec_filter.rb, line 277 def shutdown @finished = true @mutex.synchronize do kill_child(60) # TODO wait time end end
# File lib/fluent/plugin/out_exec_filter.rb, line 247 def start(command) @command = command @mutex.synchronize do @io = IO.popen(command, "r+") @pid = @io.pid @io.sync = true @thread = Thread.new(&method(:run)) end @finished = false end
# File lib/fluent/plugin/out_exec_filter.rb, line 298 def try_respawn return false if @respawns == 0 @mutex.synchronize do return false if @respawns == 0 kill_child(5) # TODO wait time @io = IO.popen(@command, "r+") @pid = @io.pid @io.sync = true @thread = Thread.new(&method(:run)) @respawns -= 1 if @respawns > 0 end @log.warn "exec_filter child process successfully respawned.", :command => @command, :respawns => @respawns true end
# File lib/fluent/plugin/out_exec_filter.rb, line 284 def write(chunk) begin chunk.write_to(@io) rescue Errno::EPIPE => e # Broken pipe (child process unexpectedly exited) @log.warn "exec_filter Broken pipe, child process maybe exited.", :command => @command if try_respawn retry # retry chunk#write_to with child respawned else raise e # to retry #write with other ChildProcess instance (when num_children > 1) end end end
Generated with the Darkfish Rdoc Generator 2.