Package com.hierynomus.smbj.transport.tcp.direct

Class DirectTcpPacketReader<D extends PacketData<?>>

java.lang.Object

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

com.hierynomus.smbj.transport.tcp.direct.DirectTcpPacketReader<D>

All Implemented Interfaces:

java.lang.Runnable

public class DirectTcpPacketReader<D extends PacketData<?>>
extends PacketReader<D>

Field Summary

Fields

Modifier and Type	Field	Description
private PacketFactory<D>	packetFactory

Fields inherited from class com.hierynomus.smbj.transport.PacketReader

in

Constructor Summary

Constructors

Constructor	Description
DirectTcpPacketReader(java.lang.String host, java.io.InputStream in, PacketFactory<D> packetFactory, PacketReceiver<D> handler)

Method Summary

Modifier and Type	Method	Description
protected D	doRead()	Read the actual SMB2 Packet from the InputStream
private void	readFully(byte[] buffer)
private D	readPacket(int packetLength)
private int	readTcpHeader()

Methods inherited from class com.hierynomus.smbj.transport.PacketReader

run, start, stop

Methods inherited from class java.lang.Object

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

Field Detail

packetFactory

private final PacketFactory<D extends PacketData<?>> packetFactory

Constructor Detail

DirectTcpPacketReader

public DirectTcpPacketReader(java.lang.String host,
                             java.io.InputStream in,
                             PacketFactory<D> packetFactory,
                             PacketReceiver<D> handler)

Method Detail

readPacket

private D readPacket(int packetLength)
              throws java.io.IOException,
                     Buffer.BufferException

Throws:

java.io.IOException

Buffer.BufferException

doRead

protected D doRead()
            throws TransportException

Description copied from class: PacketReader

Read the actual SMB2 Packet from the InputStream

Specified by:

doRead in class PacketReader<D extends PacketData<?>>

Returns:

the read SMB2Packet

Throws:

TransportException

readTcpHeader

private int readTcpHeader()
                   throws java.io.IOException,
                          Buffer.BufferException

Throws:

java.io.IOException

Buffer.BufferException

readFully

private void readFully(byte[] buffer)
                throws java.io.IOException

Throws:

java.io.IOException