svn commit: r637758 - /mina/trunk/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeEventOrderTest.java

[trustin]

Author: trustin
Date: Mon Mar 17 00:14:20 2008
New Revision: 637758

URL: http://svn.apache.org/viewvc?rev=637758&view=rev
Log:
Fixed failing VmPipeEventOrderTest

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

Modified: 
mina/trunk/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeEventOrderTest.java
URL: 
http://svn.apache.org/viewvc/mina/trunk/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeEventOrderTest.java?rev=637758&r1=637757&r2=637758&view=diff
==============================================================================
--- 
mina/trunk/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeEventOrderTest.java
 (original)
+++ 
mina/trunk/core/src/test/java/org/apache/mina/transport/vmpipe/VmPipeEventOrderTest.java
 Mon Mar 17 00:14:20 2008
@@ -196,21 +196,12 @@
 
         final VmPipeConnector vmPipeConnector = new VmPipeConnector();
         vmPipeConnector.getFilterChain().addLast("executor", new 
ExecutorFilter());
-        vmPipeConnector.setHandler(new IoHandlerAdapter() {
-            @Override
-            public void sessionOpened(IoSession session) throws Exception {
-                session.write(IoBuffer.wrap(new byte[1]));
-            }
-        });
+        vmPipeConnector.setHandler(new IoHandlerAdapter());
         ConnectFuture connectFuture = vmPipeConnector.connect(vmPipeAddress);
         connectFuture.awaitUninterruptibly();
-        
-        // Wait until one byte is written.
-        while (connectFuture.getSession().getWrittenBytes() == 0) {
-            Thread.yield();
-        }
-        
-        connectFuture.getSession().close();
+        connectFuture.getSession().write(IoBuffer.wrap(new byte[1]));
+        connectFuture.getSession().closeOnFlush().awaitUninterruptibly();
+
         semaphore.tryAcquire(1, TimeUnit.SECONDS);
         vmPipeAcceptor.unbind(vmPipeAddress);
         Assert.assertEquals("ABCD", stringBuffer.toString());