Class PacketReader<D extends PacketData<?>>

java.lang.Object

com.hierynomus.smbj.transport.PacketReader<D>

All Implemented Interfaces:

Runnable

Direct Known Subclasses:

DirectTcpPacketReader

public abstract class PacketReader<D extends PacketData<?>>
extends Object
implements Runnable

Field Summary

Fields

Modifier and Type	Field	Description
private PacketReceiver<D>	handler
protected InputStream	in
private final org.slf4j.Logger	logger
private AtomicBoolean	stopped
private Thread	thread

Constructor Summary

Constructors

Constructor	Description
PacketReader(String host, InputStream in, PacketReceiver<D> handler)

Method Summary

Modifier and Type	Method	Description
protected abstract D	doRead()	Read the actual SMB2 Packet from the InputStream
private void	readPacket()
void	run()
void	start()
void	stop()

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

logger

private final org.slf4j.Logger logger

in

protected InputStream in

handler

private PacketReceiver<D extends PacketData<?>> handler

stopped

private AtomicBoolean stopped

thread

private Thread thread

Constructor Details

PacketReader

public PacketReader(String host,
 InputStream in,
 PacketReceiver<D> handler)

Method Details

run

public void run()

Specified by:

run in interface Runnable

stop

public void stop()

readPacket

private void readPacket()
                 throws TransportException

Throws:

TransportException

doRead

protected abstract D doRead()
                     throws TransportException

Read the actual SMB2 Packet from the InputStream

Returns:

the read SMB2Packet

Throws:

TransportException

start

public void start()