You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@mina.apache.org by mh...@apache.org on 2008/02/21 22:58:11 UTC
svn commit: r630016 -
/mina/trunk/core/src/test/java/org/apache/mina/transport/AbstractFileRegionTest.java
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();
}
});