org.glassfish.grizzly.nio.transport
Class TCPNIOAsyncQueueWriter

java.lang.Object
  org.glassfish.grizzly.AbstractWriter<SocketAddress>
      org.glassfish.grizzly.nio.AbstractNIOAsyncQueueWriter
          org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter

All Implemented Interfaces:

AsyncQueue, AsyncQueueWriter<SocketAddress>, Writer<SocketAddress>

public final class TCPNIOAsyncQueueWriter
extends AbstractNIOAsyncQueueWriter

The TCP transport AsyncQueueWriter implementation, based on the Java NIO

Author:

Alexey Stashok

Field Summary

Fields inherited from class org.glassfish.grizzly.nio.AbstractNIOAsyncQueueWriter

maxPendingBytes, maxWriteReenterants, transport

Constructor Summary

TCPNIOAsyncQueueWriter(NIOTransport transport)

Method Summary

protected AsyncWriteQueueRecord	createRecord(Connection connection, Buffer message, Future<WriteResult<Buffer,SocketAddress>> future, WriteResult<Buffer,SocketAddress> currentResult, CompletionHandler<WriteResult<Buffer,SocketAddress>> completionHandler, Interceptor<WriteResult<Buffer,SocketAddress>> interceptor, SocketAddress dstAddress, Buffer outputBuffer, boolean isCloned, boolean isEmptyRecord)
protected void	onReadyToWrite(Connection connection)
protected int	write0(NIOConnection connection, AsyncWriteQueueRecord queueRecord)

Methods inherited from class org.glassfish.grizzly.nio.AbstractNIOAsyncQueueWriter

canWrite, close, failWriteRecord, getMaxPendingBytesPerConnection, getMaxWriteReenterants, isReady, onClose, onWriteComplete, onWriteFailure, onWriteIncomplete, processAsync, setMaxPendingBytesPerConnection, setMaxWriteReenterants, write, write

Methods inherited from class org.glassfish.grizzly.AbstractWriter

write, write, write, write

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.glassfish.grizzly.Writer

write, write, write, write

Constructor Detail

TCPNIOAsyncQueueWriter

public TCPNIOAsyncQueueWriter(NIOTransport transport)

Method Detail

createRecord

protected AsyncWriteQueueRecord createRecord(Connection connection,
                                             Buffer message,
                                             Future<WriteResult<Buffer,SocketAddress>> future,
                                             WriteResult<Buffer,SocketAddress> currentResult,
                                             CompletionHandler<WriteResult<Buffer,SocketAddress>> completionHandler,
                                             Interceptor<WriteResult<Buffer,SocketAddress>> interceptor,
                                             SocketAddress dstAddress,
                                             Buffer outputBuffer,
                                             boolean isCloned,
                                             boolean isEmptyRecord)

Overrides:

createRecord in class AbstractNIOAsyncQueueWriter

write0

protected int write0(NIOConnection connection,
                     AsyncWriteQueueRecord queueRecord)
              throws IOException

Specified by:

write0 in class AbstractNIOAsyncQueueWriter

Throws:

IOException

onReadyToWrite

protected final void onReadyToWrite(Connection connection)
                             throws IOException

Specified by:

onReadyToWrite in class AbstractNIOAsyncQueueWriter

Throws:

IOException