Changeset 142

Timestamp:

05/25/06 20:13:20 (2 years ago)

Author:

blackhedd

Message:

Socket acceptors

Files:

• experiments/machine/lib/machine/eio.rb (modified) (2 diffs)

experiments/machine/lib/machine/eio.rb

@@ -3 +3 @@
-
-require 'fcntl'
+require 'socket'
-
-module Machine
@@ -222 +223 @@
-
-
+#####################################
+
+module Machine
+class TcpServerEventableIO < EventableIO
+
+  #--
+  # Ruby accept_nonblock is applied on class Socket,
+  # but for some unknown reason, TCPServer is not a
+  # subclass of Socket. It's a subclass of IO->BasicSocket.
+  # So we can't do non-blocking I/O of TCPServers.
+  # This is the required idiom for creating a TCP server:
+  # sd = Socket.new( Socket::AF_INET, Socket::SOCK_STREAM, 0)
+  # sd.bind( Socket.pack_sockaddr_in( port, server ))
+  # sd.listen(5)
+  # eio = TCPServerEventableIO.new( sd )
+  #
+  def initialize io
+    super
+  end
+
+  def select_writable?
+    false
+  end
+
+  def select_readable?
+    true
+  end
+
+  #--
+  # accept_nonblock returns an array consisting of the accepted
+  # socket and a sockaddr_in which names the peer.
+  def event_read
+    begin
+      10.times {
+        sd = io.accept_nonblock
+        send_event( DataEvent.new( :accept, sd[0] ))
+      }
+    rescue Errno::EWOULDBLOCK, Errno::EAGAIN
+    end
+  end
+
+end
+end
+
+
+