Changeset 143

Timestamp:

05/25/06 20:27:24 (2 years ago)

Author:

blackhedd

Message:

nonblocking accepts for unix-domain sockets

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

@@ -239 +239 @@
-  # eio = TCPServerEventableIO.new( sd )
-  #
+  # For Unix-domain sockets, the idiom is:
+  # sd = Socket.new( Socket::AF_UNIX, Socket::SOCK_STREAM, 0)
+  # sd.bind( Socket.pack_sockaddr_un( socketname ))
+  # sd.listen(5)
+  # eio = TCPServerEventableIO.new( sd )
+  #
+  #
-  def initialize io
-    super

experiments/machine/test/eio_test.rb

@@ -21 +21 @@
-
-  def test_eio
+=begin
-    sin = Socket::pack_sockaddr_in(25, "relay.spheriq.net")
-    40.times {
@@ -44 +45 @@
-    }
-    }
+=end
-
+    #sd = Socket.new( Socket::AF_INET, Socket::SOCK_STREAM, 0)
+    #sockaddr = Socket.pack_sockaddr_in( 8901, "127.0.0.1" )
+    #sd.bind sockaddr
+    #sd.listen( 100 )
+
+    File.unlink("./a.chain")
+    sd = Socket.new( Socket::AF_UNIX, Socket::SOCK_STREAM, 0)
+    sockaddr = Socket.pack_sockaddr_un( "./a.chain" )
+    sd.bind sockaddr
+    sd.listen( 100 )
+    eio = TcpServerEventableIO.new(sd) {|me|
+      me.add_handler(:accept) {|evt|
+        eio = EventableIO.new(evt.data) {|me|
+          me.add_handler(:read) {|evt|
+            me.send_data "<<<#{evt.data.chomp}>>>\n"
+          }
+        }
+      }
+    }
-    Reactor.instance.run
-