public class LocalForwardingChannel<T extends SshContext> extends SocketForwardingChannel<T> implements ClientConnector
Channel.QueuedData
Modifier and Type | Field and Description |
---|---|
static String |
LOCAL_TYPE |
static String |
REMOTE_TYPE |
key, selectorThread, socketChannel
hostToConnect, originatingHost, originatingPort, portToConnect
connection, localwindow, localWindowLock
Constructor and Description |
---|
LocalForwardingChannel(String channelType) |
LocalForwardingChannel(String channelType,
String addressToBind,
int portToBind,
SocketChannel socketChannel)
Constructs a forwarding channel of the type "forwarded-tcpip"
|
Modifier and Type | Method and Description |
---|---|
protected byte[] |
createChannel()
Create the forwarding channel.
|
boolean |
finishConnect(SelectionKey key)
Called when the forwarded socket has been connected.
|
void |
initialize(ProtocolEngine engine,
SshEngine daemon)
No initialization is necessary so this method does nothing.
|
protected void |
onChannelOpenConfirmation()
Called when the channel has been confirmed as open.
|
protected void |
onChannelOpenFailure()
Either nothing was listening on the clients end of the tunnel, or the
connection was rejected.
|
protected void |
onRegistrationComplete()
Called when the forwarded sockets selector has been registered with a
com,maverick.nio.SelectorThread . |
protected byte[] |
openChannel(byte[] requestdata)
Open a forwarding channel.
|
canClose, canClose, evaluateClosure, evaluateWindowSpace, getInterestedOps, onChannelClosed, onChannelClosing, onChannelData, onChannelFree, onChannelOpen, onChannelRequest, onExtendedData, onLocalEOF, onRemoteClose, onRemoteEOF, onWindowAdjust, processReadEvent, processWriteEvent, registrationCompleted, run, setSelectionKey, setThread, shutdownSocket
getHost, getOriginatingHost, getOriginatingPort, getPort
addEventListener, addInputListener, addOutputListener, clearIdleState, close, getChannelType, getConnection, getConnectionProtocol, getContext, getLocalId, getLocalPacket, getLocalWindow, getQueueSize, getRemoteId, getRemotePacket, getRemoteWindow, getSessionIdentifier, isClosed, isClosing, isEOF, isLocalEOF, isOpen, isRemoteEOF, processChannelRequestResponse, queueSize, registerExtendedData, resetIdleState, sendChannelData, sendChannelData, sendChannelData, sendChannelData, sendChannelDataAndBlock, sendChannelRequest, sendEOF, sendExtendedData, sendExtendedData, sendRequestResponse, sendWindowAdjust
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
registrationCompleted
public static final String LOCAL_TYPE
public static final String REMOTE_TYPE
public LocalForwardingChannel(String channelType)
public LocalForwardingChannel(String channelType, String addressToBind, int portToBind, SocketChannel socketChannel)
addressToBind
- StringportToBind
- intsocketChannel
- SocketChannelprotected byte[] createChannel() throws IOException
createChannel
in class SocketForwardingChannel<T extends SshContext>
IOException
protected byte[] openChannel(byte[] requestdata) throws WriteOperationRequest, ChannelOpenException
openChannel
in class SocketForwardingChannel<T extends SshContext>
requestdata
- byte[]WriteOperationRequest
ChannelOpenException
protected void onRegistrationComplete()
com,maverick.nio.SelectorThread
.onRegistrationComplete
in class SocketForwardingChannel<T extends SshContext>
public boolean finishConnect(SelectionKey key)
finishConnect
in interface ClientConnector
key
- SelectionKeyprotected void onChannelOpenConfirmation()
onChannelOpenConfirmation
in class SocketForwardingChannel<T extends SshContext>
protected void onChannelOpenFailure()
onChannelOpenFailure
in class Channel<T extends SshContext>
public void initialize(ProtocolEngine engine, SshEngine daemon)
SocketForwardingChannel
initialize
in interface SocketHandler
initialize
in class SocketForwardingChannel<T extends SshContext>
engine
- ProtocolEnginedaemon
- DaemonCopyright © 2016. All rights reserved.