def initialize(processor, serverTransport, transportFactory=nil, protocolFactory=nil)
@processor = processor
@serverTransport = serverTransport
- @transportFactory = transportFactory ? transportFactory : Thrift::TransportFactory.new()
- @protocolFactory = protocolFactory ? protocolFactory : Thrift::BinaryProtocolFactory.new()
+ @transportFactory = transportFactory ? transportFactory : Thrift::TransportFactory.new
+ @protocolFactory = protocolFactory ? protocolFactory : Thrift::BinaryProtocolFactory.new
end
- def serve(); nil; end
+ def serve; nil; end
end
deprecate_class! :TServer => Server
super(processor, serverTransport, transportFactory, protocolFactory)
end
- def serve()
+ def serve
begin
- @serverTransport.listen()
+ @serverTransport.listen
while (true)
- client = @serverTransport.accept()
+ client = @serverTransport.accept
trans = @transportFactory.get_transport(client)
prot = @protocolFactory.get_protocol(trans)
begin
rescue Thrift::TransportException, Thrift::ProtocolException => ttx
#print ttx,"\n"
ensure
- trans.close()
+ trans.close
end
end
ensure
- @serverTransport.close()
+ @serverTransport.close
end
end
end
module Thrift
class ThreadedServer < Server
- def serve()
+ def serve
begin
- @serverTransport.listen()
+ @serverTransport.listen
while (true)
- client = @serverTransport.accept()
+ client = @serverTransport.accept
trans = @transportFactory.get_transport(client)
prot = @protocolFactory.get_protocol(trans)
Thread.new(prot, trans) do |p, t|
end
rescue Thrift::TransportException, Thrift::ProtocolException => e
ensure
- t.close()
+ t.close
end
end
end
ensure
- @serverTransport.close()
+ @serverTransport.close
end
end
end
## exceptions that happen in worker threads simply cause that thread
## to die and another to be spawned in its place.
def serve
- @serverTransport.listen()
+ @serverTransport.listen
begin
while (true)
Thread.new do
begin
while (true)
- client = @serverTransport.accept()
+ client = @serverTransport.accept
trans = @transportFactory.get_transport(client)
prot = @protocolFactory.get_protocol(trans)
begin
end
rescue Thrift::TransportException, Thrift::ProtocolException => e
ensure
- trans.close()
+ trans.close
end
end
rescue Exception => e
@exception_q.push(e)
ensure
- @thread_q.pop() # thread died!
+ @thread_q.pop # thread died!
end
end
end
ensure
- @serverTransport.close()
+ @serverTransport.close
end
end
end