class org.apache.qpid.proton.engine.impl.TransportSession extends java.lang.Object
{
private static final int HANDLE_MAX;
private static final org.apache.qpid.proton.amqp.UnsignedInteger DEFAULT_WINDOW_SIZE;
private final org.apache.qpid.proton.engine.impl.TransportImpl _transport;
private final org.apache.qpid.proton.engine.impl.SessionImpl _session;
private int _localChannel;
private int _remoteChannel;
private boolean _openSent;
private final org.apache.qpid.proton.amqp.UnsignedInteger _handleMax;
private org.apache.qpid.proton.amqp.UnsignedInteger _outgoingDeliveryId;
private org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindowSize;
private org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindowSize;
private org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId;
private org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId;
private final java.util.Map _remoteHandlesMap;
private final java.util.Map _localHandlesMap;
private final java.util.Map _halfOpenSenderLinks;
private final java.util.Map _halfOpenReceiverLinks;
private org.apache.qpid.proton.amqp.UnsignedInteger _incomingDeliveryId;
private org.apache.qpid.proton.amqp.UnsignedInteger _remoteIncomingWindow;
private org.apache.qpid.proton.amqp.UnsignedInteger _remoteOutgoingWindow;
private org.apache.qpid.proton.amqp.UnsignedInteger _remoteNextIncomingId;
private org.apache.qpid.proton.amqp.UnsignedInteger _remoteNextOutgoingId;
private final java.util.Map _unsettledIncomingDeliveriesById;
private final java.util.Map _unsettledOutgoingDeliveriesById;
private int _unsettledIncomingSize;
private boolean _endReceived;
private boolean _beginSent;
void <init>(org.apache.qpid.proton.engine.impl.TransportImpl, org.apache.qpid.proton.engine.impl.SessionImpl)
{
org.apache.qpid.proton.engine.impl.TransportImpl v;
java.util.HashMap v, v, v, v, v, v;
long v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v, v, v;
int v, v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.SessionImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
v = (int) -1;
v.<org.apache.qpid.proton.engine.impl.TransportSession: int _localChannel> = v;
v = (int) -1;
v.<org.apache.qpid.proton.engine.impl.TransportSession: int _remoteChannel> = v;
v = (int) 65535;
v = staticinvoke <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger valueOf(int)>(v);
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _handleMax> = v;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ZERO>;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingDeliveryId> = v;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ZERO>;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindowSize> = v;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ZERO>;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindowSize> = v;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ONE>;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId> = v;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId> = null;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _remoteHandlesMap> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _localHandlesMap> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _halfOpenSenderLinks> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _halfOpenReceiverLinks> = v;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingDeliveryId> = null;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId>;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _remoteNextIncomingId> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _unsettledIncomingDeliveriesById> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _unsettledOutgoingDeliveriesById> = v;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.TransportImpl _transport> = v;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl _session> = v;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: long getOutgoingWindow()>();
v = staticinvoke <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger valueOf(long)>(v);
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindowSize> = v;
return;
}
void unbind()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void unsetLocalChannel()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void unsetRemoteChannel()>();
return;
}
public org.apache.qpid.proton.engine.impl.SessionImpl getSession()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl _session>;
return v;
}
public int getLocalChannel()
{
int v;
org.apache.qpid.proton.engine.impl.TransportSession v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: int _localChannel>;
return v;
}
public void setLocalChannel(int)
{
int v;
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: int;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean isLocalChannelSet()>();
if v != 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl _session>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void incref()>();
label:
v.<org.apache.qpid.proton.engine.impl.TransportSession: int _localChannel> = v;
return;
}
public int getRemoteChannel()
{
int v;
org.apache.qpid.proton.engine.impl.TransportSession v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: int _remoteChannel>;
return v;
}
public void setRemoteChannel(int)
{
int v;
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: int;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean isRemoteChannelSet()>();
if v != 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl _session>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void incref()>();
label:
v.<org.apache.qpid.proton.engine.impl.TransportSession: int _remoteChannel> = v;
return;
}
public boolean isOpenSent()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean _openSent>;
return v;
}
public void setOpenSent(boolean)
{
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: boolean;
v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean _openSent> = v;
return;
}
public boolean isRemoteChannelSet()
{
int v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: int _remoteChannel>;
v = (int) -1;
if v == v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public boolean isLocalChannelSet()
{
int v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: int _localChannel>;
v = (int) -1;
if v == v goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public void unsetLocalChannel()
{
int v;
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean isLocalChannelSet()>();
if v == 0 goto label;
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void unsetLocalHandles()>();
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl _session>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void decref()>();
label:
v = (int) -1;
v.<org.apache.qpid.proton.engine.impl.TransportSession: int _localChannel> = v;
return;
}
private void unsetLocalHandles()
{
java.util.Iterator v;
java.util.Collection v;
java.util.Map v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
java.lang.Object v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _localHandlesMap>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: 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.TransportLink: void clearLocalHandle()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _localHandlesMap>;
interfaceinvoke v.<java.util.Map: void clear()>();
return;
}
public void unsetRemoteChannel()
{
int v;
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean isRemoteChannelSet()>();
if v == 0 goto label;
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void unsetRemoteHandles()>();
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl _session>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void decref()>();
label:
v = (int) -1;
v.<org.apache.qpid.proton.engine.impl.TransportSession: int _remoteChannel> = v;
return;
}
private void unsetRemoteHandles()
{
java.util.Iterator v;
java.util.Collection v;
java.util.Map v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
java.lang.Object v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _remoteHandlesMap>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: 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.TransportLink: void clearRemoteHandle()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _remoteHandlesMap>;
interfaceinvoke v.<java.util.Map: void clear()>();
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getHandleMax()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _handleMax>;
return v;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getIncomingWindowSize()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindowSize>;
return v;
}
void updateIncomingWindow()
{
org.apache.qpid.proton.engine.impl.TransportImpl v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v;
int v, v, v, v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.SessionImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl _session>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: int getIncomingCapacity()>();
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.TransportImpl _transport>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportImpl: int getMaxFrameSize()>();
if v <= 0 goto label;
if v > 0 goto label;
label:
v = <org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger DEFAULT_WINDOW_SIZE>;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindowSize> = v;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl _session>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: int getIncomingBytes()>();
v = v - v;
v = v / v;
v = staticinvoke <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger valueOf(int)>(v);
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindowSize> = v;
label:
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getOutgoingDeliveryId()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingDeliveryId>;
return v;
}
void incrementOutgoingDeliveryId()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingDeliveryId>;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ONE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger add(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingDeliveryId> = v;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getOutgoingWindowSize()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _outgoingWindowSize>;
return v;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getNextOutgoingId()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId>;
return v;
}
public org.apache.qpid.proton.engine.impl.TransportLink getLinkFromRemoteHandle(org.apache.qpid.proton.amqp.UnsignedInteger)
{
java.util.Map v;
org.apache.qpid.proton.engine.impl.TransportSession v;
java.lang.Object v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _remoteHandlesMap>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
return v;
}
public org.apache.qpid.proton.amqp.UnsignedInteger allocateLocalHandle(org.apache.qpid.proton.engine.impl.TransportLink)
{
java.lang.IllegalStateException v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
java.util.Map v, v;
int v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportLink;
v = 0;
label:
v = (int) 65535;
if v > v goto label;
v = staticinvoke <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger valueOf(int)>(v);
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _localHandlesMap>;
v = interfaceinvoke v.<java.util.Map: boolean containsKey(java.lang.Object)>(v);
if v != 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _localHandlesMap>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: void setLocalHandle(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
return v;
label:
v = v + 1;
goto label;
label:
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("no local handle available for allocation");
throw v;
}
public void addLinkRemoteHandle(org.apache.qpid.proton.engine.impl.TransportLink, org.apache.qpid.proton.amqp.UnsignedInteger)
{
java.util.Map v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _remoteHandlesMap>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void addLinkLocalHandle(org.apache.qpid.proton.engine.impl.TransportLink, org.apache.qpid.proton.amqp.UnsignedInteger)
{
java.util.Map v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _localHandlesMap>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public void freeLocalHandle(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
java.util.Map v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _localHandlesMap>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
return;
}
public void freeRemoteHandle(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
java.util.Map v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _remoteHandlesMap>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
return;
}
public org.apache.qpid.proton.engine.impl.TransportLink resolveHalfOpenLink(java.lang.String, boolean)
{
java.util.Map v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
java.lang.Object v, v;
java.lang.String v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: java.lang.String;
v := @parameter: boolean;
if v == 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _halfOpenSenderLinks>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
return v;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _halfOpenReceiverLinks>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
return v;
}
public void addHalfOpenLink(org.apache.qpid.proton.engine.impl.TransportLink, boolean)
{
java.util.Map v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.TransportLink v;
java.lang.String v, v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: boolean;
if v == 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _halfOpenSenderLinks>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: java.lang.String getName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _halfOpenReceiverLinks>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: java.lang.String getName()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return;
}
public void handleTransfer(org.apache.qpid.proton.amqp.transport.Transfer, org.apache.qpid.proton.amqp.Binary)
{
byte[] v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.engine.impl.TransportDelivery v, v;
java.util.Map v, v;
org.apache.qpid.proton.amqp.transport.DeliveryState v, v;
org.apache.qpid.proton.amqp.Binary v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v, v, v, v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v, v, v;
org.apache.qpid.proton.engine.impl.LinkImpl v, v, v;
org.apache.qpid.proton.engine.impl.ReceiverImpl v;
int v, v, v, v, v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
java.lang.Boolean v, v;
org.apache.qpid.proton.engine.impl.TransportLink v, v, v;
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.amqp.transport.Transfer v;
java.lang.Object v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.transport.Transfer;
v := @parameter: org.apache.qpid.proton.amqp.Binary;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void incrementNextIncomingId()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Transfer: org.apache.qpid.proton.amqp.UnsignedInteger getHandle()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.TransportLink getLinkFromRemoteHandle(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportReceiver: org.apache.qpid.proton.amqp.UnsignedInteger getIncomingDeliveryId()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Transfer: org.apache.qpid.proton.amqp.UnsignedInteger getDeliveryId()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
if v != null goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _unsettledIncomingDeliveriesById>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.TransportDelivery getTransportDelivery()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportDelivery: void incrementSessionSize()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingDeliveryId>;
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void verifyNewDeliveryIdSequence(org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger)>(v, v, v);
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingDeliveryId> = v;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportReceiver: org.apache.qpid.proton.engine.impl.ReceiverImpl getReceiver()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Transfer: org.apache.qpid.proton.amqp.Binary getDeliveryTag()>();
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()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.ReceiverImpl: org.apache.qpid.proton.engine.impl.DeliveryImpl delivery(byte[],int,int)>(v, v, v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Transfer: org.apache.qpid.proton.amqp.UnsignedInteger getMessageFormat()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: int intValue()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setMessageFormat(int)>(v);
label:
v = new org.apache.qpid.proton.engine.impl.TransportDelivery;
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportDelivery: void <init>(org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.engine.impl.DeliveryImpl,org.apache.qpid.proton.engine.impl.TransportLink)>(v, v, v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setTransportDelivery(org.apache.qpid.proton.engine.impl.TransportDelivery)>(v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportReceiver: void setIncomingDeliveryId(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _unsettledIncomingDeliveriesById>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl getSession()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void incrementIncomingDeliveries(int)>(1);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Transfer: org.apache.qpid.proton.amqp.transport.DeliveryState getState()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Transfer: org.apache.qpid.proton.amqp.transport.DeliveryState getState()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setRemoteDeliveryState(org.apache.qpid.proton.amqp.transport.DeliveryState)>(v);
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: int _unsettledIncomingSize>;
v = v + 1;
v.<org.apache.qpid.proton.engine.impl.TransportSession: int _unsettledIncomingSize> = v;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Transfer: boolean getAborted()>();
if v == null goto label;
if v != 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void append(org.apache.qpid.proton.amqp.Binary)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl getSession()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.Binary: int getLength()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void incrementIncomingBytes(int)>(v);
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void updateWork()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Transfer: boolean getMore()>();
if v == 0 goto label;
if v == 0 goto label;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportReceiver: void setIncomingDeliveryId(org.apache.qpid.proton.amqp.UnsignedInteger)>(null);
if v == 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setAborted()>();
goto label;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setComplete()>();
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.TransportLink getTransportLink()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: void decrementLinkCredit()>();
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.TransportLink getTransportLink()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: void incrementDeliveryCount()>();
label:
v = <java.lang.Boolean: java.lang.Boolean TRUE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Transfer: java.lang.Boolean getSettled()>();
v = virtualinvoke v.<java.lang.Boolean: boolean equals(java.lang.Object)>(v);
if v != 0 goto label;
if v == 0 goto label;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setRemoteSettled(boolean)>(1);
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindowSize>;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ONE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger subtract(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindowSize> = v;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _incomingWindowSize>;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ZERO>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: void modified(boolean)>(0);
label:
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl getSession()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnection()>();
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type DELIVERY>;
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;
}
private void verifyNewDeliveryIdSequence(org.apache.qpid.proton.amqp.UnsignedInteger, org.apache.qpid.proton.amqp.UnsignedInteger, org.apache.qpid.proton.amqp.UnsignedInteger)
{
java.lang.IllegalStateException v, v, v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v;
int v, v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
java.lang.String v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
if v != null goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>("No delivery-id specified on first Transfer of new delivery");
throw v;
label:
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: int intValue()>();
v = v + 1;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: int intValue()>();
if v == v goto label;
v = new java.lang.IllegalStateException;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ONE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger add(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Expected delivery-id \u, got \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
if v == null goto label;
v = new java.lang.IllegalStateException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.qpid.proton.amqp.UnsignedInteger,org.apache.qpid.proton.amqp.UnsignedInteger)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Illegal multiplex of deliveries on same link with delivery-id \u and \u0001");
specialinvoke v.<java.lang.IllegalStateException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public void freeLocalChannel()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void unsetLocalChannel()>();
return;
}
public void freeRemoteChannel()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void unsetRemoteChannel()>();
return;
}
private void setRemoteIncomingWindow(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _remoteIncomingWindow> = v;
return;
}
void decrementRemoteIncomingWindow()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _remoteIncomingWindow>;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ONE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger subtract(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _remoteIncomingWindow> = v;
return;
}
private void setRemoteOutgoingWindow(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _remoteOutgoingWindow> = v;
return;
}
void handleFlow(org.apache.qpid.proton.amqp.transport.Flow)
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v, v, v, v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.transport.Flow;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger getNextIncomingId()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger getIncomingWindow()>();
if v == null goto label;
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void setRemoteNextIncomingId(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger add(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger subtract(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void setRemoteIncomingWindow(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
goto label;
label:
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void setRemoteIncomingWindow(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger getNextOutgoingId()>();
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void setRemoteNextOutgoingId(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger getOutgoingWindow()>();
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void setRemoteOutgoingWindow(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger getHandle()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger getHandle()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.TransportLink getLinkFromRemoteHandle(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: void handleFlow(org.apache.qpid.proton.amqp.transport.Flow)>(v);
label:
return;
}
private void setRemoteNextOutgoingId(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _remoteNextOutgoingId> = v;
return;
}
private void setRemoteNextIncomingId(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _remoteNextIncomingId> = v;
return;
}
void handleDisposition(org.apache.qpid.proton.amqp.transport.Disposition)
{
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v;
org.apache.qpid.proton.amqp.transport.Role v, v;
java.util.Map v, v;
int v;
org.apache.qpid.proton.engine.impl.TransportSession v;
java.lang.Boolean v, v;
org.apache.qpid.proton.amqp.transport.DeliveryState v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
boolean v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
org.apache.qpid.proton.amqp.transport.Disposition v;
org.apache.qpid.proton.engine.Event$Type v;
java.lang.Object v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.transport.Disposition;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Disposition: org.apache.qpid.proton.amqp.UnsignedInteger getFirst()>();
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Disposition: org.apache.qpid.proton.amqp.UnsignedInteger getLast()>();
if v != null goto label;
v = v;
goto label;
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Disposition: org.apache.qpid.proton.amqp.UnsignedInteger getLast()>();
label:
v = v;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Disposition: org.apache.qpid.proton.amqp.transport.Role getRole()>();
v = <org.apache.qpid.proton.amqp.transport.Role: org.apache.qpid.proton.amqp.transport.Role RECEIVER>;
if v != v goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _unsettledOutgoingDeliveriesById>;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _unsettledIncomingDeliveriesById>;
label:
v = v;
label:
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: int compareTo(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
if v > 0 goto label;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Disposition: org.apache.qpid.proton.amqp.transport.DeliveryState getState()>();
if v == null goto label;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Disposition: org.apache.qpid.proton.amqp.transport.DeliveryState getState()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setRemoteDeliveryState(org.apache.qpid.proton.amqp.transport.DeliveryState)>(v);
label:
v = <java.lang.Boolean: java.lang.Boolean TRUE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Disposition: boolean getSettled()>();
v = staticinvoke <java.lang.Boolean: java.lang.Boolean valueOf(boolean)>(v);
v = virtualinvoke v.<java.lang.Boolean: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void setRemoteSettled(boolean)>(1);
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.DeliveryImpl: void updateWork()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl getSession()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnection()>();
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type DELIVERY>;
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);
label:
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ONE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger add(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
goto label;
label:
return;
}
void addUnsettledOutgoing(org.apache.qpid.proton.amqp.UnsignedInteger, org.apache.qpid.proton.engine.impl.DeliveryImpl)
{
java.util.Map v;
org.apache.qpid.proton.engine.impl.DeliveryImpl v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _unsettledOutgoingDeliveriesById>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
return;
}
public boolean hasOutgoingCredit()
{
int v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _remoteIncomingWindow>;
if v != null goto label;
v = 0;
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _remoteIncomingWindow>;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ZERO>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: int compareTo(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
if v <= 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
void incrementOutgoingId()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId>;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ONE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger add(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextOutgoingId> = v;
return;
}
public void settled(org.apache.qpid.proton.engine.impl.TransportDelivery)
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v;
org.apache.qpid.proton.engine.impl.TransportDelivery v;
java.util.Map v, v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
boolean v;
org.apache.qpid.proton.engine.impl.SessionImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportDelivery;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportDelivery: org.apache.qpid.proton.engine.impl.TransportLink getTransportLink()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = v instanceof org.apache.qpid.proton.engine.impl.ReceiverImpl;
if v == 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _unsettledIncomingDeliveriesById>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportDelivery: org.apache.qpid.proton.amqp.UnsignedInteger getDeliveryId()>();
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl getSession()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void modified(boolean)>(0);
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: java.util.Map _unsettledOutgoingDeliveriesById>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportDelivery: org.apache.qpid.proton.amqp.UnsignedInteger getDeliveryId()>();
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.engine.impl.SessionImpl getSession()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void modified(boolean)>(0);
label:
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getNextIncomingId()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId>;
return v;
}
public void setNextIncomingId(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId> = v;
return;
}
public void incrementNextIncomingId()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId>;
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ONE>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger add(org.apache.qpid.proton.amqp.UnsignedInteger)>(v);
v.<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger _nextIncomingId> = v;
return;
}
public boolean endReceived()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean _endReceived>;
return v;
}
public void receivedEnd()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean _endReceived> = 1;
return;
}
public boolean beginSent()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v = v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean _beginSent>;
return v;
}
public void sentBegin()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
v := @this: org.apache.qpid.proton.engine.impl.TransportSession;
v.<org.apache.qpid.proton.engine.impl.TransportSession: boolean _beginSent> = 1;
return;
}
static void <clinit>()
{
org.apache.qpid.proton.amqp.UnsignedInteger v;
v = staticinvoke <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger valueOf(int)>(2147483647);
<org.apache.qpid.proton.engine.impl.TransportSession: org.apache.qpid.proton.amqp.UnsignedInteger DEFAULT_WINDOW_SIZE> = v;
return;
}
}