Package net.schmizz.sshj.sftp
Class RemoteFile.ReadAheadRemoteFileInputStream
java.lang.Object
java.io.InputStream
net.schmizz.sshj.sftp.RemoteFile.ReadAheadRemoteFileInputStream
- All Implemented Interfaces:
Closeable
,AutoCloseable
- Enclosing class:
RemoteFile
-
Nested Class Summary
Nested ClassesModifier and TypeClassDescriptionprivate class
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final byte[]
private long
private boolean
private int
private final int
private ByteArrayInputStream
private final long
private final Deque
<RemoteFile.ReadAheadRemoteFileInputStream.UnconfirmedRead> -
Constructor Summary
ConstructorsConstructorDescriptionReadAheadRemoteFileInputStream
(int maxUnconfirmedReads) ReadAheadRemoteFileInputStream
(int maxUnconfirmedReads, long fileOffset) ReadAheadRemoteFileInputStream
(int maxUnconfirmedReads, long fileOffset, long readAheadLimit) -
Method Summary
Modifier and TypeMethodDescriptionint
int
read()
int
read
(byte[] into, int off, int len) private boolean
retrieveUnconfirmedRead
(boolean blocking) Methods inherited from class java.io.InputStream
close, mark, markSupported, nullInputStream, read, readAllBytes, readNBytes, readNBytes, reset, skip, skipNBytes, transferTo
-
Field Details
-
b
private final byte[] b -
maxUnconfirmedReads
private final int maxUnconfirmedReads -
readAheadLimit
private final long readAheadLimit -
unconfirmedReads
-
currentOffset
private long currentOffset -
maxReadLength
private int maxReadLength -
eof
private boolean eof -
pending
-
-
Constructor Details
-
ReadAheadRemoteFileInputStream
public ReadAheadRemoteFileInputStream(int maxUnconfirmedReads) -
ReadAheadRemoteFileInputStream
public ReadAheadRemoteFileInputStream(int maxUnconfirmedReads, long fileOffset) - Parameters:
maxUnconfirmedReads
- Maximum number of unconfirmed requests to sendfileOffset
- Initial offset in file to read from
-
ReadAheadRemoteFileInputStream
public ReadAheadRemoteFileInputStream(int maxUnconfirmedReads, long fileOffset, long readAheadLimit) - Parameters:
maxUnconfirmedReads
- Maximum number of unconfirmed requests to sendfileOffset
- Initial offset in file to read fromreadAheadLimit
- Read ahead is disabled after this limit has been reached
-
-
Method Details
-
retrieveUnconfirmedRead
- Throws:
IOException
-
read
- Specified by:
read
in classInputStream
- Throws:
IOException
-
read
- Overrides:
read
in classInputStream
- Throws:
IOException
-
available
- Overrides:
available
in classInputStream
- Throws:
IOException
-