From c9e499f1f033c416263c11be2a51dc75e126dfe8 Mon Sep 17 00:00:00 2001 From: zerofruit <14wnrkim@gmail.com> Date: Sat, 13 Aug 2022 11:50:35 +0900 Subject: [PATCH] fix: (transport) fix DefaultChannelPipeline --- .../main/java/io/el/channel/DefaultChannelPipeline.java | 9 ++++----- 1 file changed, 4 insertions(+), 5 deletions(-) diff --git a/transport/src/main/java/io/el/channel/DefaultChannelPipeline.java b/transport/src/main/java/io/el/channel/DefaultChannelPipeline.java index fcf3bb1..a0da7e6 100644 --- a/transport/src/main/java/io/el/channel/DefaultChannelPipeline.java +++ b/transport/src/main/java/io/el/channel/DefaultChannelPipeline.java @@ -47,9 +47,8 @@ private ChannelPipeline addLast(ChannelHandler handler) { final AbstractChannelHandlerContext prev = this.tailContext.prev; // TODO: generate name with the {@link ChannelHandler.getClass()} String name = UUID.randomUUID().toString(); - EventLoop eventLoop = null; final AbstractChannelHandlerContext newHandlerContext = - new DefaultChannelHandlerContext(name, this, eventLoop, handler); + new DefaultChannelHandlerContext(name, this, channel().channelEventLoop(), handler); this.tailContext.prev = newHandlerContext; newHandlerContext.next = this.tailContext; @@ -207,16 +206,16 @@ public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws E private static final class TailContext extends AbstractChannelHandlerContext { - private final TailContextHandler context; + private final TailContextHandler handler; public TailContext(ChannelPipeline pipeline) { super(HEAD_NAME, pipeline, null, TailContextHandler.class); - this.context = new TailContextHandler(); + this.handler = new TailContextHandler(); } @Override public ChannelHandler handler() { - return this.context; + return this.handler; } }