public class org.apache.qpid.proton.engine.impl.DeliveryImpl extends java.lang.Object implements org.apache.qpid.proton.engine.Delivery
{
public static final int DEFAULT_MESSAGE_FORMAT;
private static final org.apache.qpid.proton.codec.ReadableBuffer EMPTY_BUFFER;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _linkPrevious;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _linkNext;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _workNext;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _workPrev;
boolean _work;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkNext;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkPrev;
boolean _transportWork;
private org.apache.qpid.proton.engine.Record _attachments;
private java.lang.Object _context;
private final byte[] _tag;
private final org.apache.qpid.proton.engine.impl.LinkImpl _link;
private org.apache.qpid.proton.amqp.transport.DeliveryState _deliveryState;
private boolean _settled;
private boolean _remoteSettled;
private org.apache.qpid.proton.amqp.transport.DeliveryState _remoteDeliveryState;
private org.apache.qpid.proton.amqp.transport.DeliveryState _defaultDeliveryState;
private int _messageFormat;
private int _flags;
private org.apache.qpid.proton.engine.impl.TransportDelivery _transportDelivery;
private boolean _complete;
private boolean _updated;
private boolean _done;
private boolean _aborted;
private org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer;
private org.apache.qpid.proton.codec.ReadableBuffer _dataView;
void <init>(byte[], org.apache.qpid.proton.engine.impl.LinkImpl, org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
byte[] v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
org.apache.qpid.proton.engine.impl.LinkImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: byte[];
v := @parameter: org.apache.qpid.proton.engine.impl.LinkImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _defaultDeliveryState> = null;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: int _messageFormat> = 0;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: int _flags> = 0;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: byte[] _tag> = v;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl _link> = v;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: void incrementUnsettled()>();
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkPrevious> = v;
if v == null goto label;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkNext> = v;
label:
return;
}
public byte[] getTag()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
byte[] v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: byte[] _tag>;
return v;
}
public org.apache.qpid.proton.engine.impl.LinkImpl getLink()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
return v;
}
public org.apache.qpid.proton.amqp.transport.DeliveryState getLocalState()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.amqp.transport.DeliveryState v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _deliveryState>;
return v;
}
public org.apache.qpid.proton.amqp.transport.DeliveryState getRemoteState()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.amqp.transport.DeliveryState v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _remoteDeliveryState>;
return v;
}
public boolean remotelySettled()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _remoteSettled>;
return v;
}
public void setMessageFormat(int)
{
int v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: int;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: int _messageFormat> = v;
return;
}
public int getMessageFormat()
{
int v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: int _messageFormat>;
return v;
}
public void disposition(org.apache.qpid.proton.amqp.transport.DeliveryState)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.amqp.transport.DeliveryState v;
boolean v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.amqp.transport.DeliveryState;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _deliveryState> = v;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _remoteSettled>;
if v != 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _settled>;
if v != 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void addToTransportWorkList()>();
label:
return;
}
public void settle()
{
org.apache.qpid.proton.engine.impl.TransportDelivery v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v, v, v, v, v, v, v;
org.apache.qpid.proton.engine.impl.LinkImpl v, v, v, v;
boolean v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _settled>;
if v == 0 goto label;
return;
label:
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _settled> = 1;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: void decrementUnsettled()>();
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _remoteSettled>;
if v != 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void addToTransportWorkList()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.TransportDelivery _transportDelivery>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportDelivery: void settled()>();
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl current()>();
if v != v goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: boolean advance()>();
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: void remove(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkPrevious>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkPrevious>;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkNext>;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkNext> = v;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkNext>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkNext>;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkPrevious>;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkPrevious> = v;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void updateWork()>();
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkNext> = null;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkPrevious> = null;
return;
}
org.apache.qpid.proton.engine.impl.DeliveryImpl getLinkNext()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkNext>;
return v;
}
public org.apache.qpid.proton.engine.impl.DeliveryImpl next()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl getLinkNext()>();
return v;
}
public void free()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void settle()>();
return;
}
org.apache.qpid.proton.engine.impl.DeliveryImpl getLinkPrevious()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _linkPrevious>;
return v;
}
public org.apache.qpid.proton.engine.impl.DeliveryImpl getWorkNext()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v, v, v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workNext>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workNext>;
return v;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _work>;
if v != 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl getWorkHead()>();
return v;
label:
return null;
}
org.apache.qpid.proton.engine.impl.DeliveryImpl getWorkPrev()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workPrev>;
return v;
}
void setWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workNext> = v;
return;
}
void setWorkPrev(org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workPrev> = v;
return;
}
int recv(byte[], int, int)
{
byte[] v;
org.apache.qpid.proton.codec.CompositeReadableBuffer v, v, v, v, v;
int v, v, v, v, v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
v = virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: boolean hasRemaining()>();
if v == 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
v = virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: int remaining()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer get(byte[],int,int)>(v, v, v);
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer reclaimRead()>();
goto label;
label:
v = 0;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _complete>;
if v == 0 goto label;
if v != 0 goto label;
v = (int) -1;
v = v;
goto label;
label:
v = v;
label:
return v;
}
int recv(org.apache.qpid.proton.codec.WritableBuffer)
{
org.apache.qpid.proton.codec.CompositeReadableBuffer v, v, v, v, v;
int v, v, v, v, v;
org.apache.qpid.proton.codec.WritableBuffer v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.codec.WritableBuffer;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
v = virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: boolean hasRemaining()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.WritableBuffer: int remaining()>();
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
v = virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: int remaining()>();
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
interfaceinvoke v.<org.apache.qpid.proton.codec.WritableBuffer: void put(org.apache.qpid.proton.codec.ReadableBuffer)>(v);
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer reclaimRead()>();
goto label;
label:
v = 0;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _complete>;
if v == 0 goto label;
if v != 0 goto label;
v = (int) -1;
v = v;
goto label;
label:
v = v;
label:
return v;
}
org.apache.qpid.proton.codec.ReadableBuffer recv()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.codec.ReadableBuffer v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
if v == null goto label;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer> = null;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView> = null;
goto label;
label:
v = <org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer EMPTY_BUFFER>;
label:
return v;
}
void updateWork()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void workUpdate(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
return;
}
org.apache.qpid.proton.engine.impl.DeliveryImpl clearTransportWork()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkNext>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void removeTransportWork(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
return v;
}
void addToTransportWorkList()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void addTransportWork(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
return;
}
org.apache.qpid.proton.engine.impl.DeliveryImpl getTransportWorkNext()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkNext>;
return v;
}
org.apache.qpid.proton.engine.impl.DeliveryImpl getTransportWorkPrev()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkPrev>;
return v;
}
void setTransportWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkNext> = v;
return;
}
void setTransportWorkPrev(org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkPrev> = v;
return;
}
org.apache.qpid.proton.engine.impl.TransportDelivery getTransportDelivery()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.TransportDelivery v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.TransportDelivery _transportDelivery>;
return v;
}
void setTransportDelivery(org.apache.qpid.proton.engine.impl.TransportDelivery)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.TransportDelivery v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportDelivery;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.TransportDelivery _transportDelivery> = v;
return;
}
public boolean isSettled()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _settled>;
return v;
}
int send(byte[], int, int)
{
byte[] v, v;
org.apache.qpid.proton.codec.CompositeReadableBuffer v;
int v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: byte[];
v := @parameter: int;
v := @parameter: int;
v = newarray (byte)[v];
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, v, v, 0, v);
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer getOrCreateDataBuffer()>();
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer append(byte[])>(v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void addToTransportWorkList()>();
return v;
}
int send(org.apache.qpid.proton.codec.ReadableBuffer)
{
byte[] v;
org.apache.qpid.proton.codec.CompositeReadableBuffer v;
org.apache.qpid.proton.codec.ReadableBuffer v;
int v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.codec.ReadableBuffer;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int remaining()>();
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer getOrCreateDataBuffer()>();
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: byte[] copyContents(org.apache.qpid.proton.codec.ReadableBuffer)>(v);
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer append(byte[])>(v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void addToTransportWorkList()>();
return v;
}
int sendNoCopy(org.apache.qpid.proton.codec.ReadableBuffer)
{
org.apache.qpid.proton.codec.ReadableBuffer v, v, v;
int v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.codec.ReadableBuffer;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int remaining()>();
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
if v != 0 goto label;
label:
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView> = v;
goto label;
label:
specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void consolidateSendBuffers(org.apache.qpid.proton.codec.ReadableBuffer)>(v);
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void addToTransportWorkList()>();
return v;
}
private byte[] copyContents(org.apache.qpid.proton.codec.ReadableBuffer)
{
byte[] v, v;
org.apache.qpid.proton.codec.ReadableBuffer v;
int v, v, v, v, v, v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.codec.ReadableBuffer;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int remaining()>();
v = newarray (byte)[v];
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasArray()>();
if v == 0 goto label;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: byte[] array()>();
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int arrayOffset()>();
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int position()>();
v = v + v;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int remaining()>();
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, v, v, 0, v);
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int limit()>();
interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: org.apache.qpid.proton.codec.ReadableBuffer position(int)>(v);
goto label;
label:
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int remaining()>();
interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: org.apache.qpid.proton.codec.ReadableBuffer get(byte[],int,int)>(v, 0, v);
label:
return v;
}
private void consolidateSendBuffers(org.apache.qpid.proton.codec.ReadableBuffer)
{
byte[] v, v, v;
org.apache.qpid.proton.codec.CompositeReadableBuffer v, v, v;
org.apache.qpid.proton.codec.ReadableBuffer v, v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.codec.ReadableBuffer;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
if v != v goto label;
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer getOrCreateDataBuffer()>();
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: byte[] copyContents(org.apache.qpid.proton.codec.ReadableBuffer)>(v);
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer append(byte[])>(v);
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer getOrCreateDataBuffer()>();
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: byte[] copyContents(org.apache.qpid.proton.codec.ReadableBuffer)>(v);
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer append(byte[])>(v);
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: byte[] copyContents(org.apache.qpid.proton.codec.ReadableBuffer)>(v);
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer append(byte[])>(v);
interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: org.apache.qpid.proton.codec.ReadableBuffer reclaimRead()>();
label:
interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: org.apache.qpid.proton.codec.ReadableBuffer reclaimRead()>();
return;
}
void append(org.apache.qpid.proton.amqp.Binary)
{
byte[] v, v;
org.apache.qpid.proton.codec.CompositeReadableBuffer v;
int v, v, v, v, v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.amqp.Binary v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.amqp.Binary;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: byte[] getArray()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: int getArrayOffset()>();
if v > 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: int getLength()>();
v = lengthof v;
if v >= v goto label;
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: int getLength()>();
v = newarray (byte)[v];
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: byte[] getArray()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: int getArrayOffset()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: int getLength()>();
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, v, v, 0, v);
label:
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer getOrCreateDataBuffer()>();
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer append(byte[])>(v);
return;
}
private org.apache.qpid.proton.codec.CompositeReadableBuffer getOrCreateDataBuffer()
{
org.apache.qpid.proton.codec.CompositeReadableBuffer v, v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
if v != null goto label;
v = new org.apache.qpid.proton.codec.CompositeReadableBuffer;
specialinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer> = v;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView> = v;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
return v;
}
void append(byte[])
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
byte[] v;
org.apache.qpid.proton.codec.CompositeReadableBuffer v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: byte[];
v = specialinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer getOrCreateDataBuffer()>();
virtualinvoke v.<org.apache.qpid.proton.codec.CompositeReadableBuffer: org.apache.qpid.proton.codec.CompositeReadableBuffer append(byte[])>(v);
return;
}
void afterSend()
{
org.apache.qpid.proton.codec.CompositeReadableBuffer v;
org.apache.qpid.proton.codec.ReadableBuffer v, v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: org.apache.qpid.proton.codec.ReadableBuffer reclaimRead()>();
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
if v != 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.CompositeReadableBuffer _dataBuffer>;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView> = v;
label:
return;
}
org.apache.qpid.proton.codec.ReadableBuffer getData()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.codec.ReadableBuffer v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
if v != null goto label;
v = <org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer EMPTY_BUFFER>;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
label:
return v;
}
int getDataLength()
{
org.apache.qpid.proton.codec.ReadableBuffer v, v;
int v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int remaining()>();
label:
return v;
}
public int available()
{
org.apache.qpid.proton.codec.ReadableBuffer v, v;
int v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int remaining()>();
label:
return v;
}
public boolean isWritable()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
org.apache.qpid.proton.engine.impl.LinkImpl v, v, v;
boolean v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = v instanceof org.apache.qpid.proton.engine.impl.SenderImpl;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl current()>();
if v != v goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SenderImpl: boolean hasCredit()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isReadable()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v;
org.apache.qpid.proton.engine.impl.LinkImpl v, v;
boolean v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = v instanceof org.apache.qpid.proton.engine.impl.ReceiverImpl;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl current()>();
if v != v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
void setComplete()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _complete> = 1;
return;
}
void setAborted()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _aborted> = 1;
return;
}
public boolean isAborted()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _aborted>;
return v;
}
public boolean isPartial()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _complete>;
if v != 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
void setRemoteDeliveryState(org.apache.qpid.proton.amqp.transport.DeliveryState)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.amqp.transport.DeliveryState v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.amqp.transport.DeliveryState;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _remoteDeliveryState> = v;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _updated> = 1;
return;
}
public boolean isUpdated()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _updated>;
return v;
}
public void clear()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _updated> = 0;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void workUpdate(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
return;
}
void setDone()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _done> = 1;
return;
}
boolean isDone()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _done>;
return v;
}
void setRemoteSettled(boolean)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: boolean;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _remoteSettled> = v;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _updated> = 1;
return;
}
public boolean isBuffered()
{
org.apache.qpid.proton.codec.ReadableBuffer v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
boolean v, v, v, v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _remoteSettled>;
if v == 0 goto label;
return 0;
label:
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = v instanceof org.apache.qpid.proton.engine.impl.SenderImpl;
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean isDone()>();
if v == 0 goto label;
return 0;
label:
v = 0;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: boolean hasRemaining()>();
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _complete>;
if v != 0 goto label;
if v == 0 goto label;
label:
v = 1;
goto label;
label:
v = 0;
label:
return v;
label:
return 0;
}
public java.lang.Object getContext()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
java.lang.Object v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: java.lang.Object _context>;
return v;
}
public void setContext(java.lang.Object)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
java.lang.Object v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: java.lang.Object;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: java.lang.Object _context> = v;
return;
}
public org.apache.qpid.proton.engine.Record attachments()
{
org.apache.qpid.proton.engine.impl.RecordImpl v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.Record v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.Record _attachments>;
if v != null goto label;
v = new org.apache.qpid.proton.engine.impl.RecordImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.RecordImpl: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.Record _attachments> = v;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.Record _attachments>;
return v;
}
public java.lang.String toString()
{
byte[] v;
org.apache.qpid.proton.engine.impl.TransportDelivery v;
org.apache.qpid.proton.amqp.transport.DeliveryState v, v, v;
boolean v, v, v, v, v;
java.lang.StringBuilder v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
int v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
java.lang.String v, v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("DeliveryImpl [_tag=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: byte[] _tag>;
v = staticinvoke <java.util.Arrays: java.lang.String toString(byte[])>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _link=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _deliveryState=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _deliveryState>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _settled=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _settled>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(boolean)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _remoteSettled=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _remoteSettled>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(boolean)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _remoteDeliveryState=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _remoteDeliveryState>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _flags=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: int _flags>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _defaultDeliveryState=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _defaultDeliveryState>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _transportDelivery=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.TransportDelivery _transportDelivery>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _data Size=");
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: int getDataLength()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(int)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _complete=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _complete>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(boolean)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _updated=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _updated>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(boolean)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(", _done=");
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _done>;
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(boolean)>(v);
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>("]");
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public int pending()
{
org.apache.qpid.proton.codec.ReadableBuffer v, v;
int v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer _dataView>;
v = interfaceinvoke v.<org.apache.qpid.proton.codec.ReadableBuffer: int remaining()>();
label:
return v;
}
public void setDefaultDeliveryState(org.apache.qpid.proton.amqp.transport.DeliveryState)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.amqp.transport.DeliveryState v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v := @parameter: org.apache.qpid.proton.amqp.transport.DeliveryState;
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _defaultDeliveryState> = v;
return;
}
public org.apache.qpid.proton.amqp.transport.DeliveryState getDefaultDeliveryState()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.amqp.transport.DeliveryState v;
v := @this: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.amqp.transport.DeliveryState _defaultDeliveryState>;
return v;
}
static void <clinit>()
{
org.apache.qpid.proton.codec.ReadableBuffer$ByteBufferReader v;
v = staticinvoke <org.apache.qpid.proton.codec.ReadableBuffer$ByteBufferReader: org.apache.qpid.proton.codec.ReadableBuffer$ByteBufferReader allocate(int)>(0);
<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.codec.ReadableBuffer EMPTY_BUFFER> = v;
return;
}
}