Changeset 717

Timestamp:

06/20/08 17:48:42 (5 months ago)

Author:

francis

Message:

added a stub implementation of inactivity timeouts. To complete, this will need reactor-loop heartbeats

Files:

• trunk/java/src/com/rubyeventmachine/EmReactor.java (modified) (1 diff)
• trunk/java/src/com/rubyeventmachine/EventableChannel.java (modified) (1 diff)
• trunk/java/src/com/rubyeventmachine/EventableDatagramChannel.java (modified) (1 diff)
• trunk/java/src/com/rubyeventmachine/EventableSocketChannel.java (modified) (1 diff)

trunk/java/src/com/rubyeventmachine/EmReactor.java

@@ -313 +313 @@
-                sendData (sig, ByteBuffer.wrap(data.getBytes()));
-                //(Connections.get(sig)).scheduleOutboundData( ByteBuffer.wrap(data.getBytes()));
+        }
+        public void setCommInactivityTimeout (String sig, long mills) {
+                (Connections.get(sig)).setCommInactivityTimeout (mills);
-        }
-        

trunk/java/src/com/rubyeventmachine/EventableChannel.java

@@ -53 +53 @@
-        
-        public boolean writeOutboundData();
+
+        public void setCommInactivityTimeout (long seconds);
-}

trunk/java/src/com/rubyeventmachine/EventableDatagramChannel.java

@@ -164 +164 @@
-                return (bCloseScheduled && outboundQ.isEmpty()) ? false : true;
-        }
+
+        public void setCommInactivityTimeout (long seconds) {
+                // TODO
+                System.out.println ("DATAGRAM: SET COMM INACTIVITY UNIMPLEMENTED " + seconds);
+        }
-}

trunk/java/src/com/rubyeventmachine/EventableSocketChannel.java

@@ -232 +232 @@
-                        return bb;
-        }
+
+        public void setCommInactivityTimeout (long seconds) {
+                // TODO
+                System.out.println ("SOCKET: SET COMM INACTIVITY UNIMPLEMENTED " + seconds);
+        }
-}