Changeset 141

Timestamp:

05/25/06 15:39:29 (2 years ago)

Author:

blackhedd

Message:

TCP connects (nonblocking)

Files:

• experiments/machine/lib/machine/eio.rb (modified) (1 diff)
• experiments/machine/test/eio_test.rb (modified) (2 diffs)

experiments/machine/lib/machine/eio.rb

@@ -186 +186 @@
-end
-
+#####################################
+
+module Machine
+class TcpConnectEventableIO < EventableIO
+
+  # We assume we're getting a TCP socket on which
+  # connect_nonblock has been called.
+  # DO NOT attempt to read the socket.
+  # When it selects writable, the connect has completed.
+  #
+  def initialize *args
+    super
+    @pending = true
+  end
+
+  def select_writable?
+    @pending ? true : super
+  end
+
+  def select_readable?
+    @pending ? false : super
+  end
+
+  def event_write
+    if @pending
+      @pending = false
+      send_event Event.new(:connect)
+    else
+      super
+    end
+  end
+
+end
+end
+
+

experiments/machine/test/eio_test.rb

@@ -13 +13 @@
-  def setup
-    #Reactor.instance.quiet
+    # Have a thread going, because it messes up Ruby's io.sysread function
+    Thread.new {sleep 1000}
-  end
-
@@ -19 +21 @@
-
-  def test_eio
-
-
-
-
-
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
-    }
+    }
+
-    Reactor.instance.run
-