public class DefaultForwarder extends AbstractInnerCloseable implements Forwarder, SessionHolder<Session>, PortForwardingEventListenerManager
Modifier and Type | Class and Description |
---|---|
(package private) class |
DefaultForwarder.StaticIoHandler |
AbstractCloseable.State
closeFuture, futureLock, state
log
Constructor and Description |
---|
DefaultForwarder(ConnectionService service) |
doCloseGracefully, doCloseImmediately
addCloseFutureListener, builder, close, getFutureLock, isClosed, isClosing, removeCloseFutureListener
debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
startLocalPortForwarding
isRemotePortForwardingStartedForPort
addCloseFutureListener, close, close, close, getMaxCloseWaitTime, isClosed, isClosing, isOpen, removeCloseFutureListener
getSessionContext
public static final java.util.Set<ClientChannelEvent> STATIC_IO_MSG_RECEIVED_EVENTS
private final ConnectionService service
private final IoHandlerFactory socksProxyIoHandlerFactory
private final Session sessionInstance
private final java.lang.Object localLock
private final java.util.Map<SshdSocketAddress,SshdSocketAddress> localToRemote
private final java.util.Map<SshdSocketAddress,java.net.InetSocketAddress> boundLocals
private final java.lang.Object dynamicLock
private final java.util.Map<java.lang.Integer,SshdSocketAddress> remoteToLocal
private final java.util.Map<java.lang.Integer,SocksProxy> dynamicLocal
private final java.util.Map<java.lang.Integer,java.net.InetSocketAddress> boundDynamic
private final java.util.Set<LocalForwardingEntry> localForwards
private final IoHandlerFactory staticIoHandlerFactory
private final java.util.Collection<PortForwardingEventListener> listeners
private final java.util.Collection<PortForwardingEventListenerManager> managersHolder
private final PortForwardingEventListener listenerProxy
private IoAcceptor localAcceptor
private IoAcceptor dynamicAcceptor
public DefaultForwarder(ConnectionService service)
public PortForwardingEventListener getPortForwardingEventListenerProxy()
getPortForwardingEventListenerProxy
in interface PortForwardingEventListenerManager
public void addPortForwardingEventListener(PortForwardingEventListener listener)
PortForwardingEventListenerManager
addPortForwardingEventListener
in interface PortForwardingEventListenerManager
listener
- The PortForwardingEventListener
to add - never null
public void removePortForwardingEventListener(PortForwardingEventListener listener)
PortForwardingEventListenerManager
removePortForwardingEventListener
in interface PortForwardingEventListenerManager
listener
- The PortForwardingEventListener
to remove - ignored if null
public java.util.Collection<PortForwardingEventListenerManager> getRegisteredManagers()
getRegisteredManagers
in interface PortForwardingEventListenerManagerHolder
public boolean addPortForwardingEventListenerManager(PortForwardingEventListenerManager manager)
addPortForwardingEventListenerManager
in interface PortForwardingEventListenerManagerHolder
public boolean removePortForwardingEventListenerManager(PortForwardingEventListenerManager manager)
removePortForwardingEventListenerManager
in interface PortForwardingEventListenerManagerHolder
public Session getSession()
getSession
in interface SessionHolder<Session>
public final ConnectionService getConnectionService()
protected java.util.Collection<PortForwardingEventListener> getDefaultListeners()
public SshdSocketAddress startLocalPortForwarding(SshdSocketAddress local, SshdSocketAddress remote) throws java.io.IOException
PortForwardingManager
startLocalPortForwarding
in interface PortForwardingManager
local
- The local addressremote
- The remote addressSshdSocketAddress
java.io.IOException
- If failed to create the requested bindingpublic void stopLocalPortForwarding(SshdSocketAddress local) throws java.io.IOException
PortForwardingManager
stopLocalPortForwarding
in interface PortForwardingManager
local
- The local addressjava.io.IOException
- If failed to cancel the requested bindingprotected void unbindLocalForwarding(SshdSocketAddress local, SshdSocketAddress remote, java.net.InetSocketAddress bound) throws java.io.IOException
java.io.IOException
public SshdSocketAddress startRemotePortForwarding(SshdSocketAddress remote, SshdSocketAddress local) throws java.io.IOException
PortForwardingManager
Start forwarding tcpip from the given address on the server to the given address on the client.
The remote host name is the address to bind to on the server:startRemotePortForwarding
in interface PortForwardingManager
remote
- The remote addresslocal
- The local addressSshdSocketAddress
java.io.IOException
- If failed to create the requested bindingpublic void stopRemotePortForwarding(SshdSocketAddress remote) throws java.io.IOException
PortForwardingManager
stopRemotePortForwarding
in interface PortForwardingManager
remote
- The remote addressjava.io.IOException
- If failed to cancel the requested bindingprotected void signalTearingDownExplicitTunnel(SshdSocketAddress boundAddress, boolean localForwarding, SshdSocketAddress remote) throws java.io.IOException
java.io.IOException
protected void signalTearingDownExplicitTunnel(PortForwardingEventListener listener, SshdSocketAddress boundAddress, boolean localForwarding, SshdSocketAddress remoteAddress) throws java.io.IOException
java.io.IOException
protected void signalTornDownExplicitTunnel(SshdSocketAddress boundAddress, boolean localForwarding, SshdSocketAddress remoteAddress, java.lang.Throwable reason) throws java.io.IOException
java.io.IOException
protected void signalTornDownExplicitTunnel(PortForwardingEventListener listener, SshdSocketAddress boundAddress, boolean localForwarding, SshdSocketAddress remoteAddress, java.lang.Throwable reason) throws java.io.IOException
java.io.IOException
public SshdSocketAddress startDynamicPortForwarding(SshdSocketAddress local) throws java.io.IOException
PortForwardingManager
startDynamicPortForwarding
in interface PortForwardingManager
local
- The local addressSshdSocketAddress
java.io.IOException
- If failed to create the requested bindingprotected void signalEstablishedDynamicTunnel(SshdSocketAddress local, SshdSocketAddress boundAddress, java.lang.Throwable reason) throws java.io.IOException
java.io.IOException
protected void signalEstablishedDynamicTunnel(PortForwardingEventListener listener, SshdSocketAddress local, SshdSocketAddress boundAddress, java.lang.Throwable reason) throws java.io.IOException
java.io.IOException
protected void signalEstablishingDynamicTunnel(SshdSocketAddress local) throws java.io.IOException
java.io.IOException
protected void signalEstablishingDynamicTunnel(PortForwardingEventListener listener, SshdSocketAddress local) throws java.io.IOException
java.io.IOException
public void stopDynamicPortForwarding(SshdSocketAddress local) throws java.io.IOException
PortForwardingManager
stopDynamicPortForwarding
in interface PortForwardingManager
local
- The local addressjava.io.IOException
- If failed to cancel the requested bindingprotected void unbindDynamicForwarding(SshdSocketAddress local, SocksProxy proxy, java.net.InetSocketAddress bound) throws java.io.IOException
java.io.IOException
protected void signalTearingDownDynamicTunnel(SshdSocketAddress address) throws java.io.IOException
java.io.IOException
protected void signalTearingDownDynamicTunnel(PortForwardingEventListener listener, SshdSocketAddress address) throws java.io.IOException
java.io.IOException
protected void signalTornDownDynamicTunnel(SshdSocketAddress address, java.lang.Throwable reason) throws java.io.IOException
java.io.IOException
protected void signalTornDownDynamicTunnel(PortForwardingEventListener listener, SshdSocketAddress address, java.lang.Throwable reason) throws java.io.IOException
java.io.IOException
public SshdSocketAddress getForwardedPort(int remotePort)
getForwardedPort
in interface Forwarder
remotePort
- The remote portSshdSocketAddress
that the remote port is forwarded topublic SshdSocketAddress localPortForwardingRequested(SshdSocketAddress local) throws java.io.IOException
Forwarder
localPortForwardingRequested
in interface Forwarder
local
- The request addressSshdSocketAddress
- null
if not allowed to forwardjava.io.IOException
- If failed to handle requestpublic void localPortForwardingCancelled(SshdSocketAddress local) throws java.io.IOException
Forwarder
localPortForwardingCancelled
in interface Forwarder
local
- The local SshdSocketAddress
java.io.IOException
- If failed to handle requestprotected void signalEstablishingExplicitTunnel(SshdSocketAddress local, SshdSocketAddress remote, boolean localForwarding) throws java.io.IOException
java.io.IOException
protected void signalEstablishingExplicitTunnel(PortForwardingEventListener listener, SshdSocketAddress local, SshdSocketAddress remote, boolean localForwarding) throws java.io.IOException
java.io.IOException
protected void signalEstablishedExplicitTunnel(SshdSocketAddress local, SshdSocketAddress remote, boolean localForwarding, SshdSocketAddress boundAddress, java.lang.Throwable reason) throws java.io.IOException
java.io.IOException
protected void signalEstablishedExplicitTunnel(PortForwardingEventListener listener, SshdSocketAddress local, SshdSocketAddress remote, boolean localForwarding, SshdSocketAddress boundAddress, java.lang.Throwable reason) throws java.io.IOException
java.io.IOException
protected void invokePortEventListenerSignaller(Invoker<PortForwardingEventListener,java.lang.Void> invoker) throws java.lang.Throwable
java.lang.Throwable
protected void invokePortEventListenerSignallerListeners(java.util.Collection<? extends PortForwardingEventListener> listeners, Invoker<PortForwardingEventListener,java.lang.Void> invoker) throws java.lang.Throwable
java.lang.Throwable
protected void invokePortEventListenerSignallerHolders(java.util.Collection<? extends PortForwardingEventListenerManager> holders, Invoker<PortForwardingEventListener,java.lang.Void> invoker) throws java.lang.Throwable
java.lang.Throwable
protected Closeable getInnerCloseable()
getInnerCloseable
in class AbstractInnerCloseable
protected void preClose()
AbstractCloseable
preClose
in class AbstractCloseable
protected IoAcceptor createIoAcceptor(Factory<? extends IoHandler> handlerFactory)
protected IoAcceptor getLocalIoAcceptor()
protected IoAcceptor getDynamicIoAcceptor()
protected java.net.InetSocketAddress doBind(SshdSocketAddress address, IoAcceptor acceptor) throws java.io.IOException
address
- The request bind addressacceptor
- An IoAcceptor
to bind addressesInetSocketAddress
to which the binding occurredjava.io.IOException
- If failed to bindpublic java.lang.String toString()
toString
in class java.lang.Object
public java.util.List<SshdSocketAddress> getBoundLocalPortForwards(int port)
getBoundLocalPortForwards
in interface PortForwardingInformationProvider
port
- The port numberSshdSocketAddress
-es for the portisLocalPortForwardingStartedForPort
,
PortForwardingInformationProvider.getStartedLocalPortForwards()
public boolean isLocalPortForwardingStartedForPort(int port)
PortForwardingInformationProvider
isLocalPortForwardingStartedForPort
in interface PortForwardingInformationProvider
port
- The local porttrue
if local port forwarding is startedgetBoundLocalPortForwards
public java.util.List<java.util.Map.Entry<SshdSocketAddress,SshdSocketAddress>> getLocalForwardsBindings()
getLocalForwardsBindings
in interface PortForwardingInformationProvider
SshdSocketAddress
-espublic java.util.List<SshdSocketAddress> getStartedLocalPortForwards()
getStartedLocalPortForwards
in interface PortForwardingInformationProvider
List
snapshot of the currently started local port forward bindingspublic java.util.List<java.util.Map.Entry<java.lang.Integer,SshdSocketAddress>> getRemoteForwardsBindings()
getRemoteForwardsBindings
in interface PortForwardingInformationProvider
SshdSocketAddress
public SshdSocketAddress getBoundRemotePortForward(int port)
getBoundRemotePortForward
in interface PortForwardingInformationProvider
port
- The port numberSshdSocketAddress
for the port - null
if none boundisRemotePortForwardingStartedForPort
,
PortForwardingInformationProvider.getStartedRemotePortForwards()
public java.util.NavigableSet<java.lang.Integer> getStartedRemotePortForwards()
getStartedRemotePortForwards
in interface PortForwardingInformationProvider
NavigableSet
snapshot of the currently started remote port forwards