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.
734
735
736
737
|
# File 'lib/pr_eventmachine.rb', line 734
def initialize io
super
@pending = true
end
|
Class Method Details
.connect(chain) ⇒ Object
722
723
724
725
726
727
728
729
730
731
|
# File 'lib/pr_eventmachine.rb', line 722
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
748
749
750
751
752
753
754
755
756
757
|
# File 'lib/pr_eventmachine.rb', line 748
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
744
745
746
|
# File 'lib/pr_eventmachine.rb', line 744
def select_for_reading?
@pending ? false : super
end
|
#select_for_writing? ⇒ Boolean
740
741
742
|
# File 'lib/pr_eventmachine.rb', line 740
def select_for_writing?
@pending ? true : super
end
|