public class org.apache.qpid.proton.engine.impl.SessionImpl extends org.apache.qpid.proton.engine.impl.EndpointImpl implements org.apache.qpid.proton.engine.ProtonJSession
{
private final org.apache.qpid.proton.engine.impl.ConnectionImpl _connection;
private java.util.Map _senders;
private java.util.Map _receivers;
private java.util.List _oldLinksToFree;
private org.apache.qpid.proton.engine.impl.TransportSession _transportSession;
private int _incomingCapacity;
private int _incomingBytes;
private int _outgoingBytes;
private int _incomingDeliveries;
private int _outgoingDeliveries;
private long _outgoingWindow;
private java.util.Map _properties;
private java.util.Map _remoteProperties;
private org.apache.qpid.proton.amqp.Symbol[] _offeredCapabilities;
private org.apache.qpid.proton.amqp.Symbol[] _remoteOfferedCapabilities;
private org.apache.qpid.proton.amqp.Symbol[] _desiredCapabilities;
private org.apache.qpid.proton.amqp.Symbol[] _remoteDesiredCapabilities;
private org.apache.qpid.proton.engine.impl.LinkNode _node;
void <init>(org.apache.qpid.proton.engine.impl.ConnectionImpl)
{
java.util.ArrayList v;
java.util.LinkedHashMap v, v;
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.engine.impl.LinkNode v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v, v, v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.ConnectionImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void <init>()>();
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _senders> = v;
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _receivers> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.List _oldLinksToFree> = v;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingCapacity> = 0;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingBytes> = 0;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _outgoingBytes> = 0;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingDeliveries> = 0;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _outgoingDeliveries> = 0;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: long _outgoingWindow> = 2147483647L;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl _connection> = v;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl _connection>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void incref()>();
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl _connection>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.LinkNode addSessionEndpoint(org.apache.qpid.proton.engine.impl.SessionImpl)>(v);
v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.LinkNode _node> = v;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl _connection>;
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type SESSION_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);
return;
}
public org.apache.qpid.proton.engine.impl.SenderImpl sender(java.lang.String)
{
java.util.List v;
org.apache.qpid.proton.engine.impl.SenderImpl v, v;
org.apache.qpid.proton.engine.EndpointState v, v, v, v;
java.util.Map v, v, v;
java.lang.Object v;
java.lang.String v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _senders>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.qpid.proton.engine.impl.SenderImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.SenderImpl: void <init>(org.apache.qpid.proton.engine.impl.SessionImpl,java.lang.String)>(v, v);
v = v;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _senders>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SenderImpl: org.apache.qpid.proton.engine.EndpointState getLocalState()>();
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState CLOSED>;
if v != v goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SenderImpl: org.apache.qpid.proton.engine.EndpointState getRemoteState()>();
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState CLOSED>;
if v != v goto label;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.List _oldLinksToFree>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = new org.apache.qpid.proton.engine.impl.SenderImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.SenderImpl: void <init>(org.apache.qpid.proton.engine.impl.SessionImpl,java.lang.String)>(v, v);
v = v;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _senders>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
}
public org.apache.qpid.proton.engine.impl.ReceiverImpl receiver(java.lang.String)
{
org.apache.qpid.proton.engine.impl.ReceiverImpl v, v;
java.util.List v;
org.apache.qpid.proton.engine.EndpointState v, v, v, v;
java.util.Map v, v, v;
java.lang.Object v;
java.lang.String v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _receivers>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new org.apache.qpid.proton.engine.impl.ReceiverImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.ReceiverImpl: void <init>(org.apache.qpid.proton.engine.impl.SessionImpl,java.lang.String)>(v, v);
v = v;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _receivers>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.ReceiverImpl: org.apache.qpid.proton.engine.EndpointState getLocalState()>();
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState CLOSED>;
if v != v goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.ReceiverImpl: org.apache.qpid.proton.engine.EndpointState getRemoteState()>();
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState CLOSED>;
if v != v goto label;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.List _oldLinksToFree>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = new org.apache.qpid.proton.engine.impl.ReceiverImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.ReceiverImpl: void <init>(org.apache.qpid.proton.engine.impl.SessionImpl,java.lang.String)>(v, v);
v = v;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _receivers>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
return v;
}
public org.apache.qpid.proton.engine.Session next(java.util.EnumSet, java.util.EnumSet)
{
org.apache.qpid.proton.engine.impl.EndpointImplQuery v;
org.apache.qpid.proton.engine.impl.LinkNode v, v;
java.lang.Object v;
java.util.EnumSet v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: java.util.EnumSet;
v := @parameter: java.util.EnumSet;
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.SessionImpl: org.apache.qpid.proton.engine.impl.LinkNode _node>;
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);
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;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl _connection>;
return v;
}
public org.apache.qpid.proton.engine.impl.ConnectionImpl getConnection()
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
return v;
}
void postFinal()
{
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl _connection>;
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type SESSION_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);
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl _connection>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void decref()>();
return;
}
void doFree()
{
java.util.ArrayList v, v, v;
java.util.Map v, v, v, v;
org.apache.qpid.proton.engine.impl.LinkNode v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v, v;
boolean v, v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
java.util.Iterator v, v, v;
java.util.Collection v, v;
java.util.List v;
java.lang.Object v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl _connection>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void freeSession(org.apache.qpid.proton.engine.impl.SessionImpl)>(v);
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl _connection>;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.LinkNode _node>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void removeSessionEndpoint(org.apache.qpid.proton.engine.impl.LinkNode)>(v);
v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.LinkNode _node> = null;
v = new java.util.ArrayList;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _senders>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
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()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SenderImpl: void free()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _senders>;
interfaceinvoke v.<java.util.Map: void clear()>();
v = new java.util.ArrayList;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _receivers>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
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()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ReceiverImpl: void free()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _receivers>;
interfaceinvoke v.<java.util.Map: void clear()>();
v = new java.util.ArrayList;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.List _oldLinksToFree>;
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()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: void free()>();
goto label;
label:
return;
}
void modifyEndpoints()
{
java.util.Iterator v, v;
java.util.Collection v, v;
java.util.Map v, v;
java.lang.Object v, v;
boolean v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _senders>;
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.SenderImpl: void modifyEndpoints()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _receivers>;
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.ReceiverImpl: void modifyEndpoints()>();
goto label;
label:
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: void modified()>();
return;
}
org.apache.qpid.proton.engine.impl.TransportSession getTransportSession()
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.TransportSession _transportSession>;
return v;
}
void setTransportSession(org.apache.qpid.proton.engine.impl.TransportSession)
{
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportSession;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.TransportSession _transportSession> = v;
return;
}
void setNode(org.apache.qpid.proton.engine.impl.LinkNode)
{
org.apache.qpid.proton.engine.impl.LinkNode v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.LinkNode;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.LinkNode _node> = v;
return;
}
void freeSender(org.apache.qpid.proton.engine.impl.SenderImpl)
{
java.util.List v;
org.apache.qpid.proton.engine.impl.SenderImpl v;
java.util.Map v, v;
java.lang.Object v;
java.lang.String v;
boolean v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.SenderImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SenderImpl: java.lang.String getName()>();
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _senders>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _senders>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.List _oldLinksToFree>;
interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
label:
return;
}
void freeReceiver(org.apache.qpid.proton.engine.impl.ReceiverImpl)
{
org.apache.qpid.proton.engine.impl.ReceiverImpl v;
java.util.List v;
java.util.Map v, v;
java.lang.Object v;
java.lang.String v;
boolean v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.ReceiverImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.ReceiverImpl: java.lang.String getName()>();
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _receivers>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.Object: boolean equals(java.lang.Object)>(v);
if v == 0 goto label;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _receivers>;
interfaceinvoke v.<java.util.Map: java.lang.Object remove(java.lang.Object)>(v);
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.List _oldLinksToFree>;
interfaceinvoke v.<java.util.List: boolean remove(java.lang.Object)>(v);
label:
return;
}
public int getIncomingCapacity()
{
int v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingCapacity>;
return v;
}
public void setIncomingCapacity(int)
{
int v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: int;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingCapacity> = v;
return;
}
public int getIncomingBytes()
{
int v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingBytes>;
return v;
}
void incrementIncomingBytes(int)
{
int v, v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: int;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingBytes>;
v = v + v;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingBytes> = v;
return;
}
public int getOutgoingBytes()
{
int v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _outgoingBytes>;
return v;
}
void incrementOutgoingBytes(int)
{
int v, v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: int;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _outgoingBytes>;
v = v + v;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _outgoingBytes> = v;
return;
}
void incrementIncomingDeliveries(int)
{
int v, v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: int;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingDeliveries>;
v = v + v;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _incomingDeliveries> = v;
return;
}
int getOutgoingDeliveries()
{
int v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _outgoingDeliveries>;
return v;
}
void incrementOutgoingDeliveries(int)
{
int v, v, v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: int;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _outgoingDeliveries>;
v = v + v;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: int _outgoingDeliveries> = v;
return;
}
void localOpen()
{
org.apache.qpid.proton.engine.Event$Type 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.SessionImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type SESSION_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;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type SESSION_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 void setOutgoingWindow(long)
{
byte v, v;
long v;
java.lang.String v;
java.lang.IllegalArgumentException v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: long;
v = v cmp 0L;
if v < 0 goto label;
v = v cmp 4294967295L;
if v <= 0 goto label;
label:
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(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[])>("Value \'\u0001\' must be in the range [0 - 2^32-1]");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.qpid.proton.engine.impl.SessionImpl: long _outgoingWindow> = v;
return;
}
public long getOutgoingWindow()
{
long v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: long _outgoingWindow>;
return v;
}
public java.util.Map getProperties()
{
java.util.Map v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _properties>;
return v;
}
public void setProperties(java.util.Map)
{
java.util.Map v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: java.util.Map;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _properties> = v;
return;
}
public java.util.Map getRemoteProperties()
{
java.util.Map v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _remoteProperties>;
return v;
}
void setRemoteProperties(java.util.Map)
{
java.util.Map v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: java.util.Map;
v.<org.apache.qpid.proton.engine.impl.SessionImpl: java.util.Map _remoteProperties> = v;
return;
}
public org.apache.qpid.proton.amqp.Symbol[] getDesiredCapabilities()
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.amqp.Symbol[] _desiredCapabilities>;
return v;
}
public void setDesiredCapabilities(org.apache.qpid.proton.amqp.Symbol[])
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: org.apache.qpid.proton.amqp.Symbol[];
v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.amqp.Symbol[] _desiredCapabilities> = v;
return;
}
public org.apache.qpid.proton.amqp.Symbol[] getRemoteDesiredCapabilities()
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteDesiredCapabilities>;
return v;
}
void setRemoteDesiredCapabilities(org.apache.qpid.proton.amqp.Symbol[])
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: org.apache.qpid.proton.amqp.Symbol[];
v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteDesiredCapabilities> = v;
return;
}
public org.apache.qpid.proton.amqp.Symbol[] getOfferedCapabilities()
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.amqp.Symbol[] _offeredCapabilities>;
return v;
}
public void setOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[])
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: org.apache.qpid.proton.amqp.Symbol[];
v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.amqp.Symbol[] _offeredCapabilities> = v;
return;
}
public org.apache.qpid.proton.amqp.Symbol[] getRemoteOfferedCapabilities()
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v = v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteOfferedCapabilities>;
return v;
}
void setRemoteOfferedCapabilities(org.apache.qpid.proton.amqp.Symbol[])
{
org.apache.qpid.proton.amqp.Symbol[] v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.SessionImpl;
v := @parameter: org.apache.qpid.proton.amqp.Symbol[];
v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.amqp.Symbol[] _remoteOfferedCapabilities> = v;
return;
}
}