Code Review
/
controller.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Implement NetconfMessage.toString()
[controller.git]
/
opendaylight
/
netconf
/
netconf-client
/
src
/
main
/
java
/
org
/
opendaylight
/
controller
/
netconf
/
client
/
SshClientChannelInitializer.java
diff --git
a/opendaylight/netconf/netconf-client/src/main/java/org/opendaylight/controller/netconf/client/SshClientChannelInitializer.java
b/opendaylight/netconf/netconf-client/src/main/java/org/opendaylight/controller/netconf/client/SshClientChannelInitializer.java
index 829ac304bd667f680d813e32ff58ed9f9b0b6f37..7a14c4f4ac3507e953e4cdf595cc6575b38cd86e 100644
(file)
--- a/
opendaylight/netconf/netconf-client/src/main/java/org/opendaylight/controller/netconf/client/SshClientChannelInitializer.java
+++ b/
opendaylight/netconf/netconf-client/src/main/java/org/opendaylight/controller/netconf/client/SshClientChannelInitializer.java
@@
-11,9
+11,8
@@
import io.netty.channel.Channel;
import io.netty.util.concurrent.Promise;
import java.io.IOException;
import org.opendaylight.controller.netconf.nettyutil.AbstractChannelInitializer;
import io.netty.util.concurrent.Promise;
import java.io.IOException;
import org.opendaylight.controller.netconf.nettyutil.AbstractChannelInitializer;
-import org.opendaylight.controller.netconf.nettyutil.handler.ssh.SshHandler;
import org.opendaylight.controller.netconf.nettyutil.handler.ssh.authentication.AuthenticationHandler;
import org.opendaylight.controller.netconf.nettyutil.handler.ssh.authentication.AuthenticationHandler;
-import org.opendaylight.controller.netconf.nettyutil.handler.ssh.client.
Invok
er;
+import org.opendaylight.controller.netconf.nettyutil.handler.ssh.client.
AsyncSshHandl
er;
import org.opendaylight.protocol.framework.SessionListenerFactory;
final class SshClientChannelInitializer extends AbstractChannelInitializer<NetconfClientSession> {
import org.opendaylight.protocol.framework.SessionListenerFactory;
final class SshClientChannelInitializer extends AbstractChannelInitializer<NetconfClientSession> {
@@
-33,8
+32,8
@@
final class SshClientChannelInitializer extends AbstractChannelInitializer<Netco
@Override
public void initialize(final Channel ch, final Promise<NetconfClientSession> promise) {
try {
@Override
public void initialize(final Channel ch, final Promise<NetconfClientSession> promise) {
try {
- final Invoker invoker = Invoker.subsystem("netconf");
- ch.pipeline().addFirst(
new SshHandler(authenticationHandler, invok
er));
+ // ssh handler has to be the first handler in pipeline
+ ch.pipeline().addFirst(
AsyncSshHandler.createForNetconfSubsystem(authenticationHandl
er));
super.initialize(ch,promise);
} catch (final IOException e) {
throw new RuntimeException(e);
super.initialize(ch,promise);
} catch (final IOException e) {
throw new RuntimeException(e);