svn commit: r997098 - /mina/trunk/mina-core/src/test/java/org/apache/mina/filter/stream/AbstractStreamWriteFilterTest.java

[maarten]

Author: maarten
Date: Tue Sep 14 21:17:50 2010
New Revision: 997098

URL: http://svn.apache.org/viewvc?rev=997098&view=rev
Log:
added more logging to testcase (to diagnose unstable build)

Modified:
    
mina/trunk/mina-core/src/test/java/org/apache/mina/filter/stream/AbstractStreamWriteFilterTest.java

Modified: 
mina/trunk/mina-core/src/test/java/org/apache/mina/filter/stream/AbstractStreamWriteFilterTest.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/mina-core/src/test/java/org/apache/mina/filter/stream/AbstractStreamWriteFilterTest.java?rev=997098&r1=997097&r2=997098&view=diff
==============================================================================
--- 
mina/trunk/mina-core/src/test/java/org/apache/mina/filter/stream/AbstractStreamWriteFilterTest.java
 (original)
+++ 
mina/trunk/mina-core/src/test/java/org/apache/mina/filter/stream/AbstractStreamWriteFilterTest.java
 Tue Sep 14 21:17:50 2010
@@ -49,6 +49,8 @@ import org.apache.mina.util.AvailablePor
 import org.easymock.IArgumentMatcher;
 import org.easymock.classextension.EasyMock;
 import org.junit.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
 
 /**
  * TODO Add documentation
@@ -57,6 +59,8 @@ import org.junit.Test;
  */
 public abstract class AbstractStreamWriteFilterTest<M, U extends 
AbstractStreamWriteFilter<M>> {
 
+    private static final Logger LOGGER = 
LoggerFactory.getLogger(AbstractStreamWriteFilterTest.class);
+
     protected final IoSession session = new DummySession();
 
     abstract protected U createFilter();
@@ -394,24 +398,29 @@ public abstract class AbstractStreamWrit
         @Override
         public void exceptionCaught(IoSession session, Throwable cause)
                 throws Exception {
+            LOGGER.error("SenderHandler: exceptionCaught", cause);
             latch.countDown();
         }
 
         @Override
         public void sessionClosed(IoSession session) throws Exception {
+            LOGGER.info("SenderHandler: sessionClosed");
             latch.countDown();
         }
 
         @Override
         public void sessionIdle(IoSession session, IdleStatus status)
                 throws Exception {
+            LOGGER.info("SenderHandler: sessionIdle");
             latch.countDown();
         }
 
         @Override
         public void messageSent(IoSession session, Object message)
                 throws Exception {
+            LOGGER.info("SenderHandler: messageSent");
             if (message == this.message) {
+                LOGGER.info("message == this.message");
                 latch.countDown();
             }
         }
@@ -441,28 +450,33 @@ public abstract class AbstractStreamWrit
         @Override
         public void sessionIdle(IoSession session, IdleStatus status)
                 throws Exception {
+            LOGGER.info("ReceiverHandler: sessionIdle");
             session.close(true);
         }
 
         @Override
         public void exceptionCaught(IoSession session, Throwable cause)
                 throws Exception {
+            LOGGER.error("ReceiverHandler: exceptionCaught", cause);
             latch.countDown();
         }
 
         @Override
         public void sessionClosed(IoSession session) throws Exception {
+            LOGGER.info("ReceiverHandler: sessionClosed");
             latch.countDown();
         }
 
         @Override
         public void messageReceived(IoSession session, Object message)
                 throws Exception {
+            LOGGER.info("messageReceived");
             IoBuffer buf = (IoBuffer) message;
             while (buf.hasRemaining()) {
                 digest.update(buf.get());
                 bytesRead++;
             }
+            LOGGER.info("messageReceived: bytesRead = {}", bytesRead);
             if (bytesRead >= size) {
                 session.close(true);
             }