public class org.apache.qpid.proton.engine.impl.TransportImpl extends org.apache.qpid.proton.engine.impl.EndpointImpl implements org.apache.qpid.proton.engine.ProtonJTransport, org.apache.qpid.proton.amqp.transport.FrameBody$FrameBodyHandler, org.apache.qpid.proton.engine.impl.FrameHandler, org.apache.qpid.proton.engine.impl.TransportOutputWriter, org.apache.qpid.proton.engine.impl.TransportInternal { static final int BUFFER_RELEASE_THRESHOLD; private static final int CHANNEL_MAX_LIMIT; private static final boolean FRM_ENABLED; private static final int TRACE_FRAME_PAYLOAD_LENGTH; private static final java.lang.String HEADER_DESCRIPTION; private int _levels; private org.apache.qpid.proton.engine.impl.FrameParser _frameParser; private org.apache.qpid.proton.engine.impl.ConnectionImpl _connectionEndpoint; private boolean _isOpenSent; private boolean _isCloseSent; private boolean _headerWritten; private java.util.Map _remoteSessions; private java.util.Map _localSessions; private org.apache.qpid.proton.engine.impl.TransportInput _inputProcessor; private org.apache.qpid.proton.engine.impl.TransportOutput _outputProcessor; private org.apache.qpid.proton.codec.DecoderImpl _decoder; private org.apache.qpid.proton.codec.EncoderImpl _encoder; private int _maxFrameSize; private int _remoteMaxFrameSize; private int _outboundFrameSizeLimit; private int _channelMax; private int _remoteChannelMax; private final org.apache.qpid.proton.engine.impl.FrameWriter _frameWriter; private boolean _closeReceived; private org.apache.qpid.proton.amqp.transport.Open _open; private org.apache.qpid.proton.engine.impl.SaslImpl _sasl; private org.apache.qpid.proton.engine.impl.ssl.SslImpl _ssl; private final org.apache.qpid.proton.engine.impl.Ref _protocolTracer; private org.apache.qpid.proton.engine.TransportResult _lastTransportResult; private boolean _init; private boolean _processingStarted; private boolean _emitFlowEventOnSend; private boolean _useReadOnlyOutputBuffer; private org.apache.qpid.proton.engine.impl.FrameHandler _frameHandler; private boolean _head_closed; private boolean _conditionSet; private boolean postedHeadClosed; private boolean postedTailClosed; private boolean postedTransportError; private int _localIdleTimeout; private int _remoteIdleTimeout; private long _bytesInput; private long _bytesOutput; private long _localIdleDeadline; private long _lastBytesInput; private long _lastBytesOutput; private long _remoteIdleDeadline; private org.apache.qpid.proton.reactor.Selectable _selectable; private org.apache.qpid.proton.reactor.Reactor _reactor; private java.util.List _additionalTransportLayers; private final org.apache.qpid.proton.amqp.transport.Disposition cachedDisposition; private final org.apache.qpid.proton.amqp.transport.Flow cachedFlow; private final org.apache.qpid.proton.amqp.transport.Transfer cachedTransfer; static java.lang.String INCOMING; static java.lang.String OUTGOING; private static final boolean getBooleanEnv(java.lang.String) { java.lang.String v, v, v, v, v; boolean v, v, v, v; v := @parameter: java.lang.String; v = staticinvoke (v); v = "true"; v = virtualinvoke v.(v); if v != 0 goto label; v = "1"; v = virtualinvoke v.(v); if v != 0 goto label; v = "yes"; v = virtualinvoke v.(v); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public void () { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = (int) -1; specialinvoke v.(int)>(v); return; } void (int) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.Ref v; java.util.HashMap v, v; byte v; int v, v, v, v, v; org.apache.qpid.proton.engine.TransportResult v; org.apache.qpid.proton.amqp.transport.Flow v; boolean v; org.apache.qpid.proton.engine.impl.FrameWriter v; org.apache.qpid.proton.amqp.transport.Disposition v; org.apache.qpid.proton.codec.EncoderImpl v, v, v; org.apache.qpid.proton.amqp.transport.Transfer v; org.apache.qpid.proton.codec.DecoderImpl v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; specialinvoke v.()>(); v = ; if v == 0 goto label; v = 2; goto label; label: v = 0; label: v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new org.apache.qpid.proton.codec.DecoderImpl; specialinvoke v.()>(); v. = v; v = new org.apache.qpid.proton.codec.EncoderImpl; v = v.; specialinvoke v.(org.apache.qpid.proton.codec.DecoderImpl)>(v); v. = v; v = (int) -1; v. = v; v. = 512; v. = 0; v = (int) 65535; v. = v; v = (int) 65535; v. = v; v = new org.apache.qpid.proton.engine.impl.Ref; specialinvoke v.(java.lang.Object)>(null); v. = v; v = staticinvoke (); v. = v; v. = 1; v. = 1; v. = v; v. = 0; v. = 0; v. = 0; v. = 0; v. = 0; v. = 0; v. = 0L; v. = 0L; v. = 0L; v. = 0L; v. = 0L; v. = 0L; v = new org.apache.qpid.proton.amqp.transport.Disposition; specialinvoke v.()>(); v. = v; v = new org.apache.qpid.proton.amqp.transport.Flow; specialinvoke v.()>(); v. = v; v = new org.apache.qpid.proton.amqp.transport.Transfer; specialinvoke v.()>(); v. = v; v = v.; v = v.; staticinvoke (v, v); v. = v; v = new org.apache.qpid.proton.engine.impl.FrameWriter; v = v.; v = v.; specialinvoke v.(org.apache.qpid.proton.codec.EncoderImpl,int,byte,org.apache.qpid.proton.engine.impl.TransportImpl)>(v, v, 0, v); v. = v; return; } private void init() { org.apache.qpid.proton.engine.impl.FrameHandler v; org.apache.qpid.proton.engine.impl.TransportImpl v; int v, v; org.apache.qpid.proton.engine.impl.FrameParser v, v; org.apache.qpid.proton.engine.impl.TransportOutputAdaptor v; org.apache.qpid.proton.codec.DecoderImpl v; boolean v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v != 0 goto label; v. = 1; v = new org.apache.qpid.proton.engine.impl.FrameParser; v = v.; v = v.; v = v.; specialinvoke v.(org.apache.qpid.proton.engine.impl.FrameHandler,org.apache.qpid.proton.codec.ByteBufferDecoder,int,org.apache.qpid.proton.engine.impl.TransportImpl)>(v, v, v, v); v. = v; v = v.; v. = v; v = new org.apache.qpid.proton.engine.impl.TransportOutputAdaptor; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.qpid.proton.engine.impl.TransportOutputWriter,int,boolean)>(v, v, v); v. = v; label: return; } public void trace(int) { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; v. = v; return; } public int getMaxFrameSize() { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public int getRemoteMaxFrameSize() { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public void setInitialRemoteMaxFrameSize(int) { java.lang.IllegalStateException v; org.apache.qpid.proton.engine.impl.TransportImpl v; int v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; v = v.; if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Cannot set initial remote max frame size after transport has been initialised"); throw v; label: v. = v; return; } public void setMaxFrameSize(int) { java.lang.IllegalStateException v; org.apache.qpid.proton.engine.impl.TransportImpl v; int v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; v = v.; if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Cannot set max frame size after transport has been initialised"); throw v; label: v. = v; return; } public int getChannelMax() { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public void setChannelMax(int) { org.apache.qpid.proton.engine.impl.TransportImpl v; int v; java.lang.NumberFormatException v; java.lang.String v; java.lang.IllegalArgumentException v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; v = v.; if v == 0 goto label; v = new java.lang.IllegalArgumentException; specialinvoke v.(java.lang.String)>("Cannot change channel max after open frame has been sent"); throw v; label: if v < 0 goto label; if v < 65536 goto label; label: v = new java.lang.NumberFormatException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Value \"\u0001\" lies outside the range [0-65536)."); specialinvoke v.(java.lang.String)>(v); throw v; label: v. = v; return; } public int getRemoteChannelMax() { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public org.apache.qpid.proton.amqp.transport.ErrorCondition getCondition() { org.apache.qpid.proton.amqp.transport.ErrorCondition v, v; org.apache.qpid.proton.engine.impl.TransportImpl v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = specialinvoke v.(); v = specialinvoke v.(v); if v == 0 goto label; v = v; goto label; label: v = null; label: return v; } public void setCondition(org.apache.qpid.proton.amqp.transport.ErrorCondition) { org.apache.qpid.proton.amqp.transport.ErrorCondition v; org.apache.qpid.proton.engine.impl.TransportImpl v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.ErrorCondition; specialinvoke v.(v); v = specialinvoke v.(v); v. = v; return; } private boolean isConditionPopulated(org.apache.qpid.proton.amqp.transport.ErrorCondition) { org.apache.qpid.proton.amqp.transport.ErrorCondition v; org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.Symbol v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.ErrorCondition; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = 1; goto label; label: v = 0; label: return v; } public void bind(org.apache.qpid.proton.engine.Connection) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.Event$Type v; org.apache.qpid.proton.engine.EndpointState v, v, v, v, v; org.apache.qpid.proton.engine.impl.FrameParser v; org.apache.qpid.proton.engine.Connection v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v, v, v; org.apache.qpid.proton.amqp.transport.Open v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.Connection; v. = v; v = ; virtualinvoke v.(v, v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = virtualinvoke v.(); v = ; if v == v goto label; v = v.; v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); v = ; if v != v goto label; v = v.; v = ; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(); label: return; } public void unbind() { org.apache.qpid.proton.engine.impl.TransportImpl v; java.util.Map v, v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v, v, v; boolean v, v; java.util.Iterator v, v; java.util.Collection v, v; org.apache.qpid.proton.engine.Event$Type v; java.lang.Object v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: v = ; v = v.; virtualinvoke v.(v, v); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(null); v = v.; virtualinvoke v.(); return; } public int input(byte[], int, int) { byte[] v; org.apache.qpid.proton.engine.impl.TransportImpl v; java.nio.ByteBuffer v; int v, v, v; org.apache.qpid.proton.engine.TransportResult v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; v = virtualinvoke v.(v); interfaceinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v, v, v); v = virtualinvoke v.(); interfaceinvoke v.(); return v; } public org.apache.qpid.proton.engine.TransportResult oldApiCheckStateBeforeInput(int) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.TransportException v; org.apache.qpid.proton.engine.EndpointState v, v; int v; org.apache.qpid.proton.engine.TransportResult v, v, v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; v = v.; interfaceinvoke v.(); if v != 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = ; if v == v goto label; label: v = new org.apache.qpid.proton.engine.TransportException; specialinvoke v.(java.lang.String)>("Unexpected EOS when remote connection not closed: connection aborted"); v = staticinvoke (v); return v; label: v = staticinvoke (); return v; } public int output(byte[], int, int) { byte[] v; org.apache.qpid.proton.engine.impl.TransportImpl v; int v, v, v; java.nio.ByteBuffer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: byte[]; v := @parameter: int; v := @parameter: int; v = virtualinvoke v.(); v = staticinvoke (v, v, v, v); virtualinvoke v.(); return v; } public boolean writeInto(java.nio.ByteBuffer) { org.apache.qpid.proton.engine.impl.FrameWriter v; org.apache.qpid.proton.engine.impl.TransportImpl v; java.nio.ByteBuffer v; boolean v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: java.nio.ByteBuffer; specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); v = v.; virtualinvoke v.(v); v = v.; if v != 0 goto label; v = v.; if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } public org.apache.qpid.proton.engine.Sasl sasl() { java.lang.IllegalStateException v; org.apache.qpid.proton.engine.impl.TransportImpl v; int v; org.apache.qpid.proton.engine.impl.TransportInput v; org.apache.qpid.proton.engine.impl.SaslImpl v, v, v, v; org.apache.qpid.proton.engine.impl.TransportOutput v; org.apache.qpid.proton.engine.impl.TransportWrapper v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v != null goto label; v = v.; if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Sasl can\'t be initiated after transport has started processing"); throw v; label: specialinvoke v.(); v = new org.apache.qpid.proton.engine.impl.SaslImpl; v = v.; specialinvoke v.(org.apache.qpid.proton.engine.impl.TransportImpl,int)>(v, v); v. = v; v = v.; v = v.; v = v.; v = virtualinvoke v.(v, v); v. = v; v. = v; label: v = v.; return v; } public org.apache.qpid.proton.engine.Ssl ssl(org.apache.qpid.proton.engine.SslDomain, org.apache.qpid.proton.engine.SslPeerDetails) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.ssl.SslImpl v, v, v, v; org.apache.qpid.proton.engine.SslPeerDetails v; org.apache.qpid.proton.engine.impl.TransportInput v; org.apache.qpid.proton.engine.impl.TransportOutput v; org.apache.qpid.proton.engine.impl.TransportWrapper v; org.apache.qpid.proton.engine.SslDomain v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.SslDomain; v := @parameter: org.apache.qpid.proton.engine.SslPeerDetails; v = v.; if v != null goto label; specialinvoke v.(); v = new org.apache.qpid.proton.engine.impl.ssl.SslImpl; specialinvoke v.(org.apache.qpid.proton.engine.SslDomain,org.apache.qpid.proton.engine.SslPeerDetails)>(v, v); v. = v; v = v.; v = v.; v = v.; v = virtualinvoke v.(v, v); v. = v; v. = v; label: v = v.; return v; } public org.apache.qpid.proton.engine.Ssl ssl(org.apache.qpid.proton.engine.SslDomain) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.Ssl v; org.apache.qpid.proton.engine.SslDomain v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.SslDomain; v = virtualinvoke v.(v, null); return v; } private void processDetach() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.UnsignedInteger v; org.apache.qpid.proton.amqp.Symbol v; org.apache.qpid.proton.amqp.transport.Detach v; int v, v; org.apache.qpid.proton.engine.impl.TransportSession v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; org.apache.qpid.proton.engine.impl.EndpointImpl v; boolean v, v, v, v, v, v, v, v, v, v, v, v; org.apache.qpid.proton.engine.impl.SessionImpl v; org.apache.qpid.proton.engine.impl.TransportLink v; org.apache.qpid.proton.amqp.transport.ErrorCondition v; org.apache.qpid.proton.engine.EndpointState v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v == null goto label; v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = v instanceof org.apache.qpid.proton.engine.impl.LinkImpl; if v == 0 goto label; v = specialinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); v = ; if v == v goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; if v != 0 goto label; v = v instanceof org.apache.qpid.proton.engine.impl.SenderImpl; if v == 0 goto label; v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v != 0 goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(v); v = new org.apache.qpid.proton.amqp.transport.Detach; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; virtualinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(v, v, null, null); label: virtualinvoke v.(); label: v = virtualinvoke v.(); goto label; label: return; } private void writeFlow(org.apache.qpid.proton.engine.impl.TransportSession, org.apache.qpid.proton.engine.impl.TransportLink) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v, v, v; int v; org.apache.qpid.proton.engine.impl.TransportSession v; org.apache.qpid.proton.amqp.transport.Flow v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v; org.apache.qpid.proton.engine.impl.TransportLink v; org.apache.qpid.proton.engine.impl.LinkImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.TransportSession; v := @parameter: org.apache.qpid.proton.engine.impl.TransportLink; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(null); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(null); v = v.; virtualinvoke v.(null); v = v.; virtualinvoke v.(null); v = v.; virtualinvoke v.(0); label: v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v, null, null); return; } private void processSenderFlow() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v; int v; org.apache.qpid.proton.engine.impl.TransportSession v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; org.apache.qpid.proton.engine.impl.EndpointImpl v; boolean v, v, v, v; org.apache.qpid.proton.engine.impl.SessionImpl v; org.apache.qpid.proton.engine.impl.TransportSender v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v == null goto label; v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = v instanceof org.apache.qpid.proton.engine.impl.SenderImpl; if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(0); specialinvoke v.(v, v); label: v = virtualinvoke v.(); goto label; label: return; } private void processTransportWork() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.DeliveryImpl v; org.apache.qpid.proton.engine.impl.LinkImpl v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; boolean v, v, v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v == null goto label; v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = virtualinvoke v.(); v = v instanceof org.apache.qpid.proton.engine.impl.SenderImpl; if v == 0 goto label; v = specialinvoke v.(v, v); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); goto label; label: v = specialinvoke v.(v, v); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); goto label; label: return; } private boolean processTransportWorkSender(org.apache.qpid.proton.engine.impl.DeliveryImpl, org.apache.qpid.proton.engine.impl.SenderImpl) { byte[] v; org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.qpid.proton.amqp.transport.Role v; org.apache.qpid.proton.engine.impl.TransportDelivery v, v, v; org.apache.qpid.proton.amqp.transport.DeliveryState v, v, v, v; org.apache.qpid.proton.engine.impl.FrameWriter v; org.apache.qpid.proton.engine.EndpointState v, v; java.lang.Throwable v; org.apache.qpid.proton.amqp.transport.Disposition v, v, v, v, v, v, v; org.apache.qpid.proton.engine.Event$Type v; org.apache.qpid.proton.engine.impl.SenderImpl v; org.apache.qpid.proton.amqp.transport.Transfer v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.qpid.proton.engine.impl.TransportImpl v; java.lang.Runnable v; org.apache.qpid.proton.amqp.Binary v; org.apache.qpid.proton.engine.impl.ConnectionImpl v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.qpid.proton.engine.impl.SessionImpl v; org.apache.qpid.proton.engine.impl.TransportSender v; org.apache.qpid.proton.codec.ReadableBuffer v; int v, v, v, v, v, v, v, v, v, v; org.apache.qpid.proton.engine.impl.DeliveryImpl v, v, v, v; org.apache.qpid.proton.engine.impl.TransportSession v; java.lang.Boolean v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl; v := @parameter: org.apache.qpid.proton.engine.impl.SenderImpl; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v > 0 goto label; v = virtualinvoke v.(); if v == v goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v == null goto label; if v == v goto label; return 0; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); virtualinvoke v.(); label: v = new org.apache.qpid.proton.engine.impl.TransportDelivery; specialinvoke v.(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.(v); v = v.; virtualinvoke v.(v); v = v.; v = new org.apache.qpid.proton.amqp.Binary; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(null); v = v.; virtualinvoke v.(0); v = v.; virtualinvoke v.(0); v = v.; virtualinvoke v.(0); v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(null); label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = ; virtualinvoke v.(v); goto label; label: v = v.; v = ; virtualinvoke v.(v); virtualinvoke v.(v, v); label: v = virtualinvoke v.(); if v != v goto label; v = v.; virtualinvoke v.(1); goto label; label: v = v.; virtualinvoke v.(0); label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = ; virtualinvoke v.(v); goto label; label: v = v.; v = staticinvoke (v); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = virtualinvoke v.(); v = v.; v = staticinvoke (v); virtualinvoke v.(v, v, v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; virtualinvoke v.(); throw v; label: virtualinvoke v.(); virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = neg v; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(null); virtualinvoke v.(); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = (int) -1; virtualinvoke v.(v); virtualinvoke v.(); goto label; label: v = interfaceinvoke v.(); v = v - v; v = neg v; virtualinvoke v.(v); virtualinvoke v.(v); label: v = v.; if v == 0 goto label; v = virtualinvoke v.(); v = ; if v == v goto label; v = virtualinvoke v.(); v = ; virtualinvoke v.(v, v); label: if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(0); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v, null, null); label: v = virtualinvoke v.(); if v != 0 goto label; v = 1; goto label; label: v = 0; label: return v; catch java.lang.Throwable from label to label with label; } private boolean processTransportWorkReceiver(org.apache.qpid.proton.engine.impl.DeliveryImpl, org.apache.qpid.proton.engine.impl.ReceiverImpl) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.ReceiverImpl v; org.apache.qpid.proton.amqp.UnsignedInteger v, v; org.apache.qpid.proton.amqp.transport.Role v; org.apache.qpid.proton.engine.impl.TransportDelivery v; int v; org.apache.qpid.proton.engine.impl.DeliveryImpl v; org.apache.qpid.proton.engine.impl.TransportSession v; org.apache.qpid.proton.amqp.transport.DeliveryState v, v; boolean v, v; org.apache.qpid.proton.engine.impl.SessionImpl v; org.apache.qpid.proton.amqp.transport.Disposition v, v, v, v, v, v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.DeliveryImpl; v := @parameter: org.apache.qpid.proton.engine.impl.ReceiverImpl; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(0); if v != null goto label; if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v, null, null); if v == 0 goto label; virtualinvoke v.(); label: return 1; label: return 0; } private void processReceiverFlow() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v; int v; org.apache.qpid.proton.engine.impl.TransportSession v, v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v, v; org.apache.qpid.proton.engine.impl.EndpointImpl v, v; boolean v, v, v, v, v, v, v, v, v, v; org.apache.qpid.proton.engine.impl.SessionImpl v; org.apache.qpid.proton.engine.impl.TransportLink v; org.apache.qpid.proton.engine.EndpointState v, v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v == null goto label; v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = v instanceof org.apache.qpid.proton.engine.impl.ReceiverImpl; if v == 0 goto label; v = specialinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); v = ; if v != v goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; label: virtualinvoke v.(v); specialinvoke v.(v, v); label: v = virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = v instanceof org.apache.qpid.proton.engine.impl.SessionImpl; if v == 0 goto label; v = specialinvoke v.(v); v = virtualinvoke v.(); v = ; if v != v goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; specialinvoke v.(v, null); label: v = virtualinvoke v.(); goto label; label: return; } private void processAttach() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.UnsignedInteger v, v; org.apache.qpid.proton.amqp.transport.Role v, v, v; org.apache.qpid.proton.amqp.transport.ReceiverSettleMode v, v; java.util.Map v, v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; boolean v, v, v, v, v, v, v, v, v; org.apache.qpid.proton.engine.impl.SessionImpl v; org.apache.qpid.proton.amqp.transport.SenderSettleMode v, v; org.apache.qpid.proton.engine.EndpointState v, v, v, v, v, v, v, v; org.apache.qpid.proton.amqp.transport.Attach v; org.apache.qpid.proton.amqp.transport.Target v, v; int v; org.apache.qpid.proton.amqp.UnsignedLong v, v; org.apache.qpid.proton.engine.impl.TransportSession v; java.lang.String v; org.apache.qpid.proton.engine.impl.EndpointImpl v; org.apache.qpid.proton.amqp.Symbol[] v, v, v, v; org.apache.qpid.proton.engine.impl.TransportLink v; org.apache.qpid.proton.amqp.transport.Source v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v == null goto label; v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = v instanceof org.apache.qpid.proton.engine.impl.LinkImpl; if v == 0 goto label; v = specialinvoke v.(v); v = virtualinvoke v.(); v = specialinvoke v.(v); v = virtualinvoke v.(); v = ; if v == v goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = ; if v != v goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = virtualinvoke v.(); v = ; if v != v goto label; label: v = v instanceof org.apache.qpid.proton.engine.impl.ReceiverImpl; if v == 0 goto label; v = ; goto label; label: v = ; label: v = v; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = ; if v != v goto label; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: virtualinvoke v.(v, v); label: v = new org.apache.qpid.proton.amqp.transport.Attach; specialinvoke v.()>(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: virtualinvoke v.(v); v = v instanceof org.apache.qpid.proton.engine.impl.SenderImpl; if v == 0 goto label; v = ; virtualinvoke v.(v); label: v = virtualinvoke v.(); virtualinvoke v.(v, v, null, null); virtualinvoke v.(); label: v = virtualinvoke v.(); goto label; label: return; } private void processHeader() { byte[] v; org.apache.qpid.proton.engine.impl.FrameWriter v; org.apache.qpid.proton.engine.impl.TransportImpl v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v != 0 goto label; specialinvoke v.(); v = v.; v = ; virtualinvoke v.(v); v. = 1; label: return; } private void outputHeaderDescription() { org.apache.qpid.proton.engine.impl.TransportImpl v; java.lang.String v; org.apache.qpid.proton.engine.impl.ProtocolTracer v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = virtualinvoke v.(); if v == 0 goto label; v = ; virtualinvoke v.(v, "AMQP"); v = virtualinvoke v.(); if v == null goto label; interfaceinvoke v.("AMQP"); label: return; } private void processOpen() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.UnsignedInteger v, v; org.apache.qpid.proton.amqp.UnsignedShort v; java.util.Map v; int v, v, v, v, v, v, v; java.lang.String v, v, v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v, v, v, v, v, v, v; boolean v, v; org.apache.qpid.proton.amqp.Symbol[] v, v; org.apache.qpid.proton.engine.EndpointState v, v; org.apache.qpid.proton.amqp.transport.Open v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v != 0 goto label; v = v.; if v != 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = ; if v == v goto label; label: v = new org.apache.qpid.proton.amqp.transport.Open; specialinvoke v.()>(); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v != null goto label; v = ""; goto label; label: v = v; label: virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: virtualinvoke v.(""); label: v = v.; if v <= 0 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.(v); label: v = v.; if v <= 0 goto label; v = v.; v = staticinvoke (v); virtualinvoke v.(v); label: v = v.; if v <= 0 goto label; v = new org.apache.qpid.proton.amqp.UnsignedInteger; v = v.; v = v / 2; specialinvoke v.(int)>(v); virtualinvoke v.(v); label: v. = 1; virtualinvoke v.(0, v, null, null); label: return; } private void processBegin() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.transport.Begin v; org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v; org.apache.qpid.proton.amqp.UnsignedShort v; java.util.Map v, v; int v, v; org.apache.qpid.proton.engine.impl.TransportSession v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; org.apache.qpid.proton.engine.impl.EndpointImpl v; boolean v, v, v, v; org.apache.qpid.proton.amqp.Symbol[] v, v, v, v; org.apache.qpid.proton.engine.EndpointState v, v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v == null goto label; v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = v instanceof org.apache.qpid.proton.engine.impl.SessionImpl; if v == 0 goto label; v = specialinvoke v.(v); v = virtualinvoke v.(); v = ; if v == v goto label; v = virtualinvoke v.(); if v != 0 goto label; v = specialinvoke v.(v); v = new org.apache.qpid.proton.amqp.transport.Begin; specialinvoke v.()>(); v = virtualinvoke v.(); v = ; if v == v goto label; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); label: virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: virtualinvoke v.(v, v, null, null); virtualinvoke v.(); label: v = virtualinvoke v.(); goto label; label: return; } private org.apache.qpid.proton.engine.impl.TransportSession getTransportState(org.apache.qpid.proton.engine.impl.SessionImpl) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.TransportSession v, v; org.apache.qpid.proton.engine.impl.SessionImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.SessionImpl; v = virtualinvoke v.(); if v != null goto label; v = new org.apache.qpid.proton.engine.impl.TransportSession; specialinvoke v.(org.apache.qpid.proton.engine.impl.TransportImpl,org.apache.qpid.proton.engine.impl.SessionImpl)>(v, v); v = v; virtualinvoke v.(v); label: return v; } private org.apache.qpid.proton.engine.impl.TransportLink getTransportState(org.apache.qpid.proton.engine.impl.LinkImpl) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.LinkImpl v; org.apache.qpid.proton.engine.impl.TransportLink v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.LinkImpl; v = virtualinvoke v.(); if v != null goto label; v = staticinvoke (v); label: return v; } private int allocateLocalChannel(org.apache.qpid.proton.engine.impl.TransportSession) { org.apache.qpid.proton.engine.impl.TransportImpl v; java.lang.Integer v, v; java.util.Map v, v; int v, v, v; org.apache.qpid.proton.engine.impl.TransportSession v; org.apache.qpid.proton.engine.impl.ConnectionImpl v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.TransportSession; v = 0; label: v = v.; v = virtualinvoke v.(); if v >= v goto label; v = v.; v = staticinvoke (v); v = interfaceinvoke v.(v); if v != 0 goto label; v = v.; v = staticinvoke (v); interfaceinvoke v.(v, v); virtualinvoke v.(v); return v; label: v = v + 1; goto label; label: v = (int) -1; return v; } private int freeLocalChannel(org.apache.qpid.proton.engine.impl.TransportSession) { org.apache.qpid.proton.engine.impl.TransportImpl v; java.util.Map v; int v; org.apache.qpid.proton.engine.impl.TransportSession v; java.lang.Integer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.TransportSession; v = virtualinvoke v.(); v = v.; v = staticinvoke (v); interfaceinvoke v.(v); virtualinvoke v.(); return v; } private void processEnd() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.transport.End v; org.apache.qpid.proton.amqp.Symbol v; int v; org.apache.qpid.proton.engine.impl.TransportSession v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; org.apache.qpid.proton.engine.impl.EndpointImpl v; boolean v, v, v, v, v; org.apache.qpid.proton.amqp.transport.ErrorCondition v; org.apache.qpid.proton.engine.EndpointState v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v == null goto label; v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = v instanceof org.apache.qpid.proton.engine.impl.SessionImpl; if v == 0 goto label; v = virtualinvoke v.(); v = ; if v != v goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; if v != 0 goto label; v = specialinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = specialinvoke v.(v); v = new org.apache.qpid.proton.amqp.transport.End; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; virtualinvoke v.(v); label: virtualinvoke v.(v, v, null, null); label: virtualinvoke v.(); label: v = virtualinvoke v.(); goto label; label: return; } private boolean hasSendableMessages(org.apache.qpid.proton.engine.impl.SessionImpl) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.TransportLink v; int v; org.apache.qpid.proton.engine.impl.TransportSession v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; org.apache.qpid.proton.engine.impl.EndpointImpl v; boolean v, v, v, v; org.apache.qpid.proton.engine.impl.SessionImpl v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.SessionImpl; v = v.; if v != null goto label; return 0; label: v = v.; if v != 0 goto label; if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; label: v = v.; v = virtualinvoke v.(); label: if v == null goto label; v = v instanceof org.apache.qpid.proton.engine.impl.SenderImpl; if v == 0 goto label; if v == null goto label; v = virtualinvoke v.(); if v != v goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = specialinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; return 1; label: v = virtualinvoke v.(); goto label; label: return 0; } private void processClose() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.transport.Close v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v, v, v, v, v, v; boolean v, v, v, v, v; org.apache.qpid.proton.amqp.transport.ErrorCondition v, v; org.apache.qpid.proton.engine.EndpointState v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v != 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = ; if v != v goto label; label: v = v.; if v != 0 goto label; v = specialinvoke v.(null); if v != 0 goto label; v = new org.apache.qpid.proton.amqp.transport.Close; specialinvoke v.()>(); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = specialinvoke v.(v); if v == 0 goto label; v = v.; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); label: v = specialinvoke v.(v); if v == 0 goto label; virtualinvoke v.(v); label: v. = 1; virtualinvoke v.(0, v, null, null); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: return; } protected void writeFrame(int, org.apache.qpid.proton.amqp.transport.FrameBody, org.apache.qpid.proton.codec.ReadableBuffer, java.lang.Runnable) { org.apache.qpid.proton.engine.impl.FrameWriter v; org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.codec.ReadableBuffer v; int v; org.apache.qpid.proton.amqp.transport.FrameBody v; java.lang.Runnable v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; v := @parameter: org.apache.qpid.proton.amqp.transport.FrameBody; v := @parameter: org.apache.qpid.proton.codec.ReadableBuffer; v := @parameter: java.lang.Runnable; v = v.; virtualinvoke v.(v, v, v, v); return; } protected org.apache.qpid.proton.engine.impl.ConnectionImpl getConnectionImpl() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.ConnectionImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } void postFinal() { org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; return; } void doFree() { org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; return; } public void handleOpen(org.apache.qpid.proton.amqp.transport.Open, org.apache.qpid.proton.amqp.Binary, java.lang.Integer) { org.apache.qpid.proton.engine.impl.TransportImpl v; long v, v, v, v, v, v, v, v; org.apache.qpid.proton.amqp.UnsignedInteger v, v, v, v, v, v, v; java.lang.Integer v; org.apache.qpid.proton.amqp.UnsignedShort v, v; byte v, v, v; int v, v, v; org.apache.qpid.proton.amqp.Binary v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; org.apache.qpid.proton.engine.impl.FrameWriter v; org.apache.qpid.proton.engine.EndpointState v; org.apache.qpid.proton.amqp.transport.Open v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.Open; v := @parameter: org.apache.qpid.proton.amqp.Binary; v := @parameter: java.lang.Integer; v = ; virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); goto label; label: v. = v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v. = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, 2147483647L); label: v = v.; if v <= 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; staticinvoke (v, v); label: v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v. = v; label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v. = v; label: return; } public void handleBegin(org.apache.qpid.proton.amqp.transport.Begin, org.apache.qpid.proton.amqp.Binary, java.lang.Integer) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.transport.Begin v; org.apache.qpid.proton.amqp.UnsignedInteger v; java.lang.Integer v, v; org.apache.qpid.proton.amqp.UnsignedShort v, v, v; java.lang.NullPointerException v; java.util.Map v, v, v, v; int v, v; java.lang.String v; org.apache.qpid.proton.amqp.Binary v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; org.apache.qpid.proton.engine.impl.SessionImpl v; org.apache.qpid.proton.amqp.Symbol[] v, v; org.apache.qpid.proton.engine.Event$Type v; org.apache.qpid.proton.engine.EndpointState v; java.lang.Object v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.Begin; v := @parameter: org.apache.qpid.proton.amqp.Binary; v := @parameter: java.lang.Integer; v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = virtualinvoke v.(); if v != null goto label; v = v.; v = virtualinvoke v.(); specialinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v != null goto label; v = new java.lang.NullPointerException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("uncorrelated channel: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); label: v = virtualinvoke v.(); virtualinvoke v.(v); v = ; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(v, v); v = v.; v = ; virtualinvoke v.(v, v); label: return; } public void handleAttach(org.apache.qpid.proton.amqp.transport.Attach, org.apache.qpid.proton.amqp.Binary, java.lang.Integer) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.UnsignedInteger v, v, v; org.apache.qpid.proton.amqp.transport.Role v, v, v, v, v, v; java.lang.Integer v; org.apache.qpid.proton.amqp.transport.Close v; org.apache.qpid.proton.amqp.transport.ReceiverSettleMode v; java.util.Map v, v; org.apache.qpid.proton.amqp.Binary v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v, v; boolean v, v; org.apache.qpid.proton.engine.impl.SessionImpl v; org.apache.qpid.proton.amqp.transport.SenderSettleMode v; org.apache.qpid.proton.amqp.transport.ErrorCondition v; org.apache.qpid.proton.engine.EndpointState v, v; org.apache.qpid.proton.amqp.transport.Attach v; org.apache.qpid.proton.engine.impl.LinkImpl v, v; org.apache.qpid.proton.amqp.Symbol v; org.apache.qpid.proton.amqp.transport.Target v; int v; org.apache.qpid.proton.amqp.UnsignedLong v; java.lang.String v, v, v, v; org.apache.qpid.proton.amqp.Symbol[] v, v; org.apache.qpid.proton.engine.impl.TransportLink v, v; org.apache.qpid.proton.amqp.transport.Source v; org.apache.qpid.proton.engine.Event$Type v; java.lang.Object v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.Attach; v := @parameter: org.apache.qpid.proton.amqp.Binary; v := @parameter: java.lang.Integer; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v <= 0 goto label; v = new org.apache.qpid.proton.amqp.transport.ErrorCondition; v = ; specialinvoke v.(org.apache.qpid.proton.amqp.Symbol,java.lang.String)>(v, "handle-max exceeded"); v = v.; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; if v != 0 goto label; v = new org.apache.qpid.proton.amqp.transport.Close; specialinvoke v.()>(); virtualinvoke v.(v); v. = 1; virtualinvoke v.(0, v, null, null); label: virtualinvoke v.(); return; label: v = virtualinvoke v.(v); v = null; if v != null goto label; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(); if v != v goto label; v = 1; goto label; label: v = 0; label: v = virtualinvoke v.(v, v); if v != null goto label; v = virtualinvoke v.(); v = ; if v != v goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); label: v = v; v = specialinvoke v.(v); goto label; label: v = virtualinvoke v.(); label: v = virtualinvoke v.(); v = ; if v != v goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = ; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(v, v); label: v = v.; v = ; virtualinvoke v.(v, v); label: return; } public void handleFlow(org.apache.qpid.proton.amqp.transport.Flow, org.apache.qpid.proton.amqp.Binary, java.lang.Integer) { org.apache.qpid.proton.engine.impl.TransportImpl v; java.util.Map v; java.lang.Object v; org.apache.qpid.proton.amqp.Binary v; java.lang.Integer v; org.apache.qpid.proton.amqp.transport.Flow v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.Flow; v := @parameter: org.apache.qpid.proton.amqp.Binary; v := @parameter: java.lang.Integer; v = v.; v = interfaceinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: return; } public void handleTransfer(org.apache.qpid.proton.amqp.transport.Transfer, org.apache.qpid.proton.amqp.Binary, java.lang.Integer) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.transport.Transfer v; java.util.Map v; java.lang.Object v; org.apache.qpid.proton.amqp.Binary v; java.lang.Integer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.Transfer; v := @parameter: org.apache.qpid.proton.amqp.Binary; v := @parameter: java.lang.Integer; v = v.; v = interfaceinvoke v.(v); if v == null goto label; virtualinvoke v.(v, v); label: return; } public void handleDisposition(org.apache.qpid.proton.amqp.transport.Disposition, org.apache.qpid.proton.amqp.Binary, java.lang.Integer) { org.apache.qpid.proton.engine.impl.TransportImpl v; java.util.Map v; org.apache.qpid.proton.amqp.transport.Disposition v; java.lang.Object v; org.apache.qpid.proton.amqp.Binary v; java.lang.Integer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.Disposition; v := @parameter: org.apache.qpid.proton.amqp.Binary; v := @parameter: java.lang.Integer; v = v.; v = interfaceinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: return; } public void handleDetach(org.apache.qpid.proton.amqp.transport.Detach, org.apache.qpid.proton.amqp.Binary, java.lang.Integer) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.UnsignedInteger v, v; java.lang.Integer v; org.apache.qpid.proton.amqp.transport.Detach v; java.util.Map v; org.apache.qpid.proton.amqp.Binary v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; boolean v; org.apache.qpid.proton.engine.impl.TransportLink v; org.apache.qpid.proton.amqp.transport.ErrorCondition v, v, v; org.apache.qpid.proton.engine.Event$Type v, v; org.apache.qpid.proton.engine.EndpointState v; java.lang.Object v; org.apache.qpid.proton.engine.impl.LinkImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.Detach; v := @parameter: org.apache.qpid.proton.amqp.Binary; v := @parameter: java.lang.Integer; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = ; virtualinvoke v.(v, v); goto label; label: v = v.; v = ; virtualinvoke v.(v, v); label: virtualinvoke v.(); v = ; virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } public void handleEnd(org.apache.qpid.proton.amqp.transport.End, org.apache.qpid.proton.amqp.Binary, java.lang.Integer) { org.apache.qpid.proton.engine.impl.TransportImpl v; java.lang.Integer v; org.apache.qpid.proton.amqp.transport.End v; org.apache.qpid.proton.amqp.transport.ErrorCondition v, v; org.apache.qpid.proton.engine.Event$Type v; org.apache.qpid.proton.engine.EndpointState v; java.util.Map v, v; java.lang.Object v; org.apache.qpid.proton.amqp.Binary 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.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.End; v := @parameter: org.apache.qpid.proton.amqp.Binary; v := @parameter: java.lang.Integer; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = v.; interfaceinvoke v.(v); virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); v = ; virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = ; virtualinvoke v.(v, v); label: return; } public void handleClose(org.apache.qpid.proton.amqp.transport.Close, org.apache.qpid.proton.amqp.Binary, java.lang.Integer) { org.apache.qpid.proton.engine.impl.TransportImpl v; java.lang.Integer v; org.apache.qpid.proton.amqp.transport.Close v; org.apache.qpid.proton.amqp.transport.ErrorCondition v, v, v; org.apache.qpid.proton.engine.Event$Type v; org.apache.qpid.proton.engine.EndpointState v, v; org.apache.qpid.proton.amqp.Binary v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v, v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.amqp.transport.Close; v := @parameter: org.apache.qpid.proton.amqp.Binary; v := @parameter: java.lang.Integer; v. = 1; v. = 0; v = ; virtualinvoke v.(v); v = v.; if v == null goto label; v = v.; v = ; virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = ; v = v.; virtualinvoke v.(v, v); label: return; } public boolean handleFrame(org.apache.qpid.proton.framing.TransportFrame) { java.lang.IllegalStateException v; org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.Ref v; java.lang.Integer v; org.apache.qpid.proton.framing.TransportFrame v; int v; java.lang.Object v; java.lang.String v, v; org.apache.qpid.proton.amqp.Binary v; org.apache.qpid.proton.amqp.transport.FrameBody v; boolean v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.framing.TransportFrame; v = virtualinvoke v.(); if v != 0 goto label; v = new java.lang.IllegalStateException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Transport cannot accept frame: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = ; virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); if v == null goto label; interfaceinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v, v); v = v.; return v; } void put(org.apache.qpid.proton.engine.Event$Type, java.lang.Object) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.Event$Type v; java.lang.Object v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.Event$Type; v := @parameter: java.lang.Object; v = v.; if v == null goto label; v = v.; virtualinvoke v.(v, v); label: return; } private void maybePostClosed() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.Event$Type v; boolean v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v == 0 goto label; v = v.; if v == 0 goto label; v = ; virtualinvoke v.(v, v); label: return; } public void closed(org.apache.qpid.proton.engine.TransportException) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.TransportException v; org.apache.qpid.proton.amqp.Symbol v, v; java.lang.String v, v; boolean v, v, v, v, v, v; org.apache.qpid.proton.amqp.transport.ErrorCondition v, v; org.apache.qpid.proton.engine.Event$Type v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.TransportException; v = v.; if v == 0 goto label; if v == null goto label; label: v = v.; if v != 0 goto label; v = v instanceof org.apache.qpid.proton.engine.TransportDecodeException; if v == 0 goto label; v = new org.apache.qpid.proton.amqp.transport.ErrorCondition; v = ; v = virtualinvoke v.(); specialinvoke v.(org.apache.qpid.proton.amqp.Symbol,java.lang.String)>(v, v); virtualinvoke v.(v); goto label; label: if v != null goto label; v = "connection aborted"; goto label; label: v = virtualinvoke v.(); label: v = new org.apache.qpid.proton.amqp.transport.ErrorCondition; v = ; specialinvoke v.(org.apache.qpid.proton.amqp.Symbol,java.lang.String)>(v, v); virtualinvoke v.(v); label: v. = 1; label: v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v = ; virtualinvoke v.(v, v); v. = 1; label: v = v.; if v != 0 goto label; v = ; virtualinvoke v.(v, v); v. = 1; specialinvoke v.(); label: return; } public boolean isHandlingFrames() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.EndpointState v, v; org.apache.qpid.proton.engine.impl.ConnectionImpl v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; if v != null goto label; v = virtualinvoke v.(); v = ; if v != v goto label; label: v = 1; goto label; label: v = 0; label: return v; } public org.apache.qpid.proton.engine.impl.ProtocolTracer getProtocolTracer() { org.apache.qpid.proton.engine.impl.Ref v; org.apache.qpid.proton.engine.impl.TransportImpl v; java.lang.Object v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; v = virtualinvoke v.(); return v; } public void setProtocolTracer(org.apache.qpid.proton.engine.impl.ProtocolTracer) { org.apache.qpid.proton.engine.impl.Ref v; org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.ProtocolTracer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.ProtocolTracer; v = v.; virtualinvoke v.(v); return; } public java.nio.ByteBuffer getInputBuffer() { org.apache.qpid.proton.engine.impl.TransportImpl v; java.nio.ByteBuffer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = virtualinvoke v.(); return v; } public org.apache.qpid.proton.engine.TransportResult processInput() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.TransportException v; org.apache.qpid.proton.engine.TransportResult v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; label: virtualinvoke v.(); v = staticinvoke (); label: return v; label: v := @caughtexception; v = staticinvoke (v); return v; catch org.apache.qpid.proton.engine.TransportException from label to label with label; } public java.nio.ByteBuffer getOutputBuffer() { org.apache.qpid.proton.engine.impl.TransportImpl v; java.nio.ByteBuffer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; virtualinvoke v.(); v = virtualinvoke v.(); return v; } public void outputConsumed() { org.apache.qpid.proton.engine.impl.TransportImpl v; int v; org.apache.qpid.proton.engine.impl.TransportOutput v; java.nio.ByteBuffer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); return; } public int capacity() { int v; org.apache.qpid.proton.engine.impl.TransportInput v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; specialinvoke v.(); v = v.; v = interfaceinvoke v.(); return v; } public java.nio.ByteBuffer tail() { org.apache.qpid.proton.engine.impl.TransportInput v; org.apache.qpid.proton.engine.impl.TransportImpl v; java.nio.ByteBuffer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; specialinvoke v.(); v = v.; v = interfaceinvoke v.(); return v; } public void process() throws org.apache.qpid.proton.engine.TransportException { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.TransportException v; long v, v; int v, v, v; org.apache.qpid.proton.engine.impl.TransportInput v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v. = 1; label: specialinvoke v.(); v = v.; v = interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; v = v.; v = interfaceinvoke v.(); v = v - v; v = v + v; v. = v; label: goto label; label: v := @caughtexception; v. = 1; throw v; label: return; catch org.apache.qpid.proton.engine.TransportException from label to label with label; } public void close_tail() { org.apache.qpid.proton.engine.impl.TransportInput v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; specialinvoke v.(); v = v.; interfaceinvoke v.(); return; } public int pending() { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.TransportOutput v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; specialinvoke v.(); v = v.; v = interfaceinvoke v.(); return v; } public java.nio.ByteBuffer head() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.TransportOutput v; java.nio.ByteBuffer v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; specialinvoke v.(); v = v.; v = interfaceinvoke v.(); return v; } public void pop(int) { org.apache.qpid.proton.engine.impl.TransportImpl v; long v, v; org.apache.qpid.proton.engine.Event$Type v; int v, v; org.apache.qpid.proton.engine.impl.TransportOutput v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; specialinvoke v.(); v = v.; interfaceinvoke v.(v); v = v.; v = v + v; v. = v; v = virtualinvoke v.(); if v >= 0 goto label; v = v.; if v != 0 goto label; v = ; virtualinvoke v.(v, v); v. = 1; specialinvoke v.(); label: return; } public void setIdleTimeout(int) { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; v. = v; return; } public int getIdleTimeout() { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public int getRemoteIdleTimeout() { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public long tick(long) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.amqp.transport.Close v; byte v, v, v, v, v, v, v, v; org.apache.qpid.proton.engine.impl.ConnectionImpl v, v, v, v; boolean v, v, v, v; org.apache.qpid.proton.amqp.transport.ErrorCondition v; org.apache.qpid.proton.engine.EndpointState v, v, v; org.apache.qpid.proton.amqp.transport.Open v; long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.qpid.proton.amqp.Symbol v; int v, v, v, v, v, v, v, v, v, v; org.apache.qpid.proton.engine.impl.SaslImpl v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: long; v = 0L; v = v.; if v <= 0 goto label; v = v.; v = v cmp 0L; if v == 0 goto label; v = v.; v = v.; v = v cmp v; if v == 0 goto label; label: v = v.; v = specialinvoke v.(v, v); v. = v; v = v.; v. = v; goto label; label: v = v.; v = v - v; v = v cmp 0L; if v > 0 goto label; v = v.; v = specialinvoke v.(v, v); v. = v; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = ; if v == v goto label; v = new org.apache.qpid.proton.amqp.transport.ErrorCondition; v = staticinvoke ("amqp:resource-limit-exceeded"); specialinvoke v.(org.apache.qpid.proton.amqp.Symbol,java.lang.String)>(v, "local-idle-timeout expired"); v = v.; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; if v != 0 goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(); label: v = new org.apache.qpid.proton.amqp.transport.Open; specialinvoke v.()>(); v. = 1; virtualinvoke v.(0, v, null, null); label: v = v.; if v != 0 goto label; v = new org.apache.qpid.proton.amqp.transport.Close; specialinvoke v.()>(); virtualinvoke v.(v); v. = 1; virtualinvoke v.(0, v, null, null); label: virtualinvoke v.(); label: v = v.; label: v = v.; if v == 0 goto label; v = v.; if v != 0 goto label; v = v.; v = v cmp 0L; if v == 0 goto label; v = v.; v = v.; v = v cmp v; if v == 0 goto label; label: v = v.; v = v / 2; v = specialinvoke v.(v, v); v. = v; v = v.; v. = v; goto label; label: v = v.; v = v - v; v = v cmp 0L; if v > 0 goto label; v = v.; v = v / 2; v = specialinvoke v.(v, v); v. = v; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(0, null, null, null); v = v.; v = virtualinvoke v.(); v = v + v; v. = v; label: v = v cmp 0L; if v != 0 goto label; v = v.; goto label; label: v = v.; v = v.; v = v - v; v = v cmp 0L; if v > 0 goto label; v = v.; goto label; label: v = v.; label: return v; } private long computeDeadline(long, long) { org.apache.qpid.proton.engine.impl.TransportImpl v; byte v; long v, v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: long; v := @parameter: long; v = v + v; v = v cmp 0L; if v == 0 goto label; v = v; goto label; label: v = 1L; label: return v; } public long getFramesOutput() { org.apache.qpid.proton.engine.impl.FrameWriter v; org.apache.qpid.proton.engine.impl.TransportImpl v; long v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; v = virtualinvoke v.(); return v; } public long getFramesInput() { org.apache.qpid.proton.engine.impl.FrameParser v; org.apache.qpid.proton.engine.impl.TransportImpl v; long v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; v = virtualinvoke v.(); return v; } public void close_head() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.TransportOutput v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; interfaceinvoke v.(); return; } public boolean isClosed() { org.apache.qpid.proton.engine.impl.TransportImpl v; int v, v, v, v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = virtualinvoke v.(); v = virtualinvoke v.(); v = (int) -1; if v != v goto label; v = (int) -1; if v != v goto label; v = 1; goto label; label: v = 0; label: return v; } public java.lang.String toString() { org.apache.qpid.proton.engine.impl.TransportImpl v; java.lang.String v, v; org.apache.qpid.proton.engine.impl.ConnectionImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("TransportImpl [_connectionEndpoint=\u, \u]"); return v; } public void setFrameHandler(org.apache.qpid.proton.engine.impl.FrameHandler) { org.apache.qpid.proton.engine.impl.FrameHandler v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.FrameHandler; v. = v; return; } void log(java.lang.String, org.apache.qpid.proton.framing.TransportFrame) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.framing.TransportFrame v; int v; java.lang.String v; org.apache.qpid.proton.amqp.Binary v; org.apache.qpid.proton.amqp.transport.FrameBody v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: java.lang.String; v := @parameter: org.apache.qpid.proton.framing.TransportFrame; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v, v, v); label: return; } void log(java.lang.String, org.apache.qpid.proton.amqp.security.SaslFrameBody) { org.apache.qpid.proton.engine.impl.TransportImpl v; java.lang.String v; org.apache.qpid.proton.amqp.security.SaslFrameBody v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: java.lang.String; v := @parameter: org.apache.qpid.proton.amqp.security.SaslFrameBody; v = virtualinvoke v.(); if v == 0 goto label; specialinvoke v.(v, 0, v, null); label: return; } void log(java.lang.String, java.lang.String) { org.apache.qpid.proton.engine.impl.TransportImpl v; java.lang.String v, v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = virtualinvoke v.(); if v == 0 goto label; specialinvoke v.(v, 0, v, null); label: return; } private void outputMessage(java.lang.String, int, java.lang.Object, org.apache.qpid.proton.amqp.Binary) { org.apache.qpid.proton.engine.impl.TransportImpl v; int v, v, v, v; java.lang.String v, v, v; org.apache.qpid.proton.amqp.Binary v; java.io.PrintStream v; java.lang.Object v; java.lang.StringBuilder v, v, v, v, v, v, v, v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: java.lang.String; v := @parameter: int; v := @parameter: java.lang.Object; v := @parameter: org.apache.qpid.proton.amqp.Binary; v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.("["); v = staticinvoke (v); v = virtualinvoke v.(v); v = virtualinvoke v.(":"); v = virtualinvoke v.(v); virtualinvoke v.("] "); v = virtualinvoke v.(v); v = virtualinvoke v.(" "); virtualinvoke v.(v); if v == null goto label; v = virtualinvoke v.(" ("); v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(") "); v = ; v = staticinvoke (v, v, 1); virtualinvoke v.(v); label: v = ; v = virtualinvoke v.(); virtualinvoke v.(v); return; } boolean isFrameTracingEnabled() { org.apache.qpid.proton.engine.impl.TransportImpl v; int v, v; org.apache.qpid.proton.engine.impl.Ref v; java.lang.Object v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; v = v & 2; if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == null goto label; label: v = 1; goto label; label: v = 0; label: return v; } boolean isTraceFramesEnabled() { org.apache.qpid.proton.engine.impl.TransportImpl v; int v, v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; v = v & 2; if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } void localOpen() { org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; return; } void localClose() { org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; return; } public void setSelectable(org.apache.qpid.proton.reactor.Selectable) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.reactor.Selectable v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.reactor.Selectable; v. = v; return; } public org.apache.qpid.proton.reactor.Selectable getSelectable() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.reactor.Selectable v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public void setReactor(org.apache.qpid.proton.reactor.Reactor) { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.reactor.Reactor v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.reactor.Reactor; v. = v; return; } public org.apache.qpid.proton.reactor.Reactor getReactor() { org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.reactor.Reactor v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public void setEmitFlowEventOnSend(boolean) { org.apache.qpid.proton.engine.impl.TransportImpl v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: boolean; v. = v; return; } public boolean isEmitFlowEventOnSend() { org.apache.qpid.proton.engine.impl.TransportImpl v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public void setUseReadOnlyOutputBuffer(boolean) { org.apache.qpid.proton.engine.impl.TransportImpl v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: boolean; v. = v; return; } public boolean isUseReadOnlyOutputBuffer() { org.apache.qpid.proton.engine.impl.TransportImpl v; boolean v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } public void addTransportLayer(org.apache.qpid.proton.engine.impl.TransportLayer) { java.lang.IllegalStateException v; org.apache.qpid.proton.engine.impl.TransportImpl v; org.apache.qpid.proton.engine.impl.TransportLayer v; java.util.ArrayList v; java.util.List v, v, v; org.apache.qpid.proton.engine.impl.TransportInput v; org.apache.qpid.proton.engine.impl.TransportOutput v; org.apache.qpid.proton.engine.impl.TransportWrapper v; boolean v, v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: org.apache.qpid.proton.engine.impl.TransportLayer; v = v.; if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Additional layer can\'t be added after transport has started processing"); throw v; label: v = v.; if v != null goto label; v = new java.util.ArrayList; specialinvoke v.()>(); v. = v; label: v = v.; v = interfaceinvoke v.(v); if v != 0 goto label; specialinvoke v.(); v = v.; v = v.; v = interfaceinvoke v.(v, v); v. = v; v. = v; v = v.; interfaceinvoke v.(v); label: return; } public void setOutboundFrameSizeLimit(int) { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v := @parameter: int; v. = v; return; } public int getOutboundFrameSizeLimit() { int v; org.apache.qpid.proton.engine.impl.TransportImpl v; v := @this: org.apache.qpid.proton.engine.impl.TransportImpl; v = v.; return v; } static void () { int v, v; java.lang.Integer v, v; boolean v; v = staticinvoke ("proton.transport_buffer_release_threshold", 2097152); v = virtualinvoke v.(); = v; v = staticinvoke ("PN_TRACE_FRM"); = v; v = staticinvoke ("proton.trace_frame_payload_length", 1024); v = virtualinvoke v.(); = v; = "<-"; = "->"; return; } }