Method: Thrift::NonblockingServer#initialize

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

#initialize(processor, server_transport, transport_factory = nil, protocol_factory = nil, num = 20, logger = nil) ⇒ NonblockingServer

Returns a new instance of NonblockingServer.


26
27
28
29
30
31
32
33
34
35
36
37
 
# File 'lib/thrift/server/nonblocking_server.rb', line 26

def initialize(processor, server_transport, transport_factory=nil, protocol_factory=nil, num=20, logger=nil)
  super(processor, server_transport, transport_factory, protocol_factory)
  @num_threads = num
  if logger.nil?
    @logger = Logger.new(STDERR)
    @logger.level = Logger::WARN
  else
    @logger = logger
  end
  @shutdown_semaphore = Mutex.new
  @transport_semaphore = Mutex.new
end