Author: elecharny
Date: Mon Dec 12 22:58:27 2011
New Revision: 1213486
URL: http://svn.apache.org/viewvc?rev=1213486&view=rev
Log:
Split the chained commands to ease the debugging tasks.
Modified:
mina/trunk/core/src/main/java/org/apache/mina/filterchain/DefaultIoFilterController.java
mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java
Modified:
mina/trunk/core/src/main/java/org/apache/mina/filterchain/DefaultIoFilterController.java
URL:
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/filterchain/DefaultIoFilterController.java?rev=1213486&r1=1213485&r2=1213486&view=diff
==============================================================================
---
mina/trunk/core/src/main/java/org/apache/mina/filterchain/DefaultIoFilterController.java
(original)
+++
mina/trunk/core/src/main/java/org/apache/mina/filterchain/DefaultIoFilterController.java
Mon Dec 12 22:58:27 2011
@@ -127,7 +127,9 @@ public class DefaultIoFilterController i
writeChainPosition.set(chain.length - 1);
// we call the first filter, it's supposed to call the next ones
using the filter chain controller
- chain[writeChainPosition.get()].messageWriting(session, message,
this);
+ int position = writeChainPosition.get();
+ IoFilter nextFilter = chain[position];
+ nextFilter.messageWriting(session, message, this);
}
// put the future in the last write request
if (future != null) {
@@ -158,7 +160,7 @@ public class DefaultIoFilterController i
}
/**
- * At the end of write chain processing, enqueue final encoded {@link
ByteBuffer} message in the session
+ * At the end of write chain processing, enqueue final encoded {@link
ByteBuffer} message in the session
*/
private void enqueueFinalWriteMessage(IoSession session, Object message) {
LOG.debug("end of write chan we enqueue the message in the session :
{}", message);
Modified:
mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java
URL:
http://svn.apache.org/viewvc/mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java?rev=1213486&r1=1213485&r2=1213486&view=diff
==============================================================================
---
mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java
(original)
+++
mina/trunk/core/src/main/java/org/apache/mina/session/AbstractIoSession.java
Mon Dec 12 22:58:27 2011
@@ -464,7 +464,8 @@ public abstract class AbstractIoSession
}
// process the queue
- getFilterChain().processMessageWriting(this, message, future);
+ IoFilterController chain = getFilterChain();
+ chain.processMessageWriting(this, message, future);
}
/**
