Class: EventMachine::EvmaUNIXClient
Instance Attribute Summary
Attributes inherited from Selectable
#io, #uuid
Class Method Summary
collapse
Instance Method Summary
collapse
#eventable_read, #get_outbound_data_size, #get_peername, #heartbeat, #schedule_close, #send_data
Methods inherited from Selectable
#close_scheduled?, #get_peername, #heartbeat, #set_inactivity_timeout
Constructor Details
Returns a new instance of EvmaUNIXClient.
742
743
744
745
|
# File 'lib/em/pure_ruby.rb', line 742
def initialize io
super
@pending = true
end
|
Class Method Details
.connect(chain) ⇒ Object
730
731
732
733
734
735
736
737
738
739
|
# File 'lib/em/pure_ruby.rb', line 730
def self.connect chain
sd = Socket.new( Socket::AF_LOCAL, Socket::SOCK_STREAM, 0 )
begin
sd.connect_nonblock( Socket.pack_sockaddr_un( chain ))
rescue Errno::EINPROGRESS
end
EvmaUNIXClient.new sd
end
|
Instance Method Details
#eventable_write ⇒ Object
756
757
758
759
760
761
762
763
764
765
|
# File 'lib/em/pure_ruby.rb', line 756
def eventable_write
if @pending
@pending = false
if 0 == io.getsockopt(Socket::SOL_SOCKET, Socket::SO_ERROR).unpack("i").first
EventMachine::event_callback uuid, ConnectionCompleted, ""
end
else
super
end
end
|
#select_for_reading? ⇒ Boolean
752
753
754
|
# File 'lib/em/pure_ruby.rb', line 752
def select_for_reading?
@pending ? false : super
end
|
#select_for_writing? ⇒ Boolean
748
749
750
|
# File 'lib/em/pure_ruby.rb', line 748
def select_for_writing?
@pending ? true : super
end
|