Clean up SSH server subsystem handling

[netconf.git] / netconf / netconf-netty-util / src / main / java / org / opendaylight / netconf / nettyutil / AbstractNetconfSession.java

diff --git a/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/AbstractNetconfSession.java b/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/AbstractNetconfSession.java
index 3eaf83156f3494677196a20b808ae36a0e2588b4..7f1009613af2bee37144fe03a79172f7a7118505 100644 (file)
--- a/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/AbstractNetconfSession.java
+++ b/netconf/netconf-netty-util/src/main/java/org/opendaylight/netconf/nettyutil/AbstractNetconfSession.java
@@ -15,7 +15,6 @@ import io.netty.channel.ChannelHandler;
 import io.netty.channel.ChannelHandlerContext;
 import io.netty.channel.ChannelPromise;
 import io.netty.channel.SimpleChannelInboundHandler;
-import io.netty.channel.embedded.EmbeddedChannel;
 import io.netty.handler.codec.ByteToMessageDecoder;
 import io.netty.handler.codec.MessageToByteEncoder;
 import java.io.EOFException;
@@ -93,14 +92,6 @@ public abstract class AbstractNetconfSession<S extends NetconfSession, L extends
             }
         });
 
-        // FIXME: NETCONF-1106: this is a workaround for netconf-server's NetconfSubsystem using EmbeddedChannel instead
-        //                      of correctly integrating with the underlying transport channel
-        if (channel instanceof EmbeddedChannel embeddedChannel) {
-            // Embedded event loop implementation has no executor, it requires explicit invocation to process
-            synchronized (channel) {
-                embeddedChannel.runPendingTasks();
-            }
-        }
         return promise;
     }