Class AsyncPacketReader<D extends PacketData<?>>
java.lang.Object
com.hierynomus.smbj.transport.tcp.async.AsyncPacketReader<D>
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate final AsynchronousSocketChannel
private PacketReceiver
<D> private static final org.slf4j.Logger
private final PacketFactory
<D> private String
private int
private AtomicBoolean
-
Constructor Summary
ConstructorsConstructorDescriptionAsyncPacketReader
(AsynchronousSocketChannel channel, PacketFactory<D> packetFactory, PacketReceiver<D> handler) -
Method Summary
Modifier and TypeMethodDescriptionprivate void
private void
private void
initiateNextRead
(PacketBufferReader bufferReader) private boolean
private void
readAndHandlePacket
(byte[] packetBytes) void
void
stop()
-
Field Details
-
logger
private static final org.slf4j.Logger logger -
packetFactory
-
handler
-
channel
-
remoteHost
-
soTimeout
private int soTimeout -
stopped
-
-
Constructor Details
-
AsyncPacketReader
public AsyncPacketReader(AsynchronousSocketChannel channel, PacketFactory<D> packetFactory, PacketReceiver<D> handler)
-
-
Method Details
-
start
-
stop
public void stop() -
initiateNextRead
-
readAndHandlePacket
private void readAndHandlePacket(byte[] packetBytes) -
handleAsyncFailure
-
isChannelClosedByOtherParty
-
closeChannelQuietly
private void closeChannelQuietly()
-