Method: Resqued::ListenerProxy#worker_finished

Defined in:
lib/resqued/listener_proxy.rb

#worker_finished(pid) ⇒ Object

Public: Tell the listener process that a worker finished.



94
95
96
97
98
99
100
 
# File 'lib/resqued/listener_proxy.rb', line 94

def worker_finished(pid)
  return if @master_socket.nil?
  @master_socket.puts(pid)
rescue Errno::EPIPE
  @master_socket.close
  @master_socket = nil
end