Changeset 717

Show
Ignore:
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:

Legend:

Unmodified
Added
Removed
Modified
Copied
Moved
  • trunk/java/src/com/rubyeventmachine/EmReactor.java

    r668 r717  
    313313                sendData (sig, ByteBuffer.wrap(data.getBytes())); 
    314314                //(Connections.get(sig)).scheduleOutboundData( ByteBuffer.wrap(data.getBytes())); 
     315        } 
     316        public void setCommInactivityTimeout (String sig, long mills) { 
     317                (Connections.get(sig)).setCommInactivityTimeout (mills); 
    315318        } 
    316319         
  • trunk/java/src/com/rubyeventmachine/EventableChannel.java

    r668 r717  
    5353         
    5454        public boolean writeOutboundData(); 
     55 
     56        public void setCommInactivityTimeout (long seconds); 
    5557} 
  • trunk/java/src/com/rubyeventmachine/EventableDatagramChannel.java

    r668 r717  
    164164                return (bCloseScheduled && outboundQ.isEmpty()) ? false : true; 
    165165        } 
     166 
     167        public void setCommInactivityTimeout (long seconds) { 
     168                // TODO 
     169                System.out.println ("DATAGRAM: SET COMM INACTIVITY UNIMPLEMENTED " + seconds); 
     170        } 
    166171} 
  • trunk/java/src/com/rubyeventmachine/EventableSocketChannel.java

    r668 r717  
    232232                        return bb; 
    233233        } 
     234 
     235        public void setCommInactivityTimeout (long seconds) { 
     236                // TODO 
     237                System.out.println ("SOCKET: SET COMM INACTIVITY UNIMPLEMENTED " + seconds); 
     238        } 
    234239}