public class SideBandInputStream
extends java.io.InputStream
Reading from this input stream obtains data from channel 1, which is typically the bulk data stream.
Channel 2 is transparently unpacked and "scraped" to update a progress monitor. The scraping is performed behind the scenes as part of any of the read methods offered by this stream.
Channel 3 results in an exception being thrown, as the remote side has issued an unrecoverable error.
SideBandOutputStream
Modifier and Type | Field and Description |
---|---|
private int |
available |
(package private) static int |
CH_DATA |
(package private) static int |
CH_ERROR |
(package private) static int |
CH_PROGRESS |
private int |
channel |
private java.lang.String |
currentTask |
private boolean |
eof |
private int |
lastCnt |
private java.io.Writer |
messages |
private ProgressMonitor |
monitor |
private java.io.OutputStream |
out |
private static java.util.regex.Pattern |
P_BOUNDED |
private static java.util.regex.Pattern |
P_UNBOUNDED |
private PacketLineIn |
pckIn |
private java.lang.String |
progressBuffer |
private java.io.InputStream |
rawIn |
Constructor and Description |
---|
SideBandInputStream(java.io.InputStream in,
ProgressMonitor progress,
java.io.Writer messageStream,
java.io.OutputStream outputStream) |
Modifier and Type | Method and Description |
---|---|
private void |
beginTask(int totalWorkUnits) |
private void |
doProgressLine(java.lang.String msg) |
private void |
needDataPacket() |
private void |
progress(java.lang.String pkt) |
int |
read() |
int |
read(byte[] b,
int off,
int len) |
private java.lang.String |
readString(int len) |
private static java.lang.String |
remote(java.lang.String msg) |
static final int CH_DATA
static final int CH_PROGRESS
static final int CH_ERROR
private static java.util.regex.Pattern P_UNBOUNDED
private static java.util.regex.Pattern P_BOUNDED
private final java.io.InputStream rawIn
private final PacketLineIn pckIn
private final ProgressMonitor monitor
private final java.io.Writer messages
private final java.io.OutputStream out
private java.lang.String progressBuffer
private java.lang.String currentTask
private int lastCnt
private boolean eof
private int channel
private int available
SideBandInputStream(java.io.InputStream in, ProgressMonitor progress, java.io.Writer messageStream, java.io.OutputStream outputStream)
public int read() throws java.io.IOException
read
in class java.io.InputStream
java.io.IOException
public int read(byte[] b, int off, int len) throws java.io.IOException
read
in class java.io.InputStream
java.io.IOException
private void needDataPacket() throws java.io.IOException
java.io.IOException
private void progress(java.lang.String pkt) throws java.io.IOException
java.io.IOException
private void doProgressLine(java.lang.String msg) throws java.io.IOException
java.io.IOException
private void beginTask(int totalWorkUnits)
private static java.lang.String remote(java.lang.String msg)
private java.lang.String readString(int len) throws java.io.IOException
java.io.IOException