public class org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor extends java.lang.Object implements org.apache.kafkaesqueesqueesque.common.protocol.Readable, org.apache.kafkaesqueesqueesque.common.protocol.Writable
{
private final java.nio.ByteBuffer buf;
public void <init>(java.nio.ByteBuffer)
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: java.nio.ByteBuffer;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf> = v;
return;
}
public byte readByte()
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
byte v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
v = virtualinvoke v.<java.nio.ByteBuffer: byte get()>();
return v;
}
public short readShort()
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
short v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
v = virtualinvoke v.<java.nio.ByteBuffer: short getShort()>();
return v;
}
public int readInt()
{
int v;
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
v = virtualinvoke v.<java.nio.ByteBuffer: int getInt()>();
return v;
}
public long readLong()
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
long v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
v = virtualinvoke v.<java.nio.ByteBuffer: long getLong()>();
return v;
}
public double readDouble()
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v;
double v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: double readDouble(java.nio.ByteBuffer)>(v);
return v;
}
public void readArray(byte[])
{
byte[] v;
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: byte[];
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer get(byte[])>(v);
return;
}
public int readUnsignedVarint()
{
int v;
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
v = staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: int readUnsignedVarint(java.nio.ByteBuffer)>(v);
return v;
}
public java.nio.ByteBuffer readByteBuffer(int)
{
java.nio.ByteBuffer v, v, v, v;
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
int v, v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: int;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
v = virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer slice()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer limit(int)>(v);
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v + v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.Buffer position(int)>(v);
return v;
}
public void writeByte(byte)
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
byte v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: byte;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer put(byte)>(v);
return;
}
public void writeShort(short)
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
short v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: short;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putShort(short)>(v);
return;
}
public void writeInt(int)
{
int v;
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: int;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putInt(int)>(v);
return;
}
public void writeLong(long)
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
long v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: long;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer putLong(long)>(v);
return;
}
public void writeDouble(double)
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v;
double v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: double;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: void writeDouble(double,java.nio.ByteBuffer)>(v, v);
return;
}
public void writeByteArray(byte[])
{
byte[] v;
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: byte[];
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer put(byte[])>(v);
return;
}
public void writeUnsignedVarint(int)
{
int v;
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: int;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
staticinvoke <org.apache.kafkaesqueesqueesque.common.utils.ByteUtils: void writeUnsignedVarint(int,java.nio.ByteBuffer)>(v, v);
return;
}
public void writeByteBuffer(java.nio.ByteBuffer)
{
org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor v;
java.nio.ByteBuffer v, v;
v := @this: org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor;
v := @parameter: java.nio.ByteBuffer;
v = v.<org.apache.kafkaesqueesqueesque.common.protocol.ByteBufferAccessor: java.nio.ByteBuffer buf>;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer put(java.nio.ByteBuffer)>(v);
return;
}
}