You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@directory.apache.org by tr...@apache.org on 2005/04/24 19:31:48 UTC
svn commit: r164491 -
/directory/network/trunk/src/java/org/apache/mina/io/socket/SocketIoProcessor.java
Author: trustin
Date: Sun Apr 24 10:31:47 2005
New Revision: 164491
URL: http://svn.apache.org/viewcvs?rev=164491&view=rev
Log:
Fixed: SocketIoProcessor drops dataRead event when connection is closed by client.
Modified:
directory/network/trunk/src/java/org/apache/mina/io/socket/SocketIoProcessor.java
Modified: directory/network/trunk/src/java/org/apache/mina/io/socket/SocketIoProcessor.java
URL: http://svn.apache.org/viewcvs/directory/network/trunk/src/java/org/apache/mina/io/socket/SocketIoProcessor.java?rev=164491&r1=164490&r2=164491&view=diff
==============================================================================
--- directory/network/trunk/src/java/org/apache/mina/io/socket/SocketIoProcessor.java (original)
+++ directory/network/trunk/src/java/org/apache/mina/io/socket/SocketIoProcessor.java Sun Apr 24 10:31:47 2005
@@ -258,17 +258,15 @@
session.increaseReadBytes( readBytes );
session.setIdle( IdleStatus.BOTH_IDLE, false );
session.setIdle( IdleStatus.READER_IDLE, false );
- if( ret >= 0 )
+
+ if( readBytes > 0 )
{
- if( readBytes > 0 )
- {
- ByteBuffer newBuf = ByteBuffer.allocate( readBytes );
- newBuf.put( buf );
- newBuf.flip();
- session.getFilters().dataRead( session, newBuf );
- }
+ ByteBuffer newBuf = ByteBuffer.allocate( readBytes );
+ newBuf.put( buf );
+ newBuf.flip();
+ session.getFilters().dataRead( session, newBuf );
}
- else
+ if( ret < 0 )
{
scheduleRemove( session );
}