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
All Methods Instance Methods Concrete Methods 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)
-
-
-
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 interfaceChannelHolder
- 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 interfacejava.nio.channels.Channel
-
write
public void write(int w) throws java.io.IOException
- Specified by:
write
in classjava.io.OutputStream
- Throws:
java.io.IOException
-
write
public void write(byte[] buf, int s, int l) throws java.io.IOException
- Overrides:
write
in classjava.io.OutputStream
- Throws:
java.io.IOException
-
flush
public void flush() throws java.io.IOException
- Specified by:
flush
in interfacejava.io.Flushable
- Overrides:
flush
in classjava.io.OutputStream
- Throws:
java.io.IOException
-
close
public void close() throws java.io.IOException
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfacejava.nio.channels.Channel
- Specified by:
close
in interfacejava.io.Closeable
- Overrides:
close
in classjava.io.OutputStream
- Throws:
java.io.IOException
-
newBuffer
protected void newBuffer(int size)
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-