andreacavalli/netty5
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Ensure ChannelInputShutdownEvent is triggered only once

Browse Source
This commit is contained in:
Trustin Lee 2012-08-30 13:35:34 +09:00
parent 44bfc47a52
commit b4643c42aa
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
testsuite/src/test/java/io/netty/testsuite/transport/socket/SocketShutdownOutputByPeerTest.java
View File

@ -28,6 +28,7 @@ import java.net.Socket;
import java.util.concurrent.BlockingQueue; import java.util.concurrent.BlockingQueue;
import java.util.concurrent.CountDownLatch; import java.util.concurrent.CountDownLatch;
import java.util.concurrent.SynchronousQueue; import java.util.concurrent.SynchronousQueue;
import java.util.concurrent.atomic.AtomicInteger;
import org.junit.Test; import org.junit.Test;
@ -63,6 +64,7 @@ public class SocketShutdownOutputByPeerTest extends AbstractServerSocketTest {
assertTrue(h.ch.isInputShutdown()); assertTrue(h.ch.isInputShutdown());
assertFalse(h.ch.isOutputShutdown()); assertFalse(h.ch.isOutputShutdown());
assertEquals(1, h.closure.getCount()); assertEquals(1, h.closure.getCount());
assertEquals(1, h.halfClosureCount.intValue());
} finally { } finally {
s.close(); s.close();
} }
@ -99,6 +101,7 @@ public class SocketShutdownOutputByPeerTest extends AbstractServerSocketTest {
assertTrue(h.ch.isOutputShutdown()); assertTrue(h.ch.isOutputShutdown());
assertEquals(1, h.halfClosure.getCount()); assertEquals(1, h.halfClosure.getCount());
assertEquals(0, h.halfClosureCount.intValue());
} finally { } finally {
s.close(); s.close();
} }
@ -109,6 +112,7 @@ public class SocketShutdownOutputByPeerTest extends AbstractServerSocketTest {
final BlockingQueue<Byte> queue = new SynchronousQueue<Byte>(); final BlockingQueue<Byte> queue = new SynchronousQueue<Byte>();
final CountDownLatch halfClosure = new CountDownLatch(1); final CountDownLatch halfClosure = new CountDownLatch(1);
final CountDownLatch closure = new CountDownLatch(1); final CountDownLatch closure = new CountDownLatch(1);
final AtomicInteger halfClosureCount = new AtomicInteger();
@Override @Override
public void channelActive(ChannelHandlerContext ctx) throws Exception { public void channelActive(ChannelHandlerContext ctx) throws Exception {
@ -128,6 +132,7 @@ public class SocketShutdownOutputByPeerTest extends AbstractServerSocketTest {
@Override @Override
public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception { public void userEventTriggered(ChannelHandlerContext ctx, Object evt) throws Exception {
if (evt instanceof ChannelInputShutdownEvent) { if (evt instanceof ChannelInputShutdownEvent) {
halfClosureCount.incrementAndGet();
halfClosure.countDown(); halfClosure.countDown();
} }
} }