Class: NFS::SUNRPC::TCPServer
- Defined in:
- lib/nfs/sunrpc/tcp_server.rb
Instance Method Summary collapse
-
#initialize(programs, port = nil, host = '127.0.0.1') ⇒ TCPServer
constructor
A new instance of TCPServer.
Methods inherited from Server
#host, #join, #port, #shutdown, #start
Constructor Details
#initialize(programs, port = nil, host = '127.0.0.1') ⇒ TCPServer
Returns a new instance of TCPServer.
7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 |
# File 'lib/nfs/sunrpc/tcp_server.rb', line 7 def initialize(programs, port = nil, host = '127.0.0.1') @server = ::TCPServer.new(host, port) @programs = hash_programs(programs) @thread = Thread.new do loop do Thread.new(@server.accept) do |socket| loop do frame = socket.recv(4).unpack1('N') len = frame & ~0x80000000 break unless len data = socket.recv(len) result = run_procedure(data) if !result.nil? result = [result.length | (128 << 24)].pack('N') + result socket.send(result, 0) end end end end end if block_given? begin yield(self) ensure shutdown end end end |