svn commit: r577697 - /mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java

[jvermillard]

Author: jvermillard
Date: Thu Sep 20 04:45:41 2007
New Revision: 577697

URL: http://svn.apache.org/viewvc?rev=577697&view=rev
Log:
problem on selecting sockets

Modified:
    
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java

Modified: 
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java?rev=577697&r1=577696&r2=577697&view=diff
==============================================================================
--- 
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java 
(original)
+++ 
mina/trunk/core/src/main/java/org/apache/mina/common/AbstractIoProcessor.java 
Thu Sep 20 04:45:41 2007
@@ -544,12 +544,12 @@
                 // Now mask the preferred ops with the mask of the current 
session
                 int mask = session.getTrafficMask().getInterestOps();
                 try {
-                    setOpRead(session, isOpRead(session) || ( (mask 
&SelectionKey.OP_READ) >0) );
+                    setOpRead(session, isOpRead(session) && ( (mask 
&SelectionKey.OP_READ) >0) );
                 } catch (Exception e) {
                     session.getFilterChain().fireExceptionCaught(e);
                 }
                 try {
-                    setOpWrite(session, isOpWrite(session) || ( (mask 
&SelectionKey.OP_WRITE) >0) );
+                    setOpWrite(session, isOpWrite(session) && ( (mask 
&SelectionKey.OP_WRITE) >0) );
                 } catch (Exception e) {
                     session.getFilterChain().fireExceptionCaught(e);
                 }