Sha256: 130eae4d32743d18808ed45bca6be638760604370f73b292d167d5871a9abcc5
Contents?: true
Size: 1.04 KB
Versions: 4
Compression:
Stored size: 1.04 KB
Contents
module Protobuf module Rpc class EventedRunner def self.stop EventMachine.stop_event_loop if EventMachine.reactor_running? Protobuf::Logger.info 'Shutdown complete' end def self.run(server) # Ensure errors thrown within EM are caught and logged appropriately EventMachine.error_handler do |error| if error.message == 'no acceptor' raise 'Failed binding to %s:%d (%s)' % [server.host, server.port, error.message] else Protobuf::Logger.error error.message Protobuf::Logger.error error.backtrace.join("\n") end end # Startup and run the rpc server EM.schedule do EventMachine.start_server(server.host, server.port, Protobuf::Rpc::Evented::Server) && \ Protobuf::Logger.info('RPC Server listening at %s:%d in %s' % [server.host, server.port, server.env]) end # Join or start the reactor EM.reactor_running? ? EM.reactor_thread.join : EM.run end end end end
Version data entries
4 entries across 4 versions & 1 rubygems