Class: Thrift::ServerSocket

Inherits:
BaseServerTransport show all
Defined in:
lib/thrift/transport/server_socket.rb

Direct Known Subclasses

SSLServerSocket

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(host_or_port, port = nil) ⇒ ServerSocket

call-seq: initialize(host = nil, port)



26
27
28
29
30
31
32
33
34
35
 
# File 'lib/thrift/transport/server_socket.rb', line 26

def initialize(host_or_port, port = nil)
  if port
    @host = host_or_port
    @port = port
  else
    @host = nil
    @port = host_or_port
  end
  @handle = nil
end

Instance Attribute Details

#handle ⇒ Object (readonly)

Returns the value of attribute handle.



37
38
39
 
# File 'lib/thrift/transport/server_socket.rb', line 37

def handle
  @handle
end

Instance Method Details

#accept ⇒ Object 



43
44
45
46
47
48
49
50
51
 
# File 'lib/thrift/transport/server_socket.rb', line 43

def accept
  unless @handle.nil?
    sock = @handle.accept
    sock.setsockopt(::Socket::IPPROTO_TCP, ::Socket::TCP_NODELAY, 1)
    trans = Socket.new
    trans.handle = sock
    trans
  end
end

#close ⇒ Object 



53
54
55
56
 
# File 'lib/thrift/transport/server_socket.rb', line 53

def close
 @handle.close unless @handle.nil? or @handle.closed?
 @handle = nil
end

#closed? ⇒ Boolean

Returns:

  • (Boolean) 


58
59
60
 
# File 'lib/thrift/transport/server_socket.rb', line 58

def closed?
  @handle.nil? or @handle.closed?
end

#listen ⇒ Object 



39
40
41
 
# File 'lib/thrift/transport/server_socket.rb', line 39

def listen
  @handle = TCPServer.new(@host, @port)
end

#to_io ⇒ Object 



62
63
64
 
# File 'lib/thrift/transport/server_socket.rb', line 62

def to_io
  @handle&.to_io || raise(IOError, 'closed stream')
end

#to_s ⇒ Object 



66
67
68
 
# File 'lib/thrift/transport/server_socket.rb', line 66

def to_s
  "socket(#{@host}:#{@port})"
end