You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by ak...@apache.org on 2004/02/20 09:30:09 UTC
svn commit: rev 6791 - incubator/directory/eve/trunk/eve/frontend/input/pojo-impl/src/java/org/apache/eve/input
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() ;