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

Fix flacky test which was missed when commit 8fe3c83e4c

Browse Source
This commit is contained in:
Norman Maurer 2016-05-22 19:33:48 +02:00
parent 06d76eeea4
commit 26a175cd94
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java
View File

@ -769,9 +769,10 @@ public class DefaultChannelPipelineTest {
} }
@Test(timeout = 3000) @Test(timeout = 3000)
public void testHandlerAddedThrowsAndRemovedThrowsException() { public void testHandlerAddedThrowsAndRemovedThrowsException() throws InterruptedException {
final EventExecutorGroup group1 = new DefaultEventExecutorGroup(1); final EventExecutorGroup group1 = new DefaultEventExecutorGroup(1);
try { try {
final CountDownLatch latch = new CountDownLatch(1);
final Promise<Void> promise = group1.next().newPromise(); final Promise<Void> promise = group1.next().newPromise();
final Exception exceptionAdded = new RuntimeException(); final Exception exceptionAdded = new RuntimeException();
final Exception exceptionRemoved = new RuntimeException(); final Exception exceptionRemoved = new RuntimeException();
@ -785,11 +786,13 @@ public class DefaultChannelPipelineTest {
@Override @Override
public void handlerRemoved(ChannelHandlerContext ctx) throws Exception { public void handlerRemoved(ChannelHandlerContext ctx) throws Exception {
latch.countDown();
throw exceptionRemoved; throw exceptionRemoved;
} }
}); });
pipeline.addLast(group1, new CheckExceptionHandler(exceptionAdded, promise)); pipeline.addLast(group1, new CheckExceptionHandler(exceptionAdded, promise));
group.register(pipeline.channel()).syncUninterruptibly(); group.register(pipeline.channel()).syncUninterruptibly();
latch.await();
assertNull(pipeline.context(handlerName)); assertNull(pipeline.context(handlerName));
promise.syncUninterruptibly(); promise.syncUninterruptibly();
} finally { } finally {