public final class org.apache.activemq.protobuf.CodedInputStream extends java.io.FilterInputStream
{
private int lastTag;
private int limit;
private int pos;
private org.apache.activemq.protobuf.BufferInputStream bis;
public void <init>(java.io.InputStream)
{
org.apache.activemq.protobuf.CodedInputStream v;
java.lang.Class v;
java.io.InputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v := @parameter: java.io.InputStream;
specialinvoke v.<java.io.FilterInputStream: void <init>(java.io.InputStream)>(v);
v.<org.apache.activemq.protobuf.CodedInputStream: int lastTag> = 0;
v.<org.apache.activemq.protobuf.CodedInputStream: int limit> = 2147483647;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
if v != class "Lorg/apache/activemq/protobuf/BufferInputStream;" goto label;
v.<org.apache.activemq.protobuf.CodedInputStream: org.apache.activemq.protobuf.BufferInputStream bis> = v;
label:
return;
}
public void <init>(org.apache.activemq.protobuf.Buffer)
{
org.apache.activemq.protobuf.CodedInputStream v;
int v;
org.apache.activemq.protobuf.Buffer v;
org.apache.activemq.protobuf.BufferInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v := @parameter: org.apache.activemq.protobuf.Buffer;
v = new org.apache.activemq.protobuf.BufferInputStream;
specialinvoke v.<org.apache.activemq.protobuf.BufferInputStream: void <init>(org.apache.activemq.protobuf.Buffer)>(v);
specialinvoke v.<org.apache.activemq.protobuf.CodedInputStream: void <init>(java.io.InputStream)>(v);
v = v.<org.apache.activemq.protobuf.Buffer: int length>;
v.<org.apache.activemq.protobuf.CodedInputStream: int limit> = v;
return;
}
public void <init>(byte[])
{
org.apache.activemq.protobuf.CodedInputStream v;
byte[] v;
int v;
org.apache.activemq.protobuf.BufferInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v := @parameter: byte[];
v = new org.apache.activemq.protobuf.BufferInputStream;
specialinvoke v.<org.apache.activemq.protobuf.BufferInputStream: void <init>(byte[])>(v);
specialinvoke v.<org.apache.activemq.protobuf.CodedInputStream: void <init>(java.io.InputStream)>(v);
v = lengthof v;
v.<org.apache.activemq.protobuf.CodedInputStream: int limit> = v;
return;
}
public int readTag() throws java.io.IOException
{
java.io.EOFException v;
org.apache.activemq.protobuf.CodedInputStream v;
int v, v, v, v, v;
org.apache.activemq.protobuf.InvalidProtocolBufferException v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = v.<org.apache.activemq.protobuf.CodedInputStream: int pos>;
v = v.<org.apache.activemq.protobuf.CodedInputStream: int limit>;
if v < v goto label;
v.<org.apache.activemq.protobuf.CodedInputStream: int lastTag> = 0;
return 0;
label:
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawVarint32()>();
v.<org.apache.activemq.protobuf.CodedInputStream: int lastTag> = v;
v = v.<org.apache.activemq.protobuf.CodedInputStream: int lastTag>;
if v != 0 goto label;
v = staticinvoke <org.apache.activemq.protobuf.InvalidProtocolBufferException: org.apache.activemq.protobuf.InvalidProtocolBufferException invalidTag()>();
throw v;
label:
v = v.<org.apache.activemq.protobuf.CodedInputStream: int lastTag>;
label:
return v;
label:
v := @caughtexception;
v.<org.apache.activemq.protobuf.CodedInputStream: int lastTag> = 0;
return 0;
catch java.io.EOFException from label to label with label;
}
public void checkLastTagWas(int) throws org.apache.activemq.protobuf.InvalidProtocolBufferException
{
org.apache.activemq.protobuf.CodedInputStream v;
int v, v;
org.apache.activemq.protobuf.InvalidProtocolBufferException v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v := @parameter: int;
v = v.<org.apache.activemq.protobuf.CodedInputStream: int lastTag>;
if v == v goto label;
v = staticinvoke <org.apache.activemq.protobuf.InvalidProtocolBufferException: org.apache.activemq.protobuf.InvalidProtocolBufferException invalidEndTag()>();
throw v;
label:
return;
}
public boolean skipField(int) throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
int v, v, v, v, v;
org.apache.activemq.protobuf.InvalidProtocolBufferException v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v := @parameter: int;
v = staticinvoke <org.apache.activemq.protobuf.WireFormat: int getTagWireType(int)>(v);
tableswitch(v)
{
case 0: goto label;
case 1: goto label;
case 2: goto label;
case 3: goto label;
case 4: goto label;
case 5: goto label;
default: goto label;
};
label:
virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readInt32()>();
return 1;
label:
virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: long readRawLittleEndian64()>();
return 1;
label:
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawVarint32()>();
virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: void skipRawBytes(int)>(v);
return 1;
label:
virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: void skipMessage()>();
v = staticinvoke <org.apache.activemq.protobuf.WireFormat: int getTagFieldNumber(int)>(v);
v = staticinvoke <org.apache.activemq.protobuf.WireFormat: int makeTag(int,int)>(v, 4);
virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: void checkLastTagWas(int)>(v);
return 1;
label:
return 0;
label:
virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawLittleEndian32()>();
return 1;
label:
v = staticinvoke <org.apache.activemq.protobuf.InvalidProtocolBufferException: org.apache.activemq.protobuf.InvalidProtocolBufferException invalidWireType()>();
throw v;
}
public void skipMessage() throws java.io.IOException
{
int v;
org.apache.activemq.protobuf.CodedInputStream v;
boolean v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
label:
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readTag()>();
if v == 0 goto label;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: boolean skipField(int)>(v);
if v != 0 goto label;
label:
return;
}
public double readDouble() throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
long v;
double v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: long readRawLittleEndian64()>();
v = staticinvoke <java.lang.Double: double longBitsToDouble(long)>(v);
return v;
}
public float readFloat() throws java.io.IOException
{
int v;
org.apache.activemq.protobuf.CodedInputStream v;
float v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawLittleEndian32()>();
v = staticinvoke <java.lang.Float: float intBitsToFloat(int)>(v);
return v;
}
public long readUInt64() throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
long v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: long readRawVarint64()>();
return v;
}
public long readInt64() throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
long v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: long readRawVarint64()>();
return v;
}
public int readInt32() throws java.io.IOException
{
int v;
org.apache.activemq.protobuf.CodedInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawVarint32()>();
return v;
}
public long readFixed64() throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
long v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: long readRawLittleEndian64()>();
return v;
}
public int readFixed32() throws java.io.IOException
{
int v;
org.apache.activemq.protobuf.CodedInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawLittleEndian32()>();
return v;
}
public boolean readBool() throws java.io.IOException
{
int v;
org.apache.activemq.protobuf.CodedInputStream v;
boolean v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawVarint32()>();
if v == 0 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
public java.lang.String readString() throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
byte[] v;
int v, v, v;
org.apache.activemq.protobuf.Buffer v;
java.lang.String v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawVarint32()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: org.apache.activemq.protobuf.Buffer readRawBytes(int)>(v);
v = new java.lang.String;
v = v.<org.apache.activemq.protobuf.Buffer: byte[] data>;
v = v.<org.apache.activemq.protobuf.Buffer: int offset>;
v = v.<org.apache.activemq.protobuf.Buffer: int length>;
specialinvoke v.<java.lang.String: void <init>(byte[],int,int,java.lang.String)>(v, v, v, "UTF-8");
return v;
}
public org.apache.activemq.protobuf.Buffer readBytes() throws java.io.IOException
{
int v;
org.apache.activemq.protobuf.Buffer v;
org.apache.activemq.protobuf.CodedInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawVarint32()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: org.apache.activemq.protobuf.Buffer readRawBytes(int)>(v);
return v;
}
public int readUInt32() throws java.io.IOException
{
int v;
org.apache.activemq.protobuf.CodedInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawVarint32()>();
return v;
}
public int readEnum() throws java.io.IOException
{
int v;
org.apache.activemq.protobuf.CodedInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawVarint32()>();
return v;
}
public int readSFixed32() throws java.io.IOException
{
int v;
org.apache.activemq.protobuf.CodedInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawLittleEndian32()>();
return v;
}
public long readSFixed64() throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
long v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: long readRawLittleEndian64()>();
return v;
}
public int readSInt32() throws java.io.IOException
{
int v, v;
org.apache.activemq.protobuf.CodedInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: int readRawVarint32()>();
v = staticinvoke <org.apache.activemq.protobuf.CodedInputStream: int decodeZigZag32(int)>(v);
return v;
}
public long readSInt64() throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
long v, v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: long readRawVarint64()>();
v = staticinvoke <org.apache.activemq.protobuf.CodedInputStream: long decodeZigZag64(long)>(v);
return v;
}
public int readRawVarint32() throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
byte v, v, v, v, v, v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.protobuf.InvalidProtocolBufferException v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
if v < 0 goto label;
return v;
label:
v = v & 127;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
if v < 0 goto label;
v = v << 7;
v = v | v;
goto label;
label:
v = v & 127;
v = v << 7;
v = v | v;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
if v < 0 goto label;
v = v << 14;
v = v | v;
goto label;
label:
v = v & 127;
v = v << 14;
v = v | v;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
if v < 0 goto label;
v = v << 21;
v = v | v;
goto label;
label:
v = v & 127;
v = v << 21;
v = v | v;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = v << 28;
v = v | v;
if v >= 0 goto label;
v = 0;
label:
if v >= 5 goto label;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
if v < 0 goto label;
return v;
label:
v = v + 1;
goto label;
label:
v = staticinvoke <org.apache.activemq.protobuf.InvalidProtocolBufferException: org.apache.activemq.protobuf.InvalidProtocolBufferException malformedVarint()>();
throw v;
label:
return v;
}
public long readRawVarint64() throws java.io.IOException
{
long v, v;
org.apache.activemq.protobuf.CodedInputStream v;
short v;
byte v, v;
int v;
org.apache.activemq.protobuf.InvalidProtocolBufferException v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = 0;
v = 0L;
label:
if v >= 64 goto label;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = v & 127;
v = v << v;
v = v | v;
v = v & 128;
if v != 0 goto label;
return v;
label:
v = v + 7;
goto label;
label:
v = staticinvoke <org.apache.activemq.protobuf.InvalidProtocolBufferException: org.apache.activemq.protobuf.InvalidProtocolBufferException malformedVarint()>();
throw v;
}
public int readRawLittleEndian32() throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
short v, v, v, v;
byte v, v, v, v;
int v, v, v, v, v, v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = v & 255;
v = v & 255;
v = v << 8;
v = v | v;
v = v & 255;
v = v << 16;
v = v | v;
v = v & 255;
v = v << 24;
v = v | v;
return v;
}
public long readRawLittleEndian64() throws java.io.IOException
{
long v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.protobuf.CodedInputStream v;
byte v, v, v, v, v, v, v, v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = virtualinvoke v.<org.apache.activemq.protobuf.CodedInputStream: byte readRawByte()>();
v = v & 255L;
v = v & 255L;
v = v << 8;
v = v | v;
v = v & 255L;
v = v << 16;
v = v | v;
v = v & 255L;
v = v << 24;
v = v | v;
v = v & 255L;
v = v << 32;
v = v | v;
v = v & 255L;
v = v << 40;
v = v | v;
v = v & 255L;
v = v << 48;
v = v | v;
v = v & 255L;
v = v << 56;
v = v | v;
return v;
}
public static int decodeZigZag32(int)
{
int v, v, v, v, v;
v := @parameter: int;
v = v >>> 1;
v = v & 1;
v = neg v;
v = v ^ v;
return v;
}
public static long decodeZigZag64(long)
{
long v, v, v, v, v;
v := @parameter: long;
v = v >>> 1;
v = v & 1L;
v = neg v;
v = v ^ v;
return v;
}
public byte readRawByte() throws java.io.IOException
{
java.io.EOFException v, v;
org.apache.activemq.protobuf.CodedInputStream v;
int v, v, v, v, v, v;
java.io.InputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v = v.<org.apache.activemq.protobuf.CodedInputStream: int pos>;
v = v.<org.apache.activemq.protobuf.CodedInputStream: int limit>;
if v < v goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>()>();
throw v;
label:
v = v.<org.apache.activemq.protobuf.CodedInputStream: java.io.InputStream in>;
v = virtualinvoke v.<java.io.InputStream: int read()>();
if v >= 0 goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>()>();
throw v;
label:
v = v.<org.apache.activemq.protobuf.CodedInputStream: int pos>;
v = v + 1;
v.<org.apache.activemq.protobuf.CodedInputStream: int pos> = v;
v = v & 255;
return v;
}
public org.apache.activemq.protobuf.Buffer readRawBytes(int) throws java.io.IOException
{
byte[] v, v;
org.apache.activemq.protobuf.Buffer v, v, v;
org.apache.activemq.protobuf.CodedInputStream v;
int v, v, v, v, v, v, v, v, v, v, v, v, v;
org.apache.activemq.protobuf.BufferInputStream v, v;
java.io.EOFException v, v, v;
java.io.InputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v := @parameter: int;
if v != 0 goto label;
v = new org.apache.activemq.protobuf.Buffer;
v = newarray (byte)[0];
specialinvoke v.<org.apache.activemq.protobuf.Buffer: void <init>(byte[])>(v);
return v;
label:
v = v.<org.apache.activemq.protobuf.CodedInputStream: int pos>;
v = v + v;
v = v.<org.apache.activemq.protobuf.CodedInputStream: int limit>;
if v <= v goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>()>();
throw v;
label:
v = v.<org.apache.activemq.protobuf.CodedInputStream: org.apache.activemq.protobuf.BufferInputStream bis>;
if v == null goto label;
v = v.<org.apache.activemq.protobuf.CodedInputStream: org.apache.activemq.protobuf.BufferInputStream bis>;
v = virtualinvoke v.<org.apache.activemq.protobuf.BufferInputStream: org.apache.activemq.protobuf.Buffer readBuffer(int)>(v);
if v == null goto label;
v = virtualinvoke v.<org.apache.activemq.protobuf.Buffer: int getLength()>();
if v >= v goto label;
label:
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>()>();
throw v;
label:
v = v.<org.apache.activemq.protobuf.CodedInputStream: int pos>;
v = virtualinvoke v.<org.apache.activemq.protobuf.Buffer: int getLength()>();
v = v + v;
v.<org.apache.activemq.protobuf.CodedInputStream: int pos> = v;
return v;
label:
v = newarray (byte)[v];
v = 0;
label:
if v >= v goto label;
v = v.<org.apache.activemq.protobuf.CodedInputStream: java.io.InputStream in>;
v = v - v;
v = virtualinvoke v.<java.io.InputStream: int read(byte[],int,int)>(v, v, v);
if v >= 0 goto label;
v = new java.io.EOFException;
specialinvoke v.<java.io.EOFException: void <init>()>();
throw v;
label:
v = v.<org.apache.activemq.protobuf.CodedInputStream: int pos>;
v = v + v;
v.<org.apache.activemq.protobuf.CodedInputStream: int pos> = v;
v = v + v;
goto label;
label:
v = new org.apache.activemq.protobuf.Buffer;
specialinvoke v.<org.apache.activemq.protobuf.Buffer: void <init>(byte[])>(v);
return v;
}
public void skipRawBytes(int) throws java.io.IOException
{
org.apache.activemq.protobuf.CodedInputStream v;
int v, v, v;
long v;
java.io.InputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v := @parameter: int;
v = 0;
label:
if v >= v goto label;
v = v.<org.apache.activemq.protobuf.CodedInputStream: java.io.InputStream in>;
v = v - v;
v = virtualinvoke v.<java.io.InputStream: long skip(long)>(v);
v = v + v;
goto label;
label:
return;
}
public int pushLimit(int)
{
org.apache.activemq.protobuf.CodedInputStream v;
int v, v, v, v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v := @parameter: int;
v = v.<org.apache.activemq.protobuf.CodedInputStream: int limit>;
v = v.<org.apache.activemq.protobuf.CodedInputStream: int pos>;
v = v + v;
v.<org.apache.activemq.protobuf.CodedInputStream: int limit> = v;
return v;
}
public void popLimit(int)
{
int v;
org.apache.activemq.protobuf.CodedInputStream v;
v := @this: org.apache.activemq.protobuf.CodedInputStream;
v := @parameter: int;
v.<org.apache.activemq.protobuf.CodedInputStream: int limit> = v;
return;
}
}