public class org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord extends org.glassfish.grizzly.asyncqueue.AsyncQueueRecord
{
public static final int UNCOUNTABLE_RECORD_SPACE_VALUE;
private static final org.glassfish.grizzly.ThreadCache$CachedTypeIndex CACHE_IDX;
private long initialMessageSize;
private boolean isUncountable;
private java.lang.Object dstAddress;
private org.glassfish.grizzly.asyncqueue.PushBackHandler pushBackHandler;
private final org.glassfish.grizzly.asyncqueue.RecordWriteResult writeResult;
public static org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord create(org.glassfish.grizzly.Connection, org.glassfish.grizzly.asyncqueue.WritableMessage, org.glassfish.grizzly.CompletionHandler, java.lang.Object, org.glassfish.grizzly.asyncqueue.PushBackHandler, boolean)
{
org.glassfish.grizzly.asyncqueue.PushBackHandler v;
org.glassfish.grizzly.ThreadCache$CachedTypeIndex v;
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
java.lang.Object v, v;
org.glassfish.grizzly.asyncqueue.WritableMessage v;
boolean v;
org.glassfish.grizzly.CompletionHandler v;
v := @parameter: org.glassfish.grizzly.Connection;
v := @parameter: org.glassfish.grizzly.asyncqueue.WritableMessage;
v := @parameter: org.glassfish.grizzly.CompletionHandler;
v := @parameter: java.lang.Object;
v := @parameter: org.glassfish.grizzly.asyncqueue.PushBackHandler;
v := @parameter: boolean;
v = <org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.ThreadCache$CachedTypeIndex CACHE_IDX>;
v = staticinvoke <org.glassfish.grizzly.ThreadCache: java.lang.Object takeFromCache(org.glassfish.grizzly.ThreadCache$CachedTypeIndex)>(v);
if v == null goto label;
v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: boolean isRecycled> = 0;
virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: void set(org.glassfish.grizzly.Connection,org.glassfish.grizzly.asyncqueue.WritableMessage,org.glassfish.grizzly.CompletionHandler,java.lang.Object,org.glassfish.grizzly.asyncqueue.PushBackHandler,boolean)>(v, v, v, v, v, v);
return v;
label:
v = new org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
specialinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: void <init>(org.glassfish.grizzly.Connection,org.glassfish.grizzly.asyncqueue.WritableMessage,org.glassfish.grizzly.CompletionHandler,java.lang.Object,org.glassfish.grizzly.asyncqueue.PushBackHandler,boolean)>(v, v, v, v, v, v);
return v;
}
protected void <init>(org.glassfish.grizzly.Connection, org.glassfish.grizzly.asyncqueue.WritableMessage, org.glassfish.grizzly.CompletionHandler, java.lang.Object, org.glassfish.grizzly.asyncqueue.PushBackHandler, boolean)
{
org.glassfish.grizzly.asyncqueue.RecordWriteResult v;
org.glassfish.grizzly.asyncqueue.PushBackHandler v;
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
java.lang.Object v;
org.glassfish.grizzly.asyncqueue.WritableMessage v;
boolean v;
org.glassfish.grizzly.CompletionHandler v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v := @parameter: org.glassfish.grizzly.Connection;
v := @parameter: org.glassfish.grizzly.asyncqueue.WritableMessage;
v := @parameter: org.glassfish.grizzly.CompletionHandler;
v := @parameter: java.lang.Object;
v := @parameter: org.glassfish.grizzly.asyncqueue.PushBackHandler;
v := @parameter: boolean;
specialinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncQueueRecord: void <init>()>();
v = new org.glassfish.grizzly.asyncqueue.RecordWriteResult;
specialinvoke v.<org.glassfish.grizzly.asyncqueue.RecordWriteResult: void <init>()>();
v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.RecordWriteResult writeResult> = v;
virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: void set(org.glassfish.grizzly.Connection,org.glassfish.grizzly.asyncqueue.WritableMessage,org.glassfish.grizzly.CompletionHandler,java.lang.Object,org.glassfish.grizzly.asyncqueue.PushBackHandler,boolean)>(v, v, v, v, v, v);
return;
}
protected void set(org.glassfish.grizzly.Connection, org.glassfish.grizzly.asyncqueue.WritableMessage, org.glassfish.grizzly.CompletionHandler, java.lang.Object, org.glassfish.grizzly.asyncqueue.PushBackHandler, boolean)
{
org.glassfish.grizzly.asyncqueue.RecordWriteResult v;
org.glassfish.grizzly.asyncqueue.PushBackHandler v;
int v;
org.glassfish.grizzly.Connection v;
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
java.lang.Object v;
org.glassfish.grizzly.asyncqueue.WritableMessage v;
boolean v;
org.glassfish.grizzly.CompletionHandler v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v := @parameter: org.glassfish.grizzly.Connection;
v := @parameter: org.glassfish.grizzly.asyncqueue.WritableMessage;
v := @parameter: org.glassfish.grizzly.CompletionHandler;
v := @parameter: java.lang.Object;
v := @parameter: org.glassfish.grizzly.asyncqueue.PushBackHandler;
v := @parameter: boolean;
specialinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncQueueRecord: void set(org.glassfish.grizzly.Connection,java.lang.Object,org.glassfish.grizzly.CompletionHandler)>(v, v, v);
v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: java.lang.Object dstAddress> = v;
v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: boolean isUncountable> = v;
if v == null goto label;
v = interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.WritableMessage: int remaining()>();
goto label;
label:
v = 0L;
label:
v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: long initialMessageSize> = v;
v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.PushBackHandler pushBackHandler> = v;
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.RecordWriteResult writeResult>;
virtualinvoke v.<org.glassfish.grizzly.asyncqueue.RecordWriteResult: void set(org.glassfish.grizzly.Connection,java.lang.Object,java.lang.Object,long)>(v, v, v, 0L);
return;
}
public final java.lang.Object getDstAddress()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
java.lang.Object v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: void checkRecycled()>();
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: java.lang.Object dstAddress>;
return v;
}
public final org.glassfish.grizzly.asyncqueue.WritableMessage getWritableMessage()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
java.lang.Object v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: java.lang.Object message>;
return v;
}
public boolean isUncountable()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
boolean v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: boolean isUncountable>;
return v;
}
public void setUncountable(boolean)
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
boolean v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v := @parameter: boolean;
v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: boolean isUncountable> = v;
return;
}
public long getBytesToReserve()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
long v;
boolean v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: boolean isUncountable>;
if v == 0 goto label;
v = 1L;
goto label;
label:
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: long initialMessageSize>;
label:
return v;
}
public long getInitialMessageSize()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
long v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: long initialMessageSize>;
return v;
}
public long remaining()
{
int v;
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
org.glassfish.grizzly.asyncqueue.WritableMessage v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.WritableMessage getWritableMessage()>();
v = interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.WritableMessage: int remaining()>();
return v;
}
public org.glassfish.grizzly.asyncqueue.RecordWriteResult getCurrentResult()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
org.glassfish.grizzly.asyncqueue.RecordWriteResult v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.RecordWriteResult writeResult>;
return v;
}
public org.glassfish.grizzly.asyncqueue.PushBackHandler getPushBackHandler()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
org.glassfish.grizzly.asyncqueue.PushBackHandler v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.PushBackHandler pushBackHandler>;
return v;
}
public boolean canBeAggregated()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
org.glassfish.grizzly.asyncqueue.WritableMessage v;
boolean v, v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.WritableMessage getWritableMessage()>();
v = interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.WritableMessage: boolean isExternal()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void notifyCompleteAndRecycle()
{
org.glassfish.grizzly.asyncqueue.RecordWriteResult v;
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
org.glassfish.grizzly.asyncqueue.WritableMessage v;
org.glassfish.grizzly.CompletionHandler v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.CompletionHandler completionHandler>;
v = virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.WritableMessage getWritableMessage()>();
if v == null goto label;
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.RecordWriteResult writeResult>;
interfaceinvoke v.<org.glassfish.grizzly.CompletionHandler: void completed(java.lang.Object)>(v);
label:
virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: void recycle()>();
interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.WritableMessage: boolean release()>();
return;
}
public boolean isFinished()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
org.glassfish.grizzly.asyncqueue.WritableMessage v;
boolean v, v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
v = virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.WritableMessage getWritableMessage()>();
v = interfaceinvoke v.<org.glassfish.grizzly.asyncqueue.WritableMessage: boolean hasRemaining()>();
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
protected final void reset()
{
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
org.glassfish.grizzly.asyncqueue.RecordWriteResult v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: void set(org.glassfish.grizzly.Connection,org.glassfish.grizzly.asyncqueue.WritableMessage,org.glassfish.grizzly.CompletionHandler,java.lang.Object,org.glassfish.grizzly.asyncqueue.PushBackHandler,boolean)>(null, null, null, null, null, 0);
v = v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.asyncqueue.RecordWriteResult writeResult>;
virtualinvoke v.<org.glassfish.grizzly.asyncqueue.RecordWriteResult: void recycle()>();
return;
}
public void recycle()
{
org.glassfish.grizzly.utils.DebugPoint v;
java.lang.Thread v;
org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord v;
org.glassfish.grizzly.ThreadCache$CachedTypeIndex v;
java.lang.String v;
java.lang.Exception v;
boolean v;
v := @this: org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord;
virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: void checkRecycled()>();
virtualinvoke v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: void reset()>();
v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: boolean isRecycled> = 1;
v = staticinvoke <org.glassfish.grizzly.Grizzly: boolean isTrackingThreadCache()>();
if v == 0 goto label;
v = new org.glassfish.grizzly.utils.DebugPoint;
v = new java.lang.Exception;
specialinvoke v.<java.lang.Exception: void <init>()>();
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.String getName()>();
specialinvoke v.<org.glassfish.grizzly.utils.DebugPoint: void <init>(java.lang.Exception,java.lang.String)>(v, v);
v.<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.utils.DebugPoint recycleTrack> = v;
label:
v = <org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.ThreadCache$CachedTypeIndex CACHE_IDX>;
staticinvoke <org.glassfish.grizzly.ThreadCache: boolean putToCache(org.glassfish.grizzly.ThreadCache$CachedTypeIndex,java.lang.Object)>(v, v);
return;
}
static void <clinit>()
{
int v;
org.glassfish.grizzly.ThreadCache$CachedTypeIndex v;
v = staticinvoke <org.glassfish.grizzly.Writer$Reentrant: int getMaxReentrants()>();
v = staticinvoke <org.glassfish.grizzly.ThreadCache: org.glassfish.grizzly.ThreadCache$CachedTypeIndex obtainIndex(java.lang.Class,int)>(class "Lorg/glassfish/grizzly/asyncqueue/AsyncWriteQueueRecord;", v);
<org.glassfish.grizzly.asyncqueue.AsyncWriteQueueRecord: org.glassfish.grizzly.ThreadCache$CachedTypeIndex CACHE_IDX> = v;
return;
}
}