Class: MessagePack::RPC::UNIXClientTransport

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

Defined Under Namespace

Classes: ClientSocket

Instance Method Summary collapse

Constructor Details

#initialize(session, address) ⇒ UNIXClientTransport

Returns a new instance of UNIXClientTransport.



59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 59

def initialize(session, address)
	io = UNIXSocket.new(address)

	begin
		@sock = ClientSocket.new(io, session)
	rescue
		io.close
		raise
	end

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

Instance Method Details

#close ⇒ Object

ClientTransport interface



83
84
85
86
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 83

def close
	@sock.detach if @sock.attached?
	@sock.close
end

#send_data(data) ⇒ Object

ClientTransport interface



78
79
80
 
# File 'lib/msgpack/rpc/transport/unix.rb', line 78

def send_data(data)
	@sock.send_data(data)
end