From 19dcb8172704f2756631b558c530dabc78c7dcb9 Mon Sep 17 00:00:00 2001 From: Trustin Lee Date: Sat, 2 Jun 2012 02:43:26 -0700 Subject: [PATCH] Add comments for easier understanding --- .../channel/local/LocalTransportThreadModelTest.java | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java b/transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java index 93367b88db..3f2cc7a4a4 100644 --- a/transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java +++ b/transport/src/test/java/io/netty/channel/local/LocalTransportThreadModelTest.java @@ -68,18 +68,21 @@ public class LocalTransportThreadModelTest { TestHandler h3 = new TestHandler(); Channel ch = new LocalChannel(); + // With no EventExecutor specified, h1 will be always invoked by EventLoop 'l'. ch.pipeline().addLast(h1); + // h2 will be always invoked by EventExecutor 'e1'. ch.pipeline().addLast(e1, h2); + // h3 will be always invoked by EventExecutor 'e2'. ch.pipeline().addLast(e2, h3); - l.register(ch).sync(); - - ch.connect(ADDR).sync(); + l.register(ch).sync().channel().connect(ADDR).sync(); + // Fire inbound events from all possible starting points. ch.pipeline().fireInboundBufferUpdated(); ch.pipeline().context(h1).fireInboundBufferUpdated(); ch.pipeline().context(h2).fireInboundBufferUpdated(); ch.pipeline().context(h3).fireInboundBufferUpdated(); + // Fire outbound events from all possible starting points. ch.pipeline().flush(); ch.pipeline().context(h3).flush(); ch.pipeline().context(h2).flush();