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

Fix a bug where DefaultChannelPipelineTest.testFireChannelRegistered() triggers channelRegistered() twice

Browse Source
This commit is contained in:
Trustin Lee 2014-01-13 23:25:32 +09:00
parent febc53daaa
commit 3373f83cbb
1 changed files with 2 additions and 3 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

@ -190,9 +190,8 @@ public class DefaultChannelPipelineTest {
@Test @Test
public void testFireChannelRegistered() throws Exception { public void testFireChannelRegistered() throws Exception {
ChannelPipeline pipeline = new LocalChannel().pipeline();
group.register(pipeline.channel());
final CountDownLatch latch = new CountDownLatch(1); final CountDownLatch latch = new CountDownLatch(1);
ChannelPipeline pipeline = new LocalChannel().pipeline();
pipeline.addLast(new ChannelInitializer<Channel>() { pipeline.addLast(new ChannelInitializer<Channel>() {
@Override @Override
protected void initChannel(Channel ch) throws Exception { protected void initChannel(Channel ch) throws Exception {
@ -204,7 +203,7 @@ public class DefaultChannelPipelineTest {
}); });
} }
}); });
pipeline.fireChannelRegistered(); group.register(pipeline.channel());
assertTrue(latch.await(2, TimeUnit.SECONDS)); assertTrue(latch.await(2, TimeUnit.SECONDS));
} }