Package org.apache.sshd.common.channel

Class ChannelOutputStream

java.lang.Object

java.io.OutputStream

org.apache.sshd.common.channel.ChannelOutputStream

All Implemented Interfaces:

java.io.Closeable, java.io.Flushable, java.lang.AutoCloseable, java.nio.channels.Channel, ChannelHolder

public class ChannelOutputStream
extends java.io.OutputStream
implements java.nio.channels.Channel, ChannelHolder

Field Summary

Fields

Modifier and Type	Field	Description
private byte[]	b
private Buffer	buffer
private int	bufferLength
private AbstractChannel	channelInstance
private java.util.concurrent.atomic.AtomicBoolean	closedState
private byte	cmd
static long	DEFAULT_WAIT_FOR_SPACE_TIMEOUT
private boolean	eofOnClose
private int	lastSize
private org.slf4j.Logger	log
private long	maxWaitTimeout
private boolean	noDelay
private PacketWriter	packetWriter
private Window	remoteWindow
static java.lang.String	WAIT_FOR_SPACE_TIMEOUT	Configure max.

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, org.slf4j.Logger log, byte cmd, boolean eofOnClose)

Method Summary

Modifier and Type	Method	Description
void	close()
void	flush()
AbstractChannel	getChannel()
boolean	isEofOnClose()
boolean	isNoDelay()
boolean	isOpen()
protected void	newBuffer(int size)
void	setNoDelay(boolean noDelay)
java.lang.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 Detail

WAIT_FOR_SPACE_TIMEOUT

public static final java.lang.String WAIT_FOR_SPACE_TIMEOUT

Configure max. wait time (millis) to wait for space to become available

See Also:

Constant Field Values

DEFAULT_WAIT_FOR_SPACE_TIMEOUT

public static final long DEFAULT_WAIT_FOR_SPACE_TIMEOUT

channelInstance

private final AbstractChannel channelInstance

packetWriter

private final PacketWriter packetWriter

remoteWindow

private final Window remoteWindow

maxWaitTimeout

private final long maxWaitTimeout

log

private final org.slf4j.Logger log

cmd

private final byte cmd

eofOnClose

private final boolean eofOnClose

b

private final byte[] b

closedState

private final java.util.concurrent.atomic.AtomicBoolean closedState

buffer

private Buffer buffer

bufferLength

private int bufferLength

lastSize

private int lastSize

noDelay

private boolean noDelay

Constructor Detail

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)

Method Detail

getChannel

public AbstractChannel getChannel()

Specified by:

getChannel in interface ChannelHolder

Returns:

The associated Channel instance

isEofOnClose

public boolean isEofOnClose()

setNoDelay

public void setNoDelay(boolean noDelay)

isNoDelay

public boolean isNoDelay()

isOpen

public boolean isOpen()

Specified by:

isOpen in interface java.nio.channels.Channel

write

public void write(int w)
           throws java.io.IOException

Specified by:

write in class java.io.OutputStream

Throws:

java.io.IOException

write

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

Overrides:

write in class java.io.OutputStream

Throws:

java.io.IOException

flush

public void flush()
           throws java.io.IOException

Specified by:

flush in interface java.io.Flushable

Overrides:

flush in class java.io.OutputStream

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.nio.channels.Channel

Specified by:

close in interface java.io.Closeable

Overrides:

close in class java.io.OutputStream

Throws:

java.io.IOException

newBuffer

protected void newBuffer(int size)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object