public abstract class org.apache.qpid.proton.engine.impl.EndpointImpl extends java.lang.Object implements org.apache.qpid.proton.engine.ProtonJEndpoint
{
private org.apache.qpid.proton.engine.EndpointState _localState;
private org.apache.qpid.proton.engine.EndpointState _remoteState;
private org.apache.qpid.proton.amqp.transport.ErrorCondition _localError;
private org.apache.qpid.proton.amqp.transport.ErrorCondition _remoteError;
private boolean _modified;
private org.apache.qpid.proton.engine.impl.EndpointImpl _transportNext;
private org.apache.qpid.proton.engine.impl.EndpointImpl _transportPrev;
private java.lang.Object _context;
private org.apache.qpid.proton.engine.Record _attachments;
private int refcount;
boolean freed;
public void <init>()
{
org.apache.qpid.proton.amqp.transport.ErrorCondition v, v;
org.apache.qpid.proton.engine.EndpointState v, v;
org.apache.qpid.proton.engine.impl.RecordImpl v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState UNINITIALIZED>;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.EndpointState _localState> = v;
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState UNINITIALIZED>;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.EndpointState _remoteState> = v;
v = new org.apache.qpid.proton.amqp.transport.ErrorCondition;
specialinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.amqp.transport.ErrorCondition _localError> = v;
v = new org.apache.qpid.proton.amqp.transport.ErrorCondition;
specialinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.amqp.transport.ErrorCondition _remoteError> = v;
v = new org.apache.qpid.proton.engine.impl.RecordImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.RecordImpl: void <init>()>();
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.Record _attachments> = v;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: int refcount> = 1;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: boolean freed> = 0;
return;
}
void incref()
{
int v, v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: int refcount>;
v = v + 1;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: int refcount> = v;
return;
}
void decref()
{
java.lang.IllegalStateException v;
int v, v, v, v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: int refcount>;
v = v - 1;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: int refcount> = v;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: int refcount>;
if v != 0 goto label;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void postFinal()>();
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: int refcount>;
if v >= 0 goto label;
v = new java.lang.IllegalStateException;
specialinvoke v.<java.lang.IllegalStateException: void <init>()>();
throw v;
label:
return;
}
abstract void postFinal();
abstract void localOpen();
abstract void localClose();
public void open()
{
org.apache.qpid.proton.engine.EndpointState v, v, v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.EndpointState getLocalState()>();
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState ACTIVE>;
if v == v goto label;
v = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState ACTIVE>;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.EndpointState _localState> = v;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void localOpen()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void modified()>();
label:
return;
}
public void close()
{
org.apache.qpid.proton.engine.EndpointState v, v, v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: 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 = <org.apache.qpid.proton.engine.EndpointState: org.apache.qpid.proton.engine.EndpointState CLOSED>;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.EndpointState _localState> = v;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void localClose()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void modified()>();
label:
return;
}
public org.apache.qpid.proton.engine.EndpointState getLocalState()
{
org.apache.qpid.proton.engine.EndpointState v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.EndpointState _localState>;
return v;
}
public org.apache.qpid.proton.engine.EndpointState getRemoteState()
{
org.apache.qpid.proton.engine.EndpointState v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.EndpointState _remoteState>;
return v;
}
public org.apache.qpid.proton.amqp.transport.ErrorCondition getCondition()
{
org.apache.qpid.proton.amqp.transport.ErrorCondition v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.amqp.transport.ErrorCondition _localError>;
return v;
}
public void setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition)
{
org.apache.qpid.proton.amqp.transport.ErrorCondition v, v, v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v := @parameter: org.apache.qpid.proton.amqp.transport.ErrorCondition;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.amqp.transport.ErrorCondition _localError>;
virtualinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void copyFrom(org.apache.qpid.proton.amqp.transport.ErrorCondition)>(v);
goto label;
label:
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.amqp.transport.ErrorCondition _localError>;
virtualinvoke v.<org.apache.qpid.proton.amqp.transport.ErrorCondition: void clear()>();
label:
return;
}
public org.apache.qpid.proton.amqp.transport.ErrorCondition getRemoteCondition()
{
org.apache.qpid.proton.amqp.transport.ErrorCondition v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.amqp.transport.ErrorCondition _remoteError>;
return v;
}
void setLocalState(org.apache.qpid.proton.engine.EndpointState)
{
org.apache.qpid.proton.engine.EndpointState v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v := @parameter: org.apache.qpid.proton.engine.EndpointState;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.EndpointState _localState> = v;
return;
}
void setRemoteState(org.apache.qpid.proton.engine.EndpointState)
{
org.apache.qpid.proton.engine.EndpointState v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v := @parameter: org.apache.qpid.proton.engine.EndpointState;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.EndpointState _remoteState> = v;
return;
}
void modified()
{
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void modified(boolean)>(1);
return;
}
void modified(boolean)
{
org.apache.qpid.proton.engine.impl.TransportImpl v;
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v, v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
boolean v, v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v := @parameter: boolean;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: boolean _modified>;
if v != 0 goto label;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: boolean _modified> = 1;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void addModified(org.apache.qpid.proton.engine.impl.EndpointImpl)>(v);
label:
if v == 0 goto label;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: org.apache.qpid.proton.engine.impl.TransportImpl getTransport()>();
if v == null goto label;
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type TRANSPORT>;
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:
return;
}
protected abstract org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl();
void clearModified()
{
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: boolean _modified>;
if v == 0 goto label;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: boolean _modified> = 0;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ConnectionImpl: void removeModified(org.apache.qpid.proton.engine.impl.EndpointImpl)>(v);
label:
return;
}
boolean isModified()
{
org.apache.qpid.proton.engine.impl.EndpointImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: boolean _modified>;
return v;
}
org.apache.qpid.proton.engine.impl.EndpointImpl transportNext()
{
org.apache.qpid.proton.engine.impl.EndpointImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportNext>;
return v;
}
org.apache.qpid.proton.engine.impl.EndpointImpl transportPrev()
{
org.apache.qpid.proton.engine.impl.EndpointImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportPrev>;
return v;
}
abstract void doFree();
public final void free()
{
org.apache.qpid.proton.engine.impl.EndpointImpl v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: boolean freed>;
if v == 0 goto label;
return;
label:
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: boolean freed> = 1;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void doFree()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.EndpointImpl: void decref()>();
return;
}
void setTransportNext(org.apache.qpid.proton.engine.impl.EndpointImpl)
{
org.apache.qpid.proton.engine.impl.EndpointImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.EndpointImpl;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportNext> = v;
return;
}
void setTransportPrev(org.apache.qpid.proton.engine.impl.EndpointImpl)
{
org.apache.qpid.proton.engine.impl.EndpointImpl v, v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v := @parameter: org.apache.qpid.proton.engine.impl.EndpointImpl;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.impl.EndpointImpl _transportPrev> = v;
return;
}
public java.lang.Object getContext()
{
java.lang.Object v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: java.lang.Object _context>;
return v;
}
public void setContext(java.lang.Object)
{
java.lang.Object v;
org.apache.qpid.proton.engine.impl.EndpointImpl v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v := @parameter: java.lang.Object;
v.<org.apache.qpid.proton.engine.impl.EndpointImpl: java.lang.Object _context> = v;
return;
}
public org.apache.qpid.proton.engine.Record attachments()
{
org.apache.qpid.proton.engine.impl.EndpointImpl v;
org.apache.qpid.proton.engine.Record v;
v := @this: org.apache.qpid.proton.engine.impl.EndpointImpl;
v = v.<org.apache.qpid.proton.engine.impl.EndpointImpl: org.apache.qpid.proton.engine.Record _attachments>;
return v;
}
}