Contents

require 'eventmachine'
require 'socket'

class WorkerWatcher < EventMachine::ProcessWatch
  def initialize(options = {})
    @pid = options[:pid]
    @stdout = options[:stdout]
    @stderr = options[:stderr]
    @reply_exchange = options[:reply_exchange]
  end

  def process_exited
    ignored, status = Process::waitpid2 @pid
    if status.exitstatus != 0
      reply = {:type => :crash,
               :hostname => Socket.gethostname,
               :stdout => @stdout.read,
               :stderr => @stderr.read}
      @reply_exchange.publish(Yajl::Encoder.encode(reply))
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
gorgon-0.2.0	lib/gorgon/worker_watcher.rb
gorgon-0.1.1	lib/gorgon/worker_watcher.rb
gorgon-0.1.0	lib/gorgon/worker_watcher.rb
gorgon-0.0.2	lib/gorgon/worker_watcher.rb
gorgon-0.0.1	lib/gorgon/worker_watcher.rb