directory-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From akaras...@apache.org
Subject svn commit: rev 6791 - incubator/directory/eve/trunk/eve/frontend/input/pojo-impl/src/java/org/apache/eve/input
Date Fri, 20 Feb 2004 08:30:09 GMT
Author: akarasulu
Date: Fri Feb 20 00:30:09 2004
New Revision: 6791

Modified:
   incubator/directory/eve/trunk/eve/frontend/input/pojo-impl/src/java/org/apache/eve/input/DefaultInputManager.java
Log:
correctly detecting only closes and blowing away unused const

Modified: incubator/directory/eve/trunk/eve/frontend/input/pojo-impl/src/java/org/apache/eve/input/DefaultInputManager.java
==============================================================================
--- incubator/directory/eve/trunk/eve/frontend/input/pojo-impl/src/java/org/apache/eve/input/DefaultInputManager.java
(original)
+++ incubator/directory/eve/trunk/eve/frontend/input/pojo-impl/src/java/org/apache/eve/input/DefaultInputManager.java
Fri Feb 20 00:30:09 2004
@@ -49,8 +49,6 @@
 public class DefaultInputManager extends AbstractSubscriber
     implements InputManager, ConnectSubscriber, DisconnectSubscriber
 {
-    public static final long TIMEOUT_CYCLES = 2000 ;
-    
     /** the thread driving this Runnable */ 
     private Thread m_thread = null ;
     /** parameter used to politely stop running thread */
@@ -386,8 +384,7 @@
                     l_buf = m_bp.getBuffer( this ) ;
                     int l_count = 0 ;
                     
-                    
-                    if ( ( l_count = l_channel.read( l_buf ) ) <= 0 )
+                    if ( ( l_count = l_channel.read( l_buf ) ) == -1 )
                     {
                         l_channel.socket().close() ;
                         l_channel.close() ;

Mime
View raw message