Changeset 248

Timestamp:

08/19/06 09:02:44 (2 years ago)

Author:

blackhedd

Message:

supported get_peername for connected streams

Files:

• version_0/lib/pr_eventmachine.rb (modified) (5 diffs)
• version_0/ReleaseAnnouncement (modified) (1 diff)

version_0/lib/pr_eventmachine.rb

@@ -35 +35 @@
-# 
-
+# TODO List:
+# TCP-connects currently assume non-blocking connect is available- need to
+#  degrade automatically on versions of Ruby prior to June 2006.
+#
-
-require 'singleton'
@@ -107 +111 @@
-    def signal_loopbreak
-      Reactor.instance.signal_loopbreak
+    end
+
+    # #get_peername
+    def get_peername sig
+      selectable = Reactor.instance.get_selectable( sig ) or raise "unknown get_peername target"
+      selectable.get_peername
-    end
-
@@ -277 +287 @@
-  def_delegator :@my_selectable, :send_data
-  def_delegator :@my_selectable, :schedule_close
+  def_delegator :@my_selectable, :get_peername
-end
-
@@ -311 +322 @@
-    def select_for_writing?
-      false
+    end
+
+    def get_peername
+      nil
-    end
-
@@ -428 +443 @@
-    end
-
+    # #get_peername
+    # This is defined in the normal way on connected stream objects.
+    # Return an object that is suitable for passing to Socket#unpack_sockaddr_in or variants.
+    # We could also use a convenience method that did the unpacking automatically.
+    def get_peername
+      io.getpeername
+    end
+
-  end
-

version_0/ReleaseAnnouncement

@@ -15 +15 @@
-Support for user-defined events.
-
+Stable APIs- use without worrying about having your code break.
+
-------------
-