Package org.apache.sshd.common.channel

Class ChannelOutputStream

java.lang.Object

java.io.OutputStream

org.apache.sshd.common.channel.ChannelOutputStream

All Implemented Interfaces:

Closeable, Flushable, AutoCloseable, Channel, ChannelHolder

public class ChannelOutputStream
extends OutputStream
implements Channel, ChannelHolder

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	b
private Buffer	buffer
private int	bufferLength
private final AbstractChannel	channelInstance
private final AtomicBoolean	closedState
private final byte	cmd
private final boolean	eofOnClose
private int	lastSize
protected final org.slf4j.Logger	log
private final Duration	maxWaitTimeout
private boolean	noDelay
private final ChannelStreamWriter	packetWriter
private final Window	remoteWindow

Constructor Summary

Constructors

Constructor	Description
ChannelOutputStream(AbstractChannel channel, Window remoteWindow, long maxWaitTimeout, org.slf4j.Logger log, byte cmd, boolean eofOnClose)
ChannelOutputStream(AbstractChannel channel, Window remoteWindow, Duration maxWaitTimeout, org.slf4j.Logger log, byte cmd, boolean eofOnClose)
ChannelOutputStream(AbstractChannel channel, Window remoteWindow, org.slf4j.Logger log, byte cmd, boolean eofOnClose)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
AbstractChannel	getChannel()
byte	getCommandType()
boolean	isEofOnClose()
boolean	isNoDelay()
boolean	isOpen()
protected void	newBuffer(int size)
void	setNoDelay(boolean noDelay)
String	toString()
void	write(byte[] buf, int s, int l)
void	write(int w)

Methods inherited from class java.io.OutputStream

nullOutputStream, write

Methods inherited from class java.lang.Object

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

Field Details

log

protected final org.slf4j.Logger log

channelInstance

private final AbstractChannel channelInstance

packetWriter

private final ChannelStreamWriter packetWriter

remoteWindow

private final Window remoteWindow

maxWaitTimeout

private final Duration maxWaitTimeout

cmd

private final byte cmd

eofOnClose

private final boolean eofOnClose

b

private final byte[] b

closedState

private final AtomicBoolean closedState

buffer

private Buffer buffer

bufferLength

private int bufferLength

lastSize

private int lastSize

noDelay

private boolean noDelay

Constructor Details

ChannelOutputStream

public ChannelOutputStream(AbstractChannel channel,
 Window remoteWindow,
 org.slf4j.Logger log,
 byte cmd,
 boolean eofOnClose)

ChannelOutputStream

public ChannelOutputStream(AbstractChannel channel,
 Window remoteWindow,
 long maxWaitTimeout,
 org.slf4j.Logger log,
 byte cmd,
 boolean eofOnClose)

ChannelOutputStream

public ChannelOutputStream(AbstractChannel channel,
 Window remoteWindow,
 Duration maxWaitTimeout,
 org.slf4j.Logger log,
 byte cmd,
 boolean eofOnClose)

Method Details

getChannel

public AbstractChannel getChannel()

Specified by:

getChannel in interface ChannelHolder

Returns:

The associated Channel instance

getCommandType

public byte getCommandType()

Returns:

Either SSH_MSG_CHANNEL_DATA or SSH_MSG_CHANNEL_EXTENDED_DATA indicating the output stream type

isEofOnClose

public boolean isEofOnClose()

isNoDelay

public boolean isNoDelay()

setNoDelay

public void setNoDelay(boolean noDelay)

isOpen

public boolean isOpen()

Specified by:

isOpen in interface Channel

write

public void write(int w)
           throws IOException

Specified by:

write in class OutputStream

Throws:

IOException

write

public void write(byte[] buf,
 int s,
 int l)
           throws IOException

Overrides:

write in class OutputStream

Throws:

IOException

flush

public void flush()
           throws IOException

Specified by:

flush in interface Flushable

Overrides:

flush in class OutputStream

Throws:

IOException

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Channel

Specified by:

close in interface Closeable

Overrides:

close in class OutputStream

Throws:

IOException

newBuffer

protected void newBuffer(int size)

toString

public String toString()

Overrides:

toString in class Object