Top Description Fields Constructors Methods
org.glassfish.grizzly.asyncqueue

public Class AsyncWriteQueueRecord

extends AsyncQueueRecord<RecordWriteResult<K, L>>
Class Inheritance
Known Direct Subclasses
org.glassfish.grizzly.nio.transport.TCPNIOAsyncQueueWriter.CompositeQueueRecord
Annotations
@SuppressWarnings:deprecation
Imports
org.glassfish.grizzly.CompletionHandler, .Connection, .Grizzly, .ThreadCache, .WriteResult, .Writer, org.glassfish.grizzly.utils.DebugPoint
AsyncQueue write element unit
Author
Alexey Stashok

Field Summary

Modifier and TypeField and Description
private static final ThreadCache.CachedTypeIndex<AsyncWriteQueueRecord>
CACHE_IDX

private Object
dstAddress

private long
initialMessageSize

private boolean
isUncountable

private PushBackHandler
pushBackHandler

References Deprecated PushBackHandler is deprecated or references (maybe indirectly) at least one deprecated element.
public static final int
UNCOUNTABLE_RECORD_SPACE_VALUE

private final RecordWriteResult<K, L>
writeResult

Inherited from org.glassfish.grizzly.asyncqueue.AsyncQueueRecord:
completionHandlerconnectionisRecycledmessagerecycleTrack

Constructor Summary

AccessConstructor and Description
protected
AsyncWriteQueueRecord(final Connection<L> connection, final WritableMessage message, final CompletionHandler<E> completionHandler, final Object dstAddress, final PushBackHandler pushBackHandler, final boolean isUncountable)
References Deprecated PushBackHandler is deprecated or references (maybe indirectly) at least one deprecated element.

Method Summary

Modifier and TypeMethod and Description
public boolean
canBeAggregated()

public static AsyncWriteQueueRecord
create(final Connection<L> connection, final WritableMessage message, final CompletionHandler<E> completionHandler, final Object dstAddress, final PushBackHandler pushbackHandler, final boolean isUncountable)
References Deprecated PushBackHandler is deprecated or references (maybe indirectly) at least one deprecated element.

public long
getBytesToReserve()

public RecordWriteResult<K, L>
getCurrentResult()

Implements abstract org.glassfish.grizzly.asyncqueue.AsyncQueueRecord.getCurrentResult.

Returns the current record result object.

public final Object
getDstAddress()

public long
getInitialMessageSize()

public PushBackHandler
getPushBackHandler()
Deprecated

public final WritableMessage
getWritableMessage()

public boolean
isFinished()

public boolean
isUncountable()

Returns: true if record reserves in async write queue space, that is not related to message size remaining(), but is constant AsyncWriteQueueRecord#UNCOUNTABLE_RECORD_SPACE_VALUE.

public void
notifyCompleteAndRecycle()

public void
recycle()

Implements org.glassfish.grizzly.Cacheable.recycle.

public long
remaining()

protected final void
reset()

protected void
set(final Connection<L> connection, final WritableMessage message, final CompletionHandler<E> completionHandler, final Object dstAddress, final PushBackHandler pushBackHandler, final boolean isUncountable)
References Deprecated PushBackHandler is deprecated or references (maybe indirectly) at least one deprecated element.

public void
setUncountable(final boolean isUncountable)

Inherited from org.glassfish.grizzly.asyncqueue.AsyncQueueRecord:
checkRecycledgetConnectiongetMessagenotifyFailurenotifyIncompletesetsetMessage

Field Detail

CACHE_IDXback to summary
private static final ThreadCache.CachedTypeIndex<AsyncWriteQueueRecord> CACHE_IDX
dstAddressback to summary
private Object dstAddress
initialMessageSizeback to summary
private long initialMessageSize
isUncountableback to summary
private boolean isUncountable
pushBackHandlerback to summary
private PushBackHandler pushBackHandler

References Deprecated

PushBackHandler is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

UNCOUNTABLE_RECORD_SPACE_VALUEback to summary
public static final int UNCOUNTABLE_RECORD_SPACE_VALUE
writeResultback to summary
private final RecordWriteResult<K, L> writeResult

Constructor Detail

AsyncWriteQueueRecordback to summary
protected AsyncWriteQueueRecord(final Connection<L> connection, final WritableMessage message, final CompletionHandler<E> completionHandler, final Object dstAddress, final PushBackHandler pushBackHandler, final boolean isUncountable)

References Deprecated

PushBackHandler is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Method Detail

canBeAggregatedback to summary
public boolean canBeAggregated()
createback to summary
public static AsyncWriteQueueRecord create(final Connection<L> connection, final WritableMessage message, final CompletionHandler<E> completionHandler, final Object dstAddress, final PushBackHandler pushbackHandler, final boolean isUncountable)

References Deprecated

PushBackHandler is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

getBytesToReserveback to summary
public long getBytesToReserve()
getCurrentResultback to summary
public RecordWriteResult<K, L> getCurrentResult()

Implements abstract org.glassfish.grizzly.asyncqueue.AsyncQueueRecord.getCurrentResult.

Doc from org.glassfish.grizzly.asyncqueue.AsyncQueueRecord.getCurrentResult.

Returns the current record result object.

Annotations
@Override
getDstAddressback to summary
public final Object getDstAddress()
getInitialMessageSizeback to summary
public long getInitialMessageSize()
getPushBackHandlerback to summary
public PushBackHandler getPushBackHandler()

Deprecated

Annotations
@Deprecated
getWritableMessageback to summary
public final WritableMessage getWritableMessage()
isFinishedback to summary
public boolean isFinished()
isUncountableback to summary
public boolean isUncountable()
Returns:boolean

true if record reserves in async write queue space, that is not related to message size remaining(), but is constant AsyncWriteQueueRecord#UNCOUNTABLE_RECORD_SPACE_VALUE.

notifyCompleteAndRecycleback to summary
public void notifyCompleteAndRecycle()
Annotations
@SuppressWarnings:unchecked
recycleback to summary
public void recycle()

Implements org.glassfish.grizzly.Cacheable.recycle.

Annotations
@Override
remainingback to summary
public long remaining()
resetback to summary
protected final void reset()
setback to summary
protected void set(final Connection<L> connection, final WritableMessage message, final CompletionHandler<E> completionHandler, final Object dstAddress, final PushBackHandler pushBackHandler, final boolean isUncountable)

References Deprecated

PushBackHandler is deprecated or references (maybe indirectly) at least one deprecated element.

See corresponding docs for further information.

Annotations
@SuppressWarnings:unchecked
setUncountableback to summary
public void setUncountable(final boolean isUncountable)