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

trustin · trustin · commit 9c1b9492d52d · 2014-01-13T23:27:56.000+09:00
diff --git a/transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java b/transport/src/test/java/io/netty/channel/DefaultChannelPipelineTest.java
@@ -189,8 +189,9 @@ public void testChannelHandlerContextNavigation() {
 
     @Test
     public void testFireChannelRegistered() throws Exception {
-        ChannelPipeline pipeline = new LocalChannel(group.next()).pipeline();
         final CountDownLatch latch = new CountDownLatch(1);
+        Channel ch = new LocalChannel(group.next());
+        ChannelPipeline pipeline = ch.pipeline();
         pipeline.addLast(new ChannelInitializer<Channel>() {
             @Override
             protected void initChannel(Channel ch) throws Exception {
@@ -202,7 +203,7 @@ public void channelRegistered(ChannelHandlerContext ctx) throws Exception {
                 });
             }
         });
-        pipeline.fireChannelRegistered();
+        ch.unsafe().register(ch.newPromise());
         assertTrue(latch.await(2, TimeUnit.SECONDS));
     }
 
