Class AsyncDirectTcpTransport<D extends PacketData<?>, P extends Packet<?>>

java.lang.Object

com.hierynomus.smbj.transport.tcp.async.AsyncDirectTcpTransport<D,P>

All Implemented Interfaces:

TransportLayer<P>

public class AsyncDirectTcpTransport<D extends PacketData<?>, P extends Packet<?>>
extends Object
implements TransportLayer<P>

A transport layer over Direct TCP/IP that uses asynchronous I/O.

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicBoolean	connected
private static final int	DEFAULT_CONNECT_TIMEOUT
private static final int	DIRECT_HEADER_SIZE
private final PacketHandlers<D,P>	handlers
private final org.slf4j.Logger	logger
private final AsyncPacketReader<D>	packetReader
private final AsynchronousSocketChannel	socketChannel
private int	soTimeout
private final Queue<ByteBuffer>	writeQueue
private AtomicBoolean	writingNow

Constructor Summary

Constructors

Constructor	Description
AsyncDirectTcpTransport(int soTimeout, PacketHandlers<D,P> handlers, AsynchronousChannelGroup group)

Method Summary

Modifier and Type	Method	Description
void	connect(InetSocketAddress remoteAddress)	Connect to the remote side
void	disconnect()	Disconnect from the remote side
boolean	isConnected()	Checks if the transport layer is currently connected.
private ByteBuffer	prepareBufferToSend(P packet)
void	setSoTimeout(int soTimeout)
private void	startAsyncWrite()
void	write(P packet)	Write the packet to the transport.
private void	writeOrEnqueue(ByteBuffer buffer)

Methods inherited from class Object

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

Field Details

DEFAULT_CONNECT_TIMEOUT

private static final int DEFAULT_CONNECT_TIMEOUT

See Also:

• Constant Field Values

DIRECT_HEADER_SIZE

private static final int DIRECT_HEADER_SIZE

See Also:

• Constant Field Values

logger

private final org.slf4j.Logger logger

handlers

private final PacketHandlers<D extends PacketData<?>, P extends Packet<?>> handlers

socketChannel

private final AsynchronousSocketChannel socketChannel

packetReader

private final AsyncPacketReader<D extends PacketData<?>> packetReader

connected

private final AtomicBoolean connected

soTimeout

private int soTimeout

writeQueue

private final Queue<ByteBuffer> writeQueue

writingNow

private AtomicBoolean writingNow

Constructor Details

AsyncDirectTcpTransport

public AsyncDirectTcpTransport(int soTimeout,
 PacketHandlers<D,P> handlers,
 AsynchronousChannelGroup group)
                        throws IOException

Throws:

IOException

Method Details

write

public void write(P packet)
           throws TransportException

Description copied from interface: TransportLayer

Write the packet to the transport.

Specified by:

write in interface TransportLayer<D extends PacketData<?>>

Parameters:

packet - The packet to write.

Throws:

TransportException

writeOrEnqueue

private void writeOrEnqueue(ByteBuffer buffer)

connect

public void connect(InetSocketAddress remoteAddress)
             throws IOException

Description copied from interface: TransportLayer

Connect to the remote side

Specified by:

connect in interface TransportLayer<D extends PacketData<?>>

Parameters:

remoteAddress - The remote address to connect to

Throws:

IOException

disconnect

public void disconnect()
                throws IOException

Description copied from interface: TransportLayer

Disconnect from the remote side

Specified by:

disconnect in interface TransportLayer<D extends PacketData<?>>

Throws:

IOException

isConnected

public boolean isConnected()

Description copied from interface: TransportLayer

Checks if the transport layer is currently connected.

Specified by:

isConnected in interface TransportLayer<D extends PacketData<?>>

setSoTimeout

public void setSoTimeout(int soTimeout)

startAsyncWrite

private void startAsyncWrite()

prepareBufferToSend

private ByteBuffer prepareBufferToSend(P packet)