svn commit: r630016 - /mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractFileRegionTest.java

[mheath]

Author: mheath
Date: Thu Feb 21 13:58:10 2008
New Revision: 630016

URL: http://svn.apache.org/viewvc?rev=630016&view=rev
Log:
Fixed race condition in FileRegion test.

Modified:
    
mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractFileRegionTest.java

Modified: 
mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractFileRegionTest.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractFileRegionTest.java?rev=630016&r1=630015&r2=630016&view=diff
==============================================================================
--- 
mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractFileRegionTest.java
 (original)
+++ 
mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractFileRegionTest.java
 Thu Feb 21 13:58:10 2008
@@ -16,6 +16,7 @@
 import org.apache.mina.common.IoConnector;
 import org.apache.mina.common.IoHandlerAdapter;
 import org.apache.mina.common.IoSession;
+import org.apache.mina.common.WriteFuture;
 import org.apache.mina.util.AvailablePortFinder;
 
 public abstract class AbstractFileRegionTest extends TestCase {
@@ -44,10 +45,6 @@
                 session.close();
             }
             @Override
-            public void sessionClosed(IoSession session) throws Exception {
-                latch.countDown();
-            }
-            @Override
             public void messageReceived(IoSession session, Object message) 
throws Exception {
                 IoBuffer buffer = (IoBuffer) message;
                 while (buffer.hasRemaining()) {
@@ -74,6 +71,10 @@
             public void exceptionCaught(IoSession session, Throwable cause)
                     throws Exception {
                 exception[0] = cause;
+                session.close();
+            }
+            @Override
+            public void sessionClosed(IoSession session) throws Exception {
                 latch.countDown();
             }
         });