Package net.schmizz.sshj.sftp
Class PacketReader
- java.lang.Object
-
- java.lang.Thread
-
- net.schmizz.sshj.sftp.PacketReader
-
- All Implemented Interfaces:
java.lang.Runnable
public class PacketReader extends java.lang.Thread
-
-
Field Summary
Fields Modifier and Type Field Description private SFTPEngine
engine
private java.io.InputStream
in
private byte[]
lenBuf
private org.slf4j.Logger
log
Loggerprivate SFTPPacket<Response>
packet
private java.util.Map<java.lang.Long,Promise<Response,SFTPException>>
promises
-
Constructor Summary
Constructors Constructor Description PacketReader(SFTPEngine engine)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Promise<Response,SFTPException>
expectResponseTo(long requestId)
private int
getPacketLength()
void
handle()
private void
readIntoBuffer(byte[] buf, int off, int len)
SFTPPacket<Response>
readPacket()
void
run()
-
Methods inherited from class java.lang.Thread
activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield
-
-
-
-
Field Detail
-
log
private final org.slf4j.Logger log
Logger
-
in
private final java.io.InputStream in
-
promises
private final java.util.Map<java.lang.Long,Promise<Response,SFTPException>> promises
-
packet
private final SFTPPacket<Response> packet
-
lenBuf
private final byte[] lenBuf
-
engine
private final SFTPEngine engine
-
-
Constructor Detail
-
PacketReader
public PacketReader(SFTPEngine engine)
-
-
Method Detail
-
readIntoBuffer
private void readIntoBuffer(byte[] buf, int off, int len) throws java.io.IOException
- Throws:
java.io.IOException
-
getPacketLength
private int getPacketLength() throws java.io.IOException
- Throws:
java.io.IOException
-
readPacket
public SFTPPacket<Response> readPacket() throws java.io.IOException
- Throws:
java.io.IOException
-
run
public void run()
- Specified by:
run
in interfacejava.lang.Runnable
- Overrides:
run
in classjava.lang.Thread
-
handle
public void handle() throws SFTPException
- Throws:
SFTPException
-
expectResponseTo
public Promise<Response,SFTPException> expectResponseTo(long requestId)
-
-