Method: Thrift::NonblockingServer::IOManager#initialize

Defined in:
lib/thrift/server/nonblocking_server.rb

#initialize(processor, server_transport, transport_factory, protocol_factory, num, logger) ⇒ IOManager

Returns a new instance of IOManager.



101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
 
# File 'lib/thrift/server/nonblocking_server.rb', line 101

def initialize(processor, server_transport, transport_factory, protocol_factory, num, logger)
  @processor = processor
  @server_transport = server_transport
  @transport_factory = transport_factory
  @protocol_factory = protocol_factory
  @num_threads = num
  @logger = logger
  @connections = []
  @buffers = Hash.new { |h,k| h[k] = '' }
  @signal_queue = Queue.new
  @signal_pipes = IO.pipe
  @signal_pipes[1].sync = true
  @worker_queue = Queue.new
  @shutdown_queue = Queue.new
end