class org.apache.qpid.proton.engine.impl.TransportLink extends java.lang.Object
{
private org.apache.qpid.proton.amqp.UnsignedInteger _localHandle;
private java.lang.String _name;
private org.apache.qpid.proton.amqp.UnsignedInteger _remoteHandle;
private org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount;
private org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit;
private org.apache.qpid.proton.engine.impl.LinkImpl _link;
private org.apache.qpid.proton.amqp.UnsignedInteger _remoteDeliveryCount;
private org.apache.qpid.proton.amqp.UnsignedInteger _remoteLinkCredit;
private boolean _detachReceived;
private boolean _attachSent;
protected void <init>(org.apache.qpid.proton.engine.impl.LinkImpl)
{
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.TransportLink v;
java.lang.String v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.engine.impl.LinkImpl;
specialinvoke v.<java.lang.Object: void <init>()>();
v = <org.apache.qpid.proton.amqp.UnsignedInteger: org.apache.qpid.proton.amqp.UnsignedInteger ZERO>;
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit> = v;
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl _link> = v;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: java.lang.String getName()>();
v.<org.apache.qpid.proton.engine.impl.TransportLink: java.lang.String _name> = v;
return;
}
static org.apache.qpid.proton.engine.impl.TransportLink createTransportLink(org.apache.qpid.proton.engine.impl.LinkImpl)
{
org.apache.qpid.proton.engine.impl.TransportReceiver v;
org.apache.qpid.proton.engine.impl.TransportSender v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
boolean v;
v := @parameter: org.apache.qpid.proton.engine.impl.LinkImpl;
v = v instanceof org.apache.qpid.proton.engine.impl.ReceiverImpl;
if v == 0 goto label;
v = new org.apache.qpid.proton.engine.impl.TransportReceiver;
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportReceiver: void <init>(org.apache.qpid.proton.engine.impl.ReceiverImpl)>(v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.ReceiverImpl: void setTransportLink(org.apache.qpid.proton.engine.impl.TransportReceiver)>(v);
return v;
label:
v = new org.apache.qpid.proton.engine.impl.TransportSender;
specialinvoke v.<org.apache.qpid.proton.engine.impl.TransportSender: void <init>(org.apache.qpid.proton.engine.impl.SenderImpl)>(v);
virtualinvoke v.<org.apache.qpid.proton.engine.impl.SenderImpl: void setTransportLink(org.apache.qpid.proton.engine.impl.TransportSender)>(v);
return v;
}
void unbind()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: void clearLocalHandle()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: void clearRemoteHandle()>();
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getLocalHandle()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _localHandle>;
return v;
}
public void setLocalHandle(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _localHandle>;
if v != null goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: void incref()>();
label:
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _localHandle> = v;
return;
}
public boolean isLocalHandleSet()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _localHandle>;
if v == null goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.String getName()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
java.lang.String v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: java.lang.String _name>;
return v;
}
public void setName(java.lang.String)
{
org.apache.qpid.proton.engine.impl.TransportLink v;
java.lang.String v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: java.lang.String;
v.<org.apache.qpid.proton.engine.impl.TransportLink: java.lang.String _name> = v;
return;
}
public void clearLocalHandle()
{
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _localHandle>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: void decref()>();
label:
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _localHandle> = null;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getRemoteHandle()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteHandle>;
return v;
}
public void setRemoteHandle(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteHandle>;
if v != null goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: void incref()>();
label:
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteHandle> = v;
return;
}
public void clearRemoteHandle()
{
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteHandle>;
if v == null goto label;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: void decref()>();
label:
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteHandle> = null;
return;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getDeliveryCount()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount>;
return v;
}
public org.apache.qpid.proton.amqp.UnsignedInteger getLinkCredit()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit>;
return v;
}
public void addCredit(int)
{
int v, v, v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: int;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit>;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.UnsignedInteger: int intValue()>();
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.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit> = v;
return;
}
public boolean hasCredit()
{
int v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger getLinkCredit()>();
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;
}
public org.apache.qpid.proton.engine.impl.LinkImpl getLink()
{
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.TransportLink v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
return v;
}
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;
org.apache.qpid.proton.engine.Event$Type v;
org.apache.qpid.proton.engine.impl.LinkImpl v, v;
org.apache.qpid.proton.engine.impl.ConnectionImpl v;
org.apache.qpid.proton.amqp.transport.Flow v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
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 getDeliveryCount()>();
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteDeliveryCount> = v;
v = virtualinvoke v.<org.apache.qpid.proton.amqp.transport.Flow: org.apache.qpid.proton.amqp.UnsignedInteger getLinkCredit()>();
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteLinkCredit> = v;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl()>();
v = <org.apache.qpid.proton.engine.Event$Type: org.apache.qpid.proton.engine.Event$Type LINK_FLOW>;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl _link>;
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 setLinkCredit(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit> = v;
return;
}
public void setDeliveryCount(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount> = v;
return;
}
public void settled(org.apache.qpid.proton.engine.impl.TransportDelivery)
{
org.apache.qpid.proton.engine.impl.TransportDelivery v;
org.apache.qpid.proton.engine.impl.TransportSession v;
org.apache.qpid.proton.engine.impl.LinkImpl v;
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.engine.impl.SessionImpl v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.engine.impl.TransportDelivery;
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.engine.impl.LinkImpl getLink()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.LinkImpl: org.apache.qpid.proton.engine.impl.SessionImpl getSession()>();
v = virtualinvoke v.<org.apache.qpid.proton.engine.impl.SessionImpl: org.apache.qpid.proton.engine.impl.TransportSession getTransportSession()>();
virtualinvoke v.<org.apache.qpid.proton.engine.impl.TransportSession: void settled(org.apache.qpid.proton.engine.impl.TransportDelivery)>(v);
return;
}
org.apache.qpid.proton.amqp.UnsignedInteger getRemoteDeliveryCount()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteDeliveryCount>;
return v;
}
org.apache.qpid.proton.amqp.UnsignedInteger getRemoteLinkCredit()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteLinkCredit>;
return v;
}
public void setRemoteLinkCredit(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteLinkCredit> = v;
return;
}
void decrementLinkCredit()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit>;
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.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _linkCredit> = v;
return;
}
void incrementDeliveryCount()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v, v, v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount>;
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.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _deliveryCount> = v;
return;
}
public void receivedDetach()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v.<org.apache.qpid.proton.engine.impl.TransportLink: boolean _detachReceived> = 1;
return;
}
public boolean detachReceived()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: boolean _detachReceived>;
return v;
}
public boolean attachSent()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
boolean v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v = v.<org.apache.qpid.proton.engine.impl.TransportLink: boolean _attachSent>;
return v;
}
public void sentAttach()
{
org.apache.qpid.proton.engine.impl.TransportLink v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v.<org.apache.qpid.proton.engine.impl.TransportLink: boolean _attachSent> = 1;
return;
}
public void setRemoteDeliveryCount(org.apache.qpid.proton.amqp.UnsignedInteger)
{
org.apache.qpid.proton.engine.impl.TransportLink v;
org.apache.qpid.proton.amqp.UnsignedInteger v;
v := @this: org.apache.qpid.proton.engine.impl.TransportLink;
v := @parameter: org.apache.qpid.proton.amqp.UnsignedInteger;
v.<org.apache.qpid.proton.engine.impl.TransportLink: org.apache.qpid.proton.amqp.UnsignedInteger _remoteDeliveryCount> = v;
return;
}
}