Class ChannelToPortHandler

java.lang.Object

org.apache.sshd.common.util.logging.AbstractLoggingBean

org.apache.sshd.common.forward.ChannelToPortHandler

public class ChannelToPortHandler
extends AbstractLoggingBean

Implements forwarding messages received from a channel to a port in TCP/IP port forwarding.

Field Summary

Fields

Modifier and Type	Field	Description
private final Channel	channel
private final IoSession	port

Fields inherited from class AbstractLoggingBean

log

Constructor Summary

Constructors

Constructor	Description
ChannelToPortHandler(IoSession port, Channel channel)

Method Summary

Modifier and Type	Method	Description
private void	checkWindow(byte cmd, long len)
IoSession	getPortSession()	Retrieves the IoSession for the port connection.
void	handleEof()	Perform appropriate actions on the port session when the channel received an SSH_MSG_CHANNEL_EOF message.
protected void	handleWriteDataFailure(byte cmd, byte[] data, int off, int len, Throwable t)
protected void	handleWriteDataSuccess(byte cmd, byte[] data, int off, int len)
void	sendToPort(byte cmd, byte[] data, int off, long len)	Forwards data received on the SSH channel to the port and adjust the channel window once the data has been written.
IoWriteFuture	sendToPort(Buffer buffer)	Write data to the port directly without adjusting the channel window.

Methods inherited from class AbstractLoggingBean

debug, debug, debug, debug, debug, error, error, error, error, error, getSimplifiedLogger, info, info, warn, warn, warn, warn, warn, warn, warn, warn

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

port

private final IoSession port

channel

private final Channel channel

Constructor Details

ChannelToPortHandler

public ChannelToPortHandler(IoSession port,
 Channel channel)

Method Details

getPortSession

public IoSession getPortSession()

Retrieves the IoSession for the port connection.

Returns:

the IoSession, never null

handleEof

public void handleEof()
               throws IOException

Perform appropriate actions on the port session when the channel received an SSH_MSG_CHANNEL_EOF message.

Throws:

IOException

sendToPort

public IoWriteFuture sendToPort(Buffer buffer)
                         throws IOException

Write data to the port directly without adjusting the channel window.

Parameters:

buffer - data to write to the port

Returns:

an IoWriteFuture fulfilled once the data has been written

Throws:

IOException - if an error occurs

sendToPort

public void sendToPort(byte cmd,
 byte[] data,
 int off,
 long len)
                throws IOException

Forwards data received on the SSH channel to the port and adjust the channel window once the data has been written.

Parameters:

cmd - the SSH command, typically @link SshConstants#SSH_MSG_CHANNEL_DATA}, used for logging only

data - to forward

off - offset in data of the start of the data to forward

len - number of bytes to forward

Throws:

IOException - if an error occurs

handleWriteDataSuccess

protected void handleWriteDataSuccess(byte cmd,
 byte[] data,
 int off,
 int len)

handleWriteDataFailure

protected void handleWriteDataFailure(byte cmd,
 byte[] data,
 int off,
 int len,
 Throwable t)

checkWindow

private void checkWindow(byte cmd,
 long len)