public class org.apache.qpid.proton.engine.impl.ConnectionImpl extends org.apache.qpid.proton.engine.impl.EndpointImpl implements org.apache.qpid.proton.engine.ProtonJConnection
{
public static final int MAX_CHANNELS;
private java.util.List _sessions;
private org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail;
private org.apache.qpid.proton.engine.impl.EndpointImpl _transportHead;
private int _maxChannels;
private org.apache.qpid.proton.engine.impl.LinkNode _sessionHead;
private org.apache.qpid.proton.engine.impl.LinkNode _sessionTail;
private org.apache.qpid.proton.engine.impl.LinkNode _linkHead;
private org.apache.qpid.proton.engine.impl.LinkNode _linkTail;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _workHead;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _workTail;
private org.apache.qpid.proton.engine.impl.TransportImpl _transport;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkHead;
private org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkTail;
private int _transportWorkSize;
private java.lang.String _localContainerId;
private java.lang.String _localHostname;
private java.lang.String _remoteContainer;
private java.lang.String _remoteHostname;
private org.apache.qpid.proton.amqp.Symbol[] _offeredCapabilities;
private org.apache.qpid.proton.amqp.Symbol[] _desiredCapabilities;
private org.apache.qpid.proton.amqp.Symbol[] _remoteOfferedCapabilities;
private org.apache.qpid.proton.amqp.Symbol[] _remoteDesiredCapabilities;
private java.util.Map _properties;
private java.util.Map _remoteProperties;
private java.lang.Object _context;
private org.apache.qpid.proton.engine.impl.CollectorImpl _collector;
private org.apache.qpid.proton.reactor.Reactor _reactor;
private static final org.apache.qpid.proton.amqp.Symbol[] EMPTY_SYMBOL_ARRAY;
public void <init>()
{
int v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
java.util.ArrayList v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void <init>()>();
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.List _sessions> = v;
v = (int) 65535;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: int _maxChannels> = v;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: int _transportWorkSize> = 0;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _localContainerId> = "";
return;
}
public org.apache.qpid.proton.engine.impl.SessionImpl session()
{
java.util.List v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = new org.apache.qpid.proton.engine.impl.SessionImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void <init>(org.apache.qpid.proton.engine.impl.ConnectionImpl)>(v);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.List _sessions>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return v;
}
void freeSession(org.apache.qpid.proton.engine.impl.SessionImpl)
{
java.util.List v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.List _sessions>;
interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
return;
}
protected org.apache.qpid.proton.engine.impl.LinkNode addSessionEndpoint(org.apache.qpid.proton.engine.impl.SessionImpl)
{
org.apache.qpid.proton.engine.impl.LinkNode v, v, v, v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionHead>;
if v != null goto label;
v = staticinvoke <org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode newList(java.lang.Object)>(v);
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionTail> = v;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionHead> = v;
v = v;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionTail>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode addAtTail(java.lang.Object)>(v);
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionTail> = v;
v = v;
label:
return v;
}
void removeSessionEndpoint(org.apache.qpid.proton.engine.impl.LinkNode)
{
org.apache.qpid.proton.engine.impl.LinkNode v, v, v, v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.LinkNode;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode getPrev()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode getNext()>();
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionHead>;
if v != v goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionHead> = v;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionTail>;
if v != v goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionTail> = v;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode remove()>();
return;
}
protected org.apache.qpid.proton.engine.impl.LinkNode addLinkEndpoint(org.apache.qpid.proton.engine.impl.LinkImpl)
{
org.apache.qpid.proton.engine.impl.LinkNode v, v, v, 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.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.LinkImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkHead>;
if v != null goto label;
v = staticinvoke <org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode newList(java.lang.Object)>(v);
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkTail> = v;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkHead> = v;
v = v;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkTail>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode addAtTail(java.lang.Object)>(v);
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkTail> = v;
v = v;
label:
return v;
}
void removeLinkEndpoint(org.apache.qpid.proton.engine.impl.LinkNode)
{
org.apache.qpid.proton.engine.impl.LinkNode v, v, v, v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.LinkNode;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode getPrev()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode getNext()>();
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkHead>;
if v != v goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkHead> = v;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkTail>;
if v != v goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkTail> = v;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode remove()>();
return;
}
public org.apache.qpid.proton.engine.Session sessionHead(java.util.EnumSet, java.util.EnumSet)
{
org.apache.qpid.proton.engine.impl.EndpointImplQuery v;
org.apache.qpid.proton.engine.impl.LinkNode v, v, v, v;
java.lang.Object v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
java.util.EnumSet v, v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.util.EnumSet;
v := @parameter: java.util.EnumSet;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionHead>;
if v != null goto label;
return null;
label:
v = new org.apache.qpid.proton.engine.impl.EndpointImplQuery;
specialinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImplQuery: void <init>(java.util.EnumSet,java.util.EnumSet)>(v, v);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionHead>;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode$Query: boolean matches(org.apache.qpid.proton.engine.impl.LinkNode)>(v);
if v == 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionHead>;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionHead>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode next(org.apache.qpid.proton.engine.impl.LinkNode$Query)>(v);
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: java.lang.Object getValue()>();
label:
return v;
}
public org.apache.qpid.proton.engine.Link linkHead(java.util.EnumSet, java.util.EnumSet)
{
org.apache.qpid.proton.engine.impl.EndpointImplQuery v;
org.apache.qpid.proton.engine.impl.LinkNode v, v, v, v;
java.lang.Object v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
java.util.EnumSet v, v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.util.EnumSet;
v := @parameter: java.util.EnumSet;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkHead>;
if v != null goto label;
return null;
label:
v = new org.apache.qpid.proton.engine.impl.EndpointImplQuery;
specialinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImplQuery: void <init>(java.util.EnumSet,java.util.EnumSet)>(v, v);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkHead>;
v = interfaceinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode$Query: boolean matches(org.apache.qpid.proton.engine.impl.LinkNode)>(v);
if v == 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkHead>;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkHead>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode next(org.apache.qpid.proton.engine.impl.LinkNode$Query)>(v);
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: java.lang.Object getValue()>();
label:
return v;
}
protected org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
return v;
}
void postFinal()
{
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type CONNECTION_FINAL>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EventImpl put(org.apache.qpid.proton.engine.Event$Type,java.lang.Object)>(v, v);
return;
}
void doFree()
{
java.util.List v;
java.util.Iterator v;
java.lang.Object v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v;
java.util.ArrayList v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = new java.util.ArrayList;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.List _sessions>;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<org.apache.qpid.proton.engine.Session: void free()>();
goto label;
label:
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.List _sessions> = null;
return;
}
void modifyEndpoints()
{
java.util.List v, v;
java.util.Iterator v;
java.lang.Object v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v, v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.List _sessions>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.List _sessions>;
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void modifyEndpoints()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: boolean freed>;
if v != 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void modified()>();
label:
return;
}
void handleOpen(org.apache.qpid.proton.amqp.transport.Open)
{
org.apache.qpid.proton.amqp.Symbol[] v, v;
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.engine.EndpointState v;
java.util.Map v;
java.lang.String v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.amqp.transport.Open v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.amqp.transport.Open;
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState ACTIVE>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void setRemoteState(org.apache.qpid.proton.engine.EndpointState)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Open: java.lang.String getHostname()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void setRemoteHostname(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Open: java.lang.String getContainerId()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void setRemoteContainer(java.lang.String)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Open: org.apache.qpid.proton.amqp.Symbol[] getDesiredCapabilities()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void setRemoteDesiredCapabilities(org.apache.qpid.proton.amqp.Symbol[])>(v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Open: org.apache.qpid.proton.amqp.Symbol[] getOfferedCapabilities()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void setRemoteOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[])>(v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Open: java.util.Map getProperties()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void setRemoteProperties(java.util.Map)>(v);
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type CONNECTION_REMOTE_OPEN>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EventImpl put(org.apache.qpid.proton.engine.Event$Type,java.lang.Object)>(v, v);
return;
}
org.apache.qpid.proton.engine.impl.EndpointImpl getTransportHead()
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportHead>;
return v;
}
org.apache.qpid.proton.engine.impl.EndpointImpl getTransportTail()
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail>;
return v;
}
void addModified(org.apache.qpid.proton.engine.impl.EndpointImpl)
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.EndpointImpl v, v, v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail>;
if v != null goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void setTransportNext(org.apache.qpid.proton.engine.impl.EndpointImpl)>(null);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void setTransportPrev(org.apache.qpid.proton.engine.impl.EndpointImpl)>(null);
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail> = v;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportHead> = v;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void setTransportNext(org.apache.qpid.proton.engine.impl.EndpointImpl)>(v);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void setTransportPrev(org.apache.qpid.proton.engine.impl.EndpointImpl)>(v);
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail> = v;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void setTransportNext(org.apache.qpid.proton.engine.impl.EndpointImpl)>(null);
label:
return;
}
void removeModified(org.apache.qpid.proton.engine.impl.EndpointImpl)
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.EndpointImpl v, v, v, v, v, v, v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportHead>;
if v != v goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl transportNext()>();
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportHead> = v;
goto label;
label:
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl transportPrev()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl transportNext()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void setTransportNext(org.apache.qpid.proton.engine.impl.EndpointImpl)>(v);
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail>;
if v != v goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl transportPrev()>();
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportTail> = v;
goto label;
label:
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl transportNext()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl transportPrev()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void setTransportPrev(org.apache.qpid.proton.engine.impl.EndpointImpl)>(v);
label:
return;
}
public int getMaxChannels()
{
int v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: int _maxChannels>;
return v;
}
public java.lang.String getLocalContainerId()
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _localContainerId>;
return v;
}
public void setLocalContainerId(java.lang.String)
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.lang.String;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _localContainerId> = v;
return;
}
public org.apache.qpid.proton.engine.impl.DeliveryImpl getWorkHead()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workHead>;
return v;
}
public void setContainer(java.lang.String)
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.lang.String;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _localContainerId> = v;
return;
}
public java.lang.String getContainer()
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _localContainerId>;
return v;
}
public void setHostname(java.lang.String)
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.lang.String;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _localHostname> = v;
return;
}
public java.lang.String getRemoteContainer()
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _remoteContainer>;
return v;
}
public java.lang.String getRemoteHostname()
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _remoteHostname>;
return v;
}
public void setOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[])
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.amqp.Symbol[];
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _offeredCapabilities> = v;
return;
}
public void setDesiredCapabilities(org.apache.qpid.proton.amqp.Symbol[])
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.amqp.Symbol[];
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _desiredCapabilities> = v;
return;
}
public org.apache.qpid.proton.amqp.Symbol[] getRemoteOfferedCapabilities()
{
org.apache.qpid.proton.amqp.Symbol[] v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteOfferedCapabilities>;
if v != null goto label;
v = <org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] EMPTY_SYMBOL_ARRAY>;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteOfferedCapabilities>;
label:
return v;
}
public org.apache.qpid.proton.amqp.Symbol[] getRemoteDesiredCapabilities()
{
org.apache.qpid.proton.amqp.Symbol[] v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteDesiredCapabilities>;
if v != null goto label;
v = <org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] EMPTY_SYMBOL_ARRAY>;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteDesiredCapabilities>;
label:
return v;
}
org.apache.qpid.proton.amqp.Symbol[] getOfferedCapabilities()
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _offeredCapabilities>;
return v;
}
org.apache.qpid.proton.amqp.Symbol[] getDesiredCapabilities()
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _desiredCapabilities>;
return v;
}
void setRemoteOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[])
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.amqp.Symbol[];
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteOfferedCapabilities> = v;
return;
}
void setRemoteDesiredCapabilities(org.apache.qpid.proton.amqp.Symbol[])
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.amqp.Symbol[];
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteDesiredCapabilities> = v;
return;
}
java.util.Map getProperties()
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
java.util.Map v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.Map _properties>;
return v;
}
public void setProperties(java.util.Map)
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
java.util.Map v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.util.Map;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.Map _properties> = v;
return;
}
public java.util.Map getRemoteProperties()
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
java.util.Map v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.Map _remoteProperties>;
return v;
}
void setRemoteProperties(java.util.Map)
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
java.util.Map v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.util.Map;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.util.Map _remoteProperties> = v;
return;
}
public java.lang.String getHostname()
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _localHostname>;
return v;
}
void setRemoteContainer(java.lang.String)
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.lang.String;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _remoteContainer> = v;
return;
}
void setRemoteHostname(java.lang.String)
{
java.lang.String v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.lang.String;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.String _remoteHostname> = v;
return;
}
org.apache.qpid.proton.engine.impl.DeliveryImpl getWorkTail()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workTail>;
return v;
}
void removeWork(org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v, v, v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _work>;
if v != 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl getWorkNext()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl getWorkPrev()>();
if v == null goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
label:
if v == null goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setWorkPrev(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(null);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setWorkPrev(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(null);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workHead>;
if v != v goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workHead> = v;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workTail>;
if v != v goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workTail> = v;
label:
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _work> = 0;
return;
}
void addWork(org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v, v, v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _work>;
if v == 0 goto label;
return;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(null);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workTail>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setWorkPrev(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workTail>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workTail>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
label:
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workTail> = v;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workHead>;
if v != null goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workHead> = v;
label:
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _work> = 1;
return;
}
public java.util.Iterator getWorkSequence()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl$WorkSequence v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = new org.apache.qpid.proton.engine.impl.ConnectionImpl$WorkSequence;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _workHead>;
specialinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl$WorkSequence: void <init>(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
return v;
}
void setTransport(org.apache.qpid.proton.engine.impl.TransportImpl)
{
org.apache.qpid.proton.engine.impl.TransportImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportImpl;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.TransportImpl _transport> = v;
return;
}
public org.apache.qpid.proton.engine.impl.TransportImpl getTransport()
{
org.apache.qpid.proton.engine.impl.TransportImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.TransportImpl _transport>;
return v;
}
org.apache.qpid.proton.engine.impl.DeliveryImpl getTransportWorkHead()
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkHead>;
return v;
}
int getTransportWorkSize()
{
int v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: int _transportWorkSize>;
return v;
}
public void removeTransportWork(org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
int v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v, v, v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _transportWork>;
if v != 0 goto label;
return;
label:
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl getTransportWorkNext()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl getTransportWorkPrev()>();
if v == null goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setTransportWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
label:
if v == null goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setTransportWorkPrev(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setTransportWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(null);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setTransportWorkPrev(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(null);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkHead>;
if v != v goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkHead> = v;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkTail>;
if v != v goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkTail> = v;
label:
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _transportWork> = 0;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: int _transportWorkSize>;
v = v - 1;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: int _transportWorkSize> = v;
return;
}
void addTransportWork(org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
int v, v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v, v, v, v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void modified()>();
v = v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _transportWork>;
if v == 0 goto label;
return;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setTransportWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(null);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkTail>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setTransportWorkPrev(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkTail>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkTail>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setTransportWorkNext(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
label:
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkTail> = v;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkHead>;
if v != null goto label;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl _transportWorkHead> = v;
label:
v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean _transportWork> = 1;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: int _transportWorkSize>;
v = v + 1;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: int _transportWorkSize> = v;
return;
}
void workUpdate(org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v, v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean isSettled()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean isReadable()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean isWritable()>();
if v != 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: boolean isUpdated()>();
if v == 0 goto label;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void addWork(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
goto label;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void removeWork(org.apache.qpid.proton.engine.impl.DeliveryImpl)>(v);
label:
return;
}
public java.lang.Object getContext()
{
java.lang.Object v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.Object _context>;
return v;
}
public void setContext(java.lang.Object)
{
java.lang.Object v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: java.lang.Object;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: java.lang.Object _context> = v;
return;
}
public void collect(org.apache.qpid.proton.engine.Collector)
{
org.apache.qpid.proton.engine.Event$Type v, v, v;
org.apache.qpid.proton.engine.Collector v;
org.apache.qpid.proton.engine.impl.LinkNode v, v;
java.lang.Object v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.Collector;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.CollectorImpl _collector> = v;
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type CONNECTION_INIT>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EventImpl put(org.apache.qpid.proton.engine.Event$Type,java.lang.Object)>(v, v);
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _sessionHead>;
label:
if v == null goto label;
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type SESSION_INIT>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: java.lang.Object getValue()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EventImpl put(org.apache.qpid.proton.engine.Event$Type,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode getNext()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode _linkHead>;
label:
if v == null goto label;
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type LINK_INIT>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: java.lang.Object getValue()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EventImpl put(org.apache.qpid.proton.engine.Event$Type,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkNode: org.apache.qpid.proton.engine.impl.LinkNode getNext()>();
goto label;
label:
return;
}
org.apache.qpid.proton.engine.impl.EventImpl put(org.apache.qpid.proton.engine.Event$Type, java.lang.Object)
{
org.apache.qpid.proton.engine.Event$Type v;
java.lang.Object v;
org.apache.qpid.proton.engine.impl.CollectorImpl v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.EventImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.engine.Event$Type;
v := @parameter: java.lang.Object;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.CollectorImpl _collector>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.CollectorImpl _collector>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.CollectorImpl: org.apache.qpid.proton.engine.impl.EventImpl put(org.apache.qpid.proton.engine.EventType,java.lang.Object)>(v, v);
return v;
label:
return null;
}
void localOpen()
{
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type CONNECTION_LOCAL_OPEN>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EventImpl put(org.apache.qpid.proton.engine.Event$Type,java.lang.Object)>(v, v);
return;
}
void localClose()
{
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type CONNECTION_LOCAL_CLOSE>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.EventImpl put(org.apache.qpid.proton.engine.Event$Type,java.lang.Object)>(v, v);
return;
}
public org.apache.qpid.proton.reactor.Reactor getReactor()
{
org.apache.qpid.proton.reactor.Reactor v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v = v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.reactor.Reactor _reactor>;
return v;
}
public void setReactor(org.apache.qpid.proton.reactor.Reactor)
{
org.apache.qpid.proton.reactor.Reactor v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.ConnectionImpl;
v := @parameter: org.apache.qpid.proton.reactor.Reactor;
v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.reactor.Reactor _reactor> = v;
return;
}
static void <clinit>()
{
org.apache.qpid.proton.amqp.Symbol[] v;
v = newarray (org.apache.qpid.proton.amqp.Symbol)[0];
<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.amqp.Symbol[] EMPTY_SYMBOL_ARRAY> = v;
return;
}
}