return activationPromise;
}
+ @Deprecated(since = "7.0.0", forRemoval = true)
protected MinaSshNettyChannel newMinaSshNettyChannel() {
return new MinaSshNettyChannel(this, sshSession);
}
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
+@Deprecated(since = "7.0.0", forRemoval = true)
// Non-final for testing
class MinaSshNettyChannel extends AbstractServerChannel {
private static final Logger LOG = LoggerFactory.getLogger(MinaSshNettyChannel.class);
import org.opendaylight.netconf.shaded.sshd.common.io.IoWriteFuture;
import org.opendaylight.netconf.shaded.sshd.common.util.buffer.Buffer;
+@Deprecated(since = "7.0.0", forRemoval = true)
public class MinaSshNettyChannelTest {
private CallHomeSessionContext mockContext;
private ClientSession mockSession;
* Dispatcher class for creating servers and clients. The idea is to first create servers and clients and the run the
* start method that will handle sockets in different thread.
*/
-@Deprecated
+@Deprecated(forRemoval = true)
public abstract class AbstractNetconfDispatcher<S extends NetconfSession, L extends NetconfSessionListener<? super S>> {
protected interface ChannelPipelineInitializer<C extends Channel, S extends NetconfSession> {
/**
/**
* Netty SSH handler class. Acts as interface between Netty and SSH library.
*/
+@Deprecated(since = "7.0.0", forRemoval = true)
public final class AsyncSshHandler extends ChannelOutboundHandlerAdapter {
private static final Logger LOG = LoggerFactory.getLogger(AsyncSshHandler.class);
private static final VarHandle DISCONNECTED;
* Listener on async input stream from SSH session.
* This listeners schedules reads in a loop until the session is closed or read fails.
*/
+@Deprecated(since = "7.0.0", forRemoval = true)
public final class AsyncSshHandlerReader implements SshFutureListener<IoReadFuture>, AutoCloseable {
-
private static final Logger LOG = LoggerFactory.getLogger(AsyncSshHandlerReader.class);
-
private static final int BUFFER_SIZE = 2048;
private final AutoCloseable connectionClosedCallback;
* Async Ssh writer. Takes messages(byte arrays) and sends them encrypted to remote server.
* Also handles pending writes by caching requests until pending state is over.
*/
+@Deprecated(since = "7.0.0", forRemoval = true)
public final class AsyncSshHandlerWriter implements AutoCloseable {
private static final Logger LOG = LoggerFactory.getLogger(AsyncSshHandlerWriter.class);
private static final Pattern NON_ASCII = Pattern.compile("([^\\x20-\\x7E\\x0D\\x0A])+");
import static java.util.Objects.requireNonNull;
import com.google.common.annotations.Beta;
-import java.io.Serial;
import org.opendaylight.netconf.shaded.sshd.common.SshException;
/**
*/
@Beta
public class AuthenticationFailedException extends SshException {
- @Serial
+ @java.io.Serial
private static final long serialVersionUID = 1L;
public AuthenticationFailedException(final String message) {
import static com.google.common.base.Verify.verify;
-import com.google.common.annotations.Beta;
import com.google.common.collect.ImmutableList;
import java.util.List;
import java.util.stream.Stream;
/**
* A {@link ClientBuilder} which builds {@link NetconfSshClient} instances.
*/
-@Beta
+@Deprecated(since = "7.0.0", forRemoval = true)
public class NetconfClientBuilder extends ClientBuilder {
// RFC8332 rsa-sha2-256/rsa-sha2-512 are not a part of Mina's default set of signatures for clients as of 2.5.1.
// Add them to ensure interop with modern highly-secured devices.
import static java.util.Objects.requireNonNull;
-import com.google.common.annotations.Beta;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelPipeline;
import java.io.IOException;
* A {@link ClientSessionImpl} which additionally allows creation of NETCONF subsystem channel, which is routed to
* a particular {@link ChannelHandlerContext}.
*/
-@Beta
+@Deprecated(since = "7.0.0", forRemoval = true)
public final class NetconfClientSessionImpl extends ClientSessionImpl implements NettyAwareClientSession {
public NetconfClientSessionImpl(final ClientFactoryManager client, final IoSession ioSession) throws Exception {
super(client, ioSession);
*/
package org.opendaylight.netconf.nettyutil.handler.ssh.client;
-import com.google.common.annotations.Beta;
import org.opendaylight.netconf.shaded.sshd.client.ClientFactoryManager;
import org.opendaylight.netconf.shaded.sshd.client.session.SessionFactory;
import org.opendaylight.netconf.shaded.sshd.common.io.IoSession;
/**
* A {@link SessionFactory} which creates {@link NetconfClientSessionImpl}s.
*/
-@Beta
+@Deprecated(since = "7.0.0", forRemoval = true)
public class NetconfSessionFactory extends SessionFactory {
public NetconfSessionFactory(final ClientFactoryManager client) {
super(client);
*/
package org.opendaylight.netconf.nettyutil.handler.ssh.client;
-import com.google.common.annotations.Beta;
import org.opendaylight.netconf.shaded.sshd.client.SshClient;
/**
* An extension to {@link SshClient} which uses {@link NetconfSessionFactory} to create sessions (leading towards
* {@link NetconfClientSessionImpl}.
*/
-@Beta
+@Deprecated(since = "7.0.0", forRemoval = true)
public class NetconfSshClient extends SshClient {
@Override
protected NetconfSessionFactory createSessionFactory() {
*/
package org.opendaylight.netconf.nettyutil.handler.ssh.client;
-import com.google.common.annotations.Beta;
import io.netty.channel.ChannelHandlerContext;
import io.netty.channel.ChannelPipeline;
import java.io.IOException;
* A {@link ClientSession} which additionally allows subsystem channels which are forwarded to a particular Netty
* channel context.
*/
-@Beta
+@Deprecated(since = "7.0.0", forRemoval = true)
public interface NettyAwareClientSession extends ClientSession {
/**
* Allocate a channel to the specified subsystem. Incoming data on the channel will be routed to the
/**
* Abstract base class for {@link ChannelSubsystem}s backed by a Netty {@link ChannelHandlerContext}.
*/
+@Deprecated(since = "7.0.0", forRemoval = true)
abstract class NettyChannelSubsystem extends ChannelSubsystem {
private static final Logger LOG = LoggerFactory.getLogger(NettyChannelSubsystem.class);
Code Review / netconf.git / commitdiff