Class: MessagePack::RPC::UDPServerTransport

Inherits:
Object
  • Object
show all
Defined in:
lib/msgpack/rpc/transport/udp.rb

Defined Under Namespace

Classes: ResponseSender, ServerSocket

Instance Method Summary collapse

Constructor Details

#initialize(address) ⇒ UDPServerTransport

Returns a new instance of UDPServerTransport.



124
125
126
127
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 124

def initialize(address)
	@address = address
	@sock = nil
end

Instance Method Details

#close ⇒ Object

ServerTransport interface



152
153
154
155
156
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 152

def close
	return unless @lsock
	@lsock.detach if @lsock.attached?
	@lsock.close
end

#listen(server) ⇒ Object

ServerTransport interface



130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
 
# File 'lib/msgpack/rpc/transport/udp.rb', line 130

def listen(server)
	@server = server
	host, port = *@address.unpack
	io = UDPSocket.new
	io.bind(*@address)

	begin
		@sock = ServerSocket.new(io, @server)
	rescue
		io.close
		raise
	end

	begin
		@server.loop.attach(@sock)
	rescue
		@sock.close
		raise
	end
end