# File lib/pr_eventmachine.rb, line 722 722: def self.connect chain 723: sd = Socket.new( Socket::AF_LOCAL, Socket::SOCK_STREAM, 0 ) 724: begin 725: # TODO, this assumes a current Ruby snapshot. 726: # We need to degrade to a nonblocking connect otherwise. 727: sd.connect_nonblock( Socket.pack_sockaddr_un( chain )) 728: rescue Errno::EINPROGRESS 729: end 730: EvmaUNIXClient.new sd 731: end