public final class org.apache.kafkaesqueesque.common.utils.Utils extends java.lang.Object
{
private static final java.util.regex.Pattern HOST_PORT_PATTERN;
private static final java.util.regex.Pattern VALID_HOST_CHARACTERS;
private static final java.text.DecimalFormat TWO_DIGIT_FORMAT;
private static final java.lang.String[] BYTE_SCALE_SUFFIXES;
public static final java.lang.String NL;
private static final org.slf4j.Logger log;
private void <init>()
{
org.apache.kafkaesqueesque.common.utils.Utils v;
v := @this: org.apache.kafkaesqueesque.common.utils.Utils;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public static java.util.List sorted(java.util.Collection)
{
java.util.List v;
java.util.ArrayList v;
java.util.Collection v;
v := @parameter: java.util.Collection;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>(java.util.Collection)>(v);
staticinvoke <java.util.Collections: void sort(java.util.List)>(v);
v = staticinvoke <java.util.Collections: java.util.List unmodifiableList(java.util.List)>(v);
return v;
}
public static java.lang.String utf8(byte[])
{
byte[] v;
java.lang.String v;
java.nio.charset.Charset v;
v := @parameter: byte[];
v = new java.lang.String;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
return v;
}
public static java.lang.String utf8(java.nio.ByteBuffer, int)
{
int v;
java.lang.String v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: int;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.String utf8(java.nio.ByteBuffer,int,int)>(v, 0, v);
return v;
}
public static java.lang.String utf8(java.nio.ByteBuffer)
{
int v;
java.lang.String v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.String utf8(java.nio.ByteBuffer,int)>(v, v);
return v;
}
public static java.lang.String utf8(java.nio.ByteBuffer, int, int)
{
byte[] v, v;
java.nio.ByteBuffer v;
java.nio.charset.Charset v;
int v, v, v, v, v, v;
java.lang.String v, v;
boolean v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: int;
v := @parameter: int;
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasArray()>();
if v == 0 goto label;
v = new java.lang.String;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int arrayOffset()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v + v;
v = v + v;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],int,int,java.nio.charset.Charset)>(v, v, v, v);
return v;
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: byte[] toArray(java.nio.ByteBuffer,int,int)>(v, v, v);
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.String utf8(byte[])>(v);
return v;
}
public static byte[] utf8(java.lang.String)
{
byte[] v;
java.lang.String v;
java.nio.charset.Charset v;
v := @parameter: java.lang.String;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes(java.nio.charset.Charset)>(v);
return v;
}
public static int abs(int)
{
int v, v;
v := @parameter: int;
if v != -2147483648 goto label;
v = 0;
goto label;
label:
v = staticinvoke <java.lang.Math: int abs(int)>(v);
label:
return v;
}
public static transient long min(long, long[])
{
long[] v;
byte v;
int v, v;
long v, v, v;
v := @parameter: long;
v := @parameter: long[];
v = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v cmp v;
if v >= 0 goto label;
v = v;
label:
v = v + 1;
goto label;
label:
return v;
}
public static transient long max(long, long[])
{
long[] v;
byte v;
int v, v;
long v, v, v;
v := @parameter: long;
v := @parameter: long[];
v = v;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = v cmp v;
if v <= 0 goto label;
v = v;
label:
v = v + 1;
goto label;
label:
return v;
}
public static short min(short, short)
{
int v;
short v, v;
v := @parameter: short;
v := @parameter: short;
v = staticinvoke <java.lang.Math: int min(int,int)>(v, v);
return v;
}
public static int utf8Length(java.lang.CharSequence)
{
java.lang.CharSequence v;
int v, v, v;
char v;
boolean v;
v := @parameter: java.lang.CharSequence;
v = 0;
v = 0;
v = interfaceinvoke v.<java.lang.CharSequence: int length()>();
label:
if v >= v goto label;
v = interfaceinvoke v.<java.lang.CharSequence: char charAt(int)>(v);
if v > 127 goto label;
v = v + 1;
goto label;
label:
if v > 2047 goto label;
v = v + 2;
goto label;
label:
v = staticinvoke <java.lang.Character: boolean isHighSurrogate(char)>(v);
if v == 0 goto label;
v = v + 4;
v = v + 1;
goto label;
label:
v = v + 3;
label:
v = v + 1;
goto label;
label:
return v;
}
public static byte[] toArray(java.nio.ByteBuffer)
{
int v;
byte[] v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: byte[] toArray(java.nio.ByteBuffer,int,int)>(v, 0, v);
return v;
}
public static byte[] toArray(java.nio.ByteBuffer, int)
{
int v;
byte[] v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: int;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: byte[] toArray(java.nio.ByteBuffer,int,int)>(v, 0, v);
return v;
}
public static byte[] toNullableArray(java.nio.ByteBuffer)
{
byte[] v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer;
if v != null goto label;
v = null;
goto label;
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: byte[] toArray(java.nio.ByteBuffer)>(v);
label:
return v;
}
public static java.nio.ByteBuffer wrapNullable(byte[])
{
byte[] v;
java.nio.ByteBuffer v;
v := @parameter: byte[];
if v != null goto label;
v = null;
goto label;
label:
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer wrap(byte[])>(v);
label:
return v;
}
public static byte[] toArray(java.nio.ByteBuffer, int, int)
{
byte[] v, v;
java.nio.ByteBuffer v;
int v, v, v, v, v, v, v, v;
boolean v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: int;
v := @parameter: int;
v = newarray (byte)[v];
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasArray()>();
if v == 0 goto label;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int arrayOffset()>();
v = v + v;
v = v + v;
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, v, v, 0, v);
goto label;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v + v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer get(byte[])>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
label:
return v;
}
public static byte[] copyArray(byte[])
{
int v;
byte[] v, v;
v := @parameter: byte[];
v = lengthof v;
v = staticinvoke <java.util.Arrays: byte[] copyOf(byte[],int)>(v, v);
return v;
}
public static void sleep(long)
{
long v;
java.lang.InterruptedException v;
java.lang.Thread v;
v := @parameter: long;
label:
staticinvoke <java.lang.Thread: void sleep(long)>(v);
label:
goto label;
label:
v := @caughtexception;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
label:
return;
catch java.lang.InterruptedException from label to label with label;
}
public static java.lang.Object newInstance(java.lang.Class)
{
java.lang.Object[] v;
java.lang.NoSuchMethodException v;
java.lang.Class[] v;
java.lang.reflect.Constructor v;
java.lang.Exception v;
org.apache.kafkaesqueesque.common.KafkaException v, v, v;
java.lang.Class v;
java.lang.Object v;
java.lang.String v, v, v, v;
v := @parameter: java.lang.Class;
if v != null goto label;
v = new org.apache.kafkaesqueesque.common.KafkaException;
specialinvoke v.<org.apache.kafkaesqueesque.common.KafkaException: void <init>(java.lang.String)>("class cannot be null");
throw v;
label:
v = newarray (java.lang.Class)[0];
v = virtualinvoke v.<java.lang.Class: java.lang.reflect.Constructor getDeclaredConstructor(java.lang.Class[])>(v);
v = newarray (java.lang.Object)[0];
v = virtualinvoke v.<java.lang.reflect.Constructor: java.lang.Object newInstance(java.lang.Object[])>(v);
label:
return v;
label:
v := @caughtexception;
v = new org.apache.kafkaesqueesque.common.KafkaException;
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Could not find a public no-argument constructor for \u0001");
specialinvoke v.<org.apache.kafkaesqueesque.common.KafkaException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = new org.apache.kafkaesqueesque.common.KafkaException;
v = virtualinvoke v.<java.lang.Class: java.lang.String getName()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Could not instantiate class \u0001");
specialinvoke v.<org.apache.kafkaesqueesque.common.KafkaException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.NoSuchMethodException from label to label with label;
catch java.lang.ReflectiveOperationException from label to label with label;
catch java.lang.RuntimeException from label to label with label;
}
public static java.lang.Object newInstance(java.lang.String, java.lang.Class) throws java.lang.ClassNotFoundException
{
java.lang.Class v, v;
java.lang.Object v;
java.lang.String v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.Class loadClass(java.lang.String,java.lang.Class)>(v, v);
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.Object newInstance(java.lang.Class)>(v);
return v;
}
public static java.lang.Class loadClass(java.lang.String, java.lang.Class) throws java.lang.ClassNotFoundException
{
java.lang.Class v, v, v;
java.lang.ClassLoader v;
java.lang.String v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Class;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.ClassLoader getContextOrKafkaClassLoader()>();
v = staticinvoke <java.lang.Class: java.lang.Class forName(java.lang.String,boolean,java.lang.ClassLoader)>(v, 1, v);
v = virtualinvoke v.<java.lang.Class: java.lang.Class asSubclass(java.lang.Class)>(v);
return v;
}
public static transient java.lang.Object newParameterizedInstance(java.lang.String, java.lang.Object[]) throws java.lang.ClassNotFoundException
{
java.lang.NoSuchMethodException v;
java.lang.InstantiationException v;
java.lang.IllegalAccessException v;
java.lang.reflect.InvocationTargetException v;
java.lang.ClassLoader v;
java.lang.Object[] v, v, v, v, v, v;
java.lang.reflect.Constructor v;
int v, v, v, v, v, v, v, v, v, v;
java.lang.String v, v, v, v, v, v;
java.lang.Class[] v;
java.lang.Class v;
java.lang.ClassNotFoundException v, v, v, v;
java.lang.Object v, v, v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Object[];
v = lengthof v;
v = v / 2;
v = newarray (java.lang.Class)[v];
v = lengthof v;
v = v / 2;
v = newarray (java.lang.Object)[v];
label:
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.ClassLoader getContextOrKafkaClassLoader()>();
v = staticinvoke <java.lang.Class: java.lang.Class forName(java.lang.String,boolean,java.lang.ClassLoader)>(v, 1, v);
v = 0;
label:
v = lengthof v;
v = v / 2;
if v >= v goto label;
v = 2 * v;
v = v[v];
v[v] = v;
v = 2 * v;
v = v + 1;
v = v[v];
v[v] = v;
v = v + 1;
goto label;
label:
v = virtualinvoke v.<java.lang.Class: java.lang.reflect.Constructor getConstructor(java.lang.Class[])>(v);
v = virtualinvoke v.<java.lang.reflect.Constructor: java.lang.Object newInstance(java.lang.Object[])>(v);
label:
return v;
label:
v := @caughtexception;
v = new java.lang.ClassNotFoundException;
v = newarray (java.lang.Object)[2];
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.String join(java.lang.Object[],java.lang.String)>(v, ", ");
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failed to find constructor with %s for %s", v);
specialinvoke v.<java.lang.ClassNotFoundException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = new java.lang.ClassNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failed to instantiate %s", v);
specialinvoke v.<java.lang.ClassNotFoundException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = new java.lang.ClassNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to access constructor of %s", v);
specialinvoke v.<java.lang.ClassNotFoundException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
label:
v := @caughtexception;
v = new java.lang.ClassNotFoundException;
v = newarray (java.lang.Object)[1];
v[0] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Unable to invoke constructor of %s", v);
specialinvoke v.<java.lang.ClassNotFoundException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.lang.NoSuchMethodException from label to label with label;
catch java.lang.InstantiationException from label to label with label;
catch java.lang.IllegalAccessException from label to label with label;
catch java.lang.reflect.InvocationTargetException from label to label with label;
}
public static int murmur2(byte[])
{
byte[] v;
byte v, v, v, v, v, v, v;
short v, v, v, v, v, v, v;
int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @parameter: byte[];
v = lengthof v;
v = -1756908916 ^ v;
v = v / 4;
v = 0;
label:
if v >= v goto label;
v = v * 4;
v = v + 0;
v = v[v];
v = v & 255;
v = v + 1;
v = v[v];
v = v & 255;
v = v << 8;
v = v + v;
v = v + 2;
v = v[v];
v = v & 255;
v = v << 16;
v = v + v;
v = v + 3;
v = v[v];
v = v & 255;
v = v << 24;
v = v + v;
v = v * 1540483477;
v = v >>> 24;
v = v ^ v;
v = v * 1540483477;
v = v * 1540483477;
v = v ^ v;
v = v + 1;
goto label;
label:
v = v % 4;
tableswitch(v)
{
case 1: goto label;
case 2: goto label;
case 3: goto label;
default: goto label;
};
label:
v = (int) -4;
v = v & v;
v = v + 2;
v = v[v];
v = v & 255;
v = v << 16;
v = v ^ v;
label:
v = (int) -4;
v = v & v;
v = v + 1;
v = v[v];
v = v & 255;
v = v << 8;
v = v ^ v;
label:
v = (int) -4;
v = v & v;
v = v[v];
v = v & 255;
v = v ^ v;
v = v * 1540483477;
label:
v = v >>> 13;
v = v ^ v;
v = v * 1540483477;
v = v >>> 15;
v = v ^ v;
return v;
}
public static java.lang.String getHost(java.lang.String)
{
java.util.regex.Matcher v;
java.lang.String v, v;
java.util.regex.Pattern v;
boolean v;
v := @parameter: java.lang.String;
v = <org.apache.kafkaesqueesque.common.utils.Utils: java.util.regex.Pattern HOST_PORT_PATTERN>;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(1);
goto label;
label:
v = null;
label:
return v;
}
public static java.lang.Integer getPort(java.lang.String)
{
java.util.regex.Matcher v;
int v;
java.lang.String v, v;
java.util.regex.Pattern v;
java.lang.Integer v;
boolean v;
v := @parameter: java.lang.String;
v = <org.apache.kafkaesqueesque.common.utils.Utils: java.util.regex.Pattern HOST_PORT_PATTERN>;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v == 0 goto label;
v = virtualinvoke v.<java.util.regex.Matcher: java.lang.String group(int)>(2);
v = staticinvoke <java.lang.Integer: int parseInt(java.lang.String)>(v);
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
goto label;
label:
v = null;
label:
return v;
}
public static boolean validHostPattern(java.lang.String)
{
java.util.regex.Matcher v;
java.lang.String v;
java.util.regex.Pattern v;
boolean v;
v := @parameter: java.lang.String;
v = <org.apache.kafkaesqueesque.common.utils.Utils: java.util.regex.Pattern VALID_HOST_CHARACTERS>;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
return v;
}
public static java.lang.String formatAddress(java.lang.String, java.lang.Integer)
{
java.lang.String v, v;
java.lang.Integer v;
boolean v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.Integer;
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>(":");
if v == 0 goto label;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.Integer)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("[\u]:\u0001");
goto label;
label:
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.Integer)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u0001:\u0001");
label:
return v;
}
public static java.lang.String formatBytes(long)
{
java.lang.IndexOutOfBoundsException v;
java.lang.String[] v;
long v;
byte v;
int v;
java.lang.String v, v, v, v, v;
double v, v, v, v, v, v;
java.text.DecimalFormat v;
v := @parameter: long;
v = v cmp 0L;
if v >= 0 goto label;
v = staticinvoke <java.lang.String: java.lang.String valueOf(long)>(v);
return v;
label:
v = staticinvoke <java.lang.Math: double log(double)>(v);
v = staticinvoke <java.lang.Math: double log(double)>(1024.0);
v = v / v;
v = staticinvoke <java.lang.Math: double floor(double)>(v);
v = staticinvoke <java.lang.Math: double pow(double,double)>(1024.0, v);
v = v / v;
v = <org.apache.kafkaesqueesque.common.utils.Utils: java.text.DecimalFormat TWO_DIGIT_FORMAT>;
v = virtualinvoke v.<java.text.DecimalFormat: java.lang.String format(double)>(v);
label:
v = <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.String[] BYTE_SCALE_SUFFIXES>;
v = v[v];
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u \u0001");
label:
return v;
label:
v := @caughtexception;
v = staticinvoke <java.lang.String: java.lang.String valueOf(double)>(v);
return v;
catch java.lang.IndexOutOfBoundsException from label to label with label;
}
public static java.lang.String join(java.lang.Object[], java.lang.String)
{
java.util.List v;
java.lang.Object[] v;
java.lang.String v, v;
v := @parameter: java.lang.Object[];
v := @parameter: java.lang.String;
v = staticinvoke <java.util.Arrays: java.util.List asList(java.lang.Object[])>(v);
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.String join(java.util.Collection,java.lang.String)>(v, v);
return v;
}
public static java.lang.String join(java.util.Collection, java.lang.String)
{
java.util.Iterator v;
java.util.Collection v;
java.lang.Object v;
java.lang.StringBuilder v;
java.lang.String v, v;
boolean v, v;
v := @parameter: java.util.Collection;
v := @parameter: java.lang.String;
virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
goto label;
label:
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public static java.lang.String mkString(java.util.Map, java.lang.String, java.lang.String, java.lang.String, java.lang.String)
{
java.util.Map v;
java.lang.String v, v, v, v, v, v;
boolean v;
java.util.Iterator v;
java.util.Set v;
java.lang.Object v, v, v;
java.lang.StringBuilder v, v, v, v;
v := @parameter: java.util.Map;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new java.lang.StringBuilder;
specialinvoke v.<java.lang.StringBuilder: void <init>()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = "";
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.Object)>(v);
v = v;
goto label;
label:
virtualinvoke v.<java.lang.StringBuilder: java.lang.StringBuilder append(java.lang.String)>(v);
v = virtualinvoke v.<java.lang.StringBuilder: java.lang.String toString()>();
return v;
}
public static java.util.Map parseMap(java.lang.String, java.lang.String, java.lang.String)
{
java.lang.String[] v, v;
java.util.HashMap v;
int v, v;
java.lang.String v, v, v, v, v, v;
boolean v;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<java.lang.String: boolean isEmpty()>();
if v != 0 goto label;
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = virtualinvoke v.<java.lang.String: java.lang.String[] split(java.lang.String,int)>(v, 2);
v = v[0];
v = v[1];
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.Properties loadProps(java.lang.String) throws java.io.IOException
{
java.lang.String v;
java.util.Properties v;
v := @parameter: java.lang.String;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.util.Properties loadProps(java.lang.String,java.util.List)>(v, null);
return v;
}
public static java.util.Properties loadProps(java.lang.String, java.util.List) throws java.io.IOException
{
java.io.PrintStream v;
java.lang.Throwable v;
java.util.Properties v, v;
java.lang.String[] v;
java.util.function.Consumer v;
java.util.List v;
java.nio.file.OpenOption[] v;
java.lang.String v;
java.nio.file.Path v;
boolean v;
java.io.InputStream v;
v := @parameter: java.lang.String;
v := @parameter: java.util.List;
v = new java.util.Properties;
specialinvoke v.<java.util.Properties: void <init>()>();
if v == null goto label;
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = newarray (java.nio.file.OpenOption)[0];
v = staticinvoke <java.nio.file.Files: java.io.InputStream newInputStream(java.nio.file.Path,java.nio.file.OpenOption[])>(v, v);
label:
virtualinvoke v.<java.util.Properties: void load(java.io.InputStream)>(v);
label:
if v == null goto label;
virtualinvoke v.<java.io.InputStream: void close()>();
goto label;
label:
v := @caughtexception;
throw v;
label:
v = <java.lang.System: java.io.PrintStream out>;
virtualinvoke v.<java.io.PrintStream: void println(java.lang.String)>("Did not load any properties since the property file is not specified");
label:
if v == null goto label;
v = interfaceinvoke v.<java.util.List: boolean isEmpty()>();
if v == 0 goto label;
label:
return v;
label:
v = new java.util.Properties;
specialinvoke v.<java.util.Properties: void <init>()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils$lambda_loadProps_0__656: java.util.function.Consumer bootstrap$(java.util.Properties,java.util.Properties)>(v, v);
interfaceinvoke v.<java.util.List: void forEach(java.util.function.Consumer)>(v);
return v;
catch java.lang.Throwable from label to label with label;
}
public static java.util.Map propsToStringMap(java.util.Properties)
{
java.util.Properties v;
java.util.Iterator v;
java.util.Set v;
java.util.HashMap v;
java.lang.Object v, v, v;
java.lang.String v, v;
boolean v;
v := @parameter: java.util.Properties;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v = virtualinvoke v.<java.util.Properties: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
goto label;
label:
return v;
}
public static java.lang.String stackTrace(java.lang.Throwable)
{
java.io.PrintWriter v;
java.lang.Throwable v;
java.io.StringWriter v;
java.lang.String v;
v := @parameter: java.lang.Throwable;
v = new java.io.StringWriter;
specialinvoke v.<java.io.StringWriter: void <init>()>();
v = new java.io.PrintWriter;
specialinvoke v.<java.io.PrintWriter: void <init>(java.io.Writer)>(v);
virtualinvoke v.<java.lang.Throwable: void printStackTrace(java.io.PrintWriter)>(v);
v = virtualinvoke v.<java.io.StringWriter: java.lang.String toString()>();
return v;
}
public static byte[] readBytes(java.nio.ByteBuffer, int, int)
{
byte[] v, v;
java.nio.ByteBuffer v;
int v, v, v, v;
boolean v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: int;
v := @parameter: int;
v = newarray (byte)[v];
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasArray()>();
if v == 0 goto label;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int arrayOffset()>();
v = v + v;
staticinvoke <java.lang.System: void arraycopy(java.lang.Object,int,java.lang.Object,int,int)>(v, v, v, 0, v);
goto label;
label:
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer mark()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer get(byte[])>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer reset()>();
label:
return v;
}
public static byte[] readBytes(java.nio.ByteBuffer)
{
int v;
byte[] v;
java.nio.ByteBuffer v;
v := @parameter: java.nio.ByteBuffer;
v = virtualinvoke v.<java.nio.ByteBuffer: int limit()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: byte[] readBytes(java.nio.ByteBuffer,int,int)>(v, 0, v);
return v;
}
public static java.lang.String readFileAsString(java.lang.String) throws java.io.IOException
{
byte[] v;
java.io.IOException v, v;
java.lang.String[] v;
java.nio.charset.Charset v;
java.lang.String v, v, v;
java.nio.file.Path v;
v := @parameter: java.lang.String;
label:
v = newarray (java.lang.String)[0];
v = staticinvoke <java.nio.file.Paths: java.nio.file.Path get(java.lang.String,java.lang.String[])>(v, v);
v = staticinvoke <java.nio.file.Files: byte[] readAllBytes(java.nio.file.Path)>(v);
v = new java.lang.String;
v = <java.nio.charset.StandardCharsets: java.nio.charset.Charset UTF_8>;
specialinvoke v.<java.lang.String: void <init>(byte[],java.nio.charset.Charset)>(v, v);
label:
return v;
label:
v := @caughtexception;
v = new java.io.IOException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("Unable to read file \u0001");
specialinvoke v.<java.io.IOException: void <init>(java.lang.String,java.lang.Throwable)>(v, v);
throw v;
catch java.io.IOException from label to label with label;
}
public static java.nio.ByteBuffer ensureCapacity(java.nio.ByteBuffer, int)
{
int v, v;
java.nio.ByteBuffer v, v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: int;
v = virtualinvoke v.<java.nio.ByteBuffer: int capacity()>();
if v <= v goto label;
v = staticinvoke <java.nio.ByteBuffer: java.nio.ByteBuffer allocate(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer flip()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer put(java.nio.ByteBuffer)>(v);
return v;
label:
return v;
}
public static transient java.util.Set mkSet(java.lang.Object[])
{
java.lang.Object[] v;
java.util.HashSet v;
int v, v, v, v;
java.lang.Object v;
double v;
v := @parameter: java.lang.Object[];
v = new java.util.HashSet;
v = lengthof v;
v = v / 0.75;
v = v + 1;
specialinvoke v.<java.util.HashSet: void <init>(int)>(v);
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.Map$Entry mkEntry(java.lang.Object, java.lang.Object)
{
java.lang.Object v, v;
org.apache.kafkaesqueesque.common.utils.Utils$1 v;
v := @parameter: java.lang.Object;
v := @parameter: java.lang.Object;
v = new org.apache.kafkaesqueesque.common.utils.Utils$1;
specialinvoke v.<org.apache.kafkaesqueesque.common.utils.Utils$1: void <init>(java.lang.Object,java.lang.Object)>(v, v);
return v;
}
public static transient java.util.Map mkMap(java.util.Map$Entry[])
{
java.util.LinkedHashMap v;
java.util.Map$Entry v;
int v, v;
java.lang.Object v, v;
java.util.Map$Entry[] v;
v := @parameter: java.util.Map$Entry[];
v = new java.util.LinkedHashMap;
specialinvoke v.<java.util.LinkedHashMap: void <init>()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<java.util.LinkedHashMap: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
return v;
}
public static java.util.Properties mkProperties(java.util.Map)
{
java.util.Properties v;
java.util.Iterator v;
java.util.Set v;
java.util.Map v;
java.lang.Object v, v, v;
boolean v;
v := @parameter: java.util.Map;
v = new java.util.Properties;
specialinvoke v.<java.util.Properties: void <init>()>();
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getValue()>();
virtualinvoke v.<java.util.Properties: java.lang.Object setProperty(java.lang.String,java.lang.String)>(v, v);
goto label;
label:
return v;
}
public static void delete(java.io.File) throws java.io.IOException
{
java.util.List v;
java.io.File v;
v := @parameter: java.io.File;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: void delete(java.io.File,java.util.List)>(v, v);
return;
}
public static void delete(java.io.File, java.util.List) throws java.io.IOException
{
java.util.List v;
org.apache.kafkaesqueesque.common.utils.Utils$2 v;
java.nio.file.Path v;
java.io.File v;
v := @parameter: java.io.File;
v := @parameter: java.util.List;
if v != null goto label;
return;
label:
v = virtualinvoke v.<java.io.File: java.nio.file.Path toPath()>();
v = new org.apache.kafkaesqueesque.common.utils.Utils$2;
specialinvoke v.<org.apache.kafkaesqueesque.common.utils.Utils$2: void <init>(java.io.File,java.util.List)>(v, v);
staticinvoke <java.nio.file.Files: java.nio.file.Path walkFileTree(java.nio.file.Path,java.nio.file.FileVisitor)>(v, v);
return;
}
public static java.util.List safe(java.util.List)
{
java.util.List v, v;
v := @parameter: java.util.List;
if v != null goto label;
v = staticinvoke <java.util.Collections: java.util.List emptyList()>();
goto label;
label:
v = v;
label:
return v;
}
public static java.lang.ClassLoader getKafkaClassLoader()
{
java.lang.Class v;
java.lang.ClassLoader v;
v = class "Lorg/apache/kafkaesqueesque/common/utils/Utils;";
v = virtualinvoke v.<java.lang.Class: java.lang.ClassLoader getClassLoader()>();
return v;
}
public static java.lang.ClassLoader getContextOrKafkaClassLoader()
{
java.lang.ClassLoader v, v;
java.lang.Thread v;
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
v = virtualinvoke v.<java.lang.Thread: java.lang.ClassLoader getContextClassLoader()>();
if v != null goto label;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.lang.ClassLoader getKafkaClassLoader()>();
return v;
label:
return v;
}
public static void atomicMoveWithFallback(java.nio.file.Path, java.nio.file.Path) throws java.io.IOException
{
java.nio.file.CopyOption[] v, v;
java.lang.Object[] v;
org.slf4j.Logger v;
java.io.IOException v, v;
java.nio.file.StandardCopyOption v, v;
java.lang.String v;
java.nio.file.Path v, v;
v := @parameter: java.nio.file.Path;
v := @parameter: java.nio.file.Path;
label:
v = newarray (java.nio.file.CopyOption)[1];
v = <java.nio.file.StandardCopyOption: java.nio.file.StandardCopyOption ATOMIC_MOVE>;
v[0] = v;
staticinvoke <java.nio.file.Files: java.nio.file.Path move(java.nio.file.Path,java.nio.file.Path,java.nio.file.CopyOption[])>(v, v, v);
label:
goto label;
label:
v := @caughtexception;
label:
v = newarray (java.nio.file.CopyOption)[1];
v = <java.nio.file.StandardCopyOption: java.nio.file.StandardCopyOption REPLACE_EXISTING>;
v[0] = v;
staticinvoke <java.nio.file.Files: java.nio.file.Path move(java.nio.file.Path,java.nio.file.Path,java.nio.file.CopyOption[])>(v, v, v);
v = <org.apache.kafkaesqueesque.common.utils.Utils: org.slf4j.Logger log>;
v = newarray (java.lang.Object)[3];
v[0] = v;
v[1] = v;
v = virtualinvoke v.<java.io.IOException: java.lang.String getMessage()>();
v[2] = v;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object[])>("Non-atomic move of {} to {} succeeded after atomic move failed due to {}", v);
label:
goto label;
label:
v := @caughtexception;
virtualinvoke v.<java.io.IOException: void addSuppressed(java.lang.Throwable)>(v);
throw v;
label:
return;
catch java.io.IOException from label to label with label;
catch java.io.IOException from label to label with label;
}
public static transient void closeAll(java.io.Closeable[]) throws java.io.IOException
{
java.io.Closeable v;
int v, v;
java.io.Closeable[] v;
java.io.IOException v, v;
v := @parameter: java.io.Closeable[];
v = null;
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
label:
if v == null goto label;
interfaceinvoke v.<java.io.Closeable: void close()>();
label:
goto label;
label:
v := @caughtexception;
if v == null goto label;
virtualinvoke v.<java.io.IOException: void addSuppressed(java.lang.Throwable)>(v);
goto label;
label:
v = v;
label:
v = v + 1;
goto label;
label:
if v == null goto label;
throw v;
label:
return;
catch java.io.IOException from label to label with label;
}
public static void closeQuietly(java.lang.AutoCloseable, java.lang.String)
{
java.lang.String v;
java.lang.AutoCloseable v;
v := @parameter: java.lang.AutoCloseable;
v := @parameter: java.lang.String;
return;
}
public static void closeQuietly(java.lang.AutoCloseable, java.lang.String, java.util.concurrent.atomic.AtomicReference)
{
java.lang.String v;
java.lang.AutoCloseable v;
java.util.concurrent.atomic.AtomicReference v;
v := @parameter: java.lang.AutoCloseable;
v := @parameter: java.lang.String;
v := @parameter: java.util.concurrent.atomic.AtomicReference;
return;
}
public static int toPositive(int)
{
int v, v;
v := @parameter: int;
v = v & 2147483647;
return v;
}
public static java.nio.ByteBuffer sizeDelimited(java.nio.ByteBuffer, int)
{
int v, v, v;
java.nio.ByteBuffer v, v, v;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: int;
v = virtualinvoke v.<java.nio.ByteBuffer: int getInt(int)>(v);
if v >= 0 goto label;
return null;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer duplicate()>();
v = v + 4;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
v = virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer slice()>();
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer limit(int)>(v);
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer rewind()>();
return v;
}
public static void readFullyOrFail(java.nio.channels.FileChannel, java.nio.ByteBuffer, long, java.lang.String) throws java.io.IOException
{
java.lang.Object[] v;
long v;
java.lang.Integer v, v;
java.nio.ByteBuffer v;
byte v;
java.lang.Long v;
int v, v, v;
java.lang.String v, v, v;
boolean v;
java.lang.IllegalArgumentException v;
java.io.EOFException v;
java.nio.channels.FileChannel v;
v := @parameter: java.nio.channels.FileChannel;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: long;
v := @parameter: java.lang.String;
v = v cmp 0L;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The file channel position cannot be negative, but it is \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: void readFully(java.nio.channels.FileChannel,java.nio.ByteBuffer,long)>(v, v, v);
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v == 0 goto label;
v = new java.io.EOFException;
v = newarray (java.lang.Object)[5];
v[0] = v;
v[1] = v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = v - v;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[3] = v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[4] = v;
v = staticinvoke <java.lang.String: java.lang.String format(java.lang.String,java.lang.Object[])>("Failed to read `%s` from file channel `%s`. Expected to read %d bytes, but reached end of file after reading %d bytes. Started read from position %d.", v);
specialinvoke v.<java.io.EOFException: void <init>(java.lang.String)>(v);
throw v;
label:
return;
}
public static void readFully(java.nio.channels.FileChannel, java.nio.ByteBuffer, long) throws java.io.IOException
{
long v, v;
java.lang.IllegalArgumentException v;
java.nio.ByteBuffer v;
byte v;
int v, v;
java.lang.String v;
java.nio.channels.FileChannel v;
boolean v;
v := @parameter: java.nio.channels.FileChannel;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: long;
v = v cmp 0L;
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("The file channel position cannot be negative, but it is \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v = v;
label:
v = virtualinvoke v.<java.nio.channels.FileChannel: int read(java.nio.ByteBuffer,long)>(v, v);
v = v + v;
v = (int) -1;
if v == v goto label;
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v != 0 goto label;
label:
return;
}
public static final void readFully(java.io.InputStream, java.nio.ByteBuffer) throws java.io.IOException
{
byte[] v;
java.nio.ByteBuffer v;
int v, v, v, v, v, v, v, v, v, v, v;
boolean v;
java.lang.IllegalArgumentException v;
java.io.InputStream v;
v := @parameter: java.io.InputStream;
v := @parameter: java.nio.ByteBuffer;
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasArray()>();
if v != 0 goto label;
v = new java.lang.IllegalArgumentException;
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>("destinationBuffer must be backed by an array");
throw v;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: int arrayOffset()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v + v;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int remaining()>();
v = 0;
label:
v = v + v;
v = v - v;
v = virtualinvoke v.<java.io.InputStream: int read(byte[],int,int)>(v, v, v);
v = (int) -1;
if v == v goto label;
v = v + v;
if v > v goto label;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v + v;
virtualinvoke v.<java.nio.ByteBuffer: java.nio.ByteBuffer position(int)>(v);
return;
}
public static void writeFully(java.nio.channels.FileChannel, java.nio.ByteBuffer) throws java.io.IOException
{
java.nio.channels.FileChannel v;
java.nio.ByteBuffer v;
boolean v;
v := @parameter: java.nio.channels.FileChannel;
v := @parameter: java.nio.ByteBuffer;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasRemaining()>();
if v == 0 goto label;
virtualinvoke v.<java.nio.channels.FileChannel: int write(java.nio.ByteBuffer)>(v);
goto label;
label:
return;
}
public static void writeTo(java.io.DataOutput, java.nio.ByteBuffer, int) throws java.io.IOException
{
byte[] v;
java.io.DataOutput v;
java.nio.ByteBuffer v;
byte v;
int v, v, v, v, v, v, v;
boolean v;
v := @parameter: java.io.DataOutput;
v := @parameter: java.nio.ByteBuffer;
v := @parameter: int;
v = virtualinvoke v.<java.nio.ByteBuffer: boolean hasArray()>();
if v == 0 goto label;
v = virtualinvoke v.<java.nio.ByteBuffer: byte[] array()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = virtualinvoke v.<java.nio.ByteBuffer: int arrayOffset()>();
v = v + v;
interfaceinvoke v.<java.io.DataOutput: void write(byte[],int,int)>(v, v, v);
goto label;
label:
v = virtualinvoke v.<java.nio.ByteBuffer: int position()>();
v = v;
label:
v = v + v;
if v >= v goto label;
v = virtualinvoke v.<java.nio.ByteBuffer: byte get(int)>(v);
interfaceinvoke v.<java.io.DataOutput: void writeByte(int)>(v);
v = v + 1;
goto label;
label:
return;
}
public static java.util.List toList(java.util.Iterator)
{
java.util.Iterator v;
java.lang.Object v;
boolean v;
java.util.ArrayList v;
v := @parameter: java.util.Iterator;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
goto label;
label:
return v;
}
public static java.util.List concatListsUnmodifiable(java.util.List, java.util.List)
{
java.util.List v, v, v;
java.util.function.Function v;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils$unmodifiableList__657: java.util.function.Function bootstrap$()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: java.util.List concatLists(java.util.List,java.util.List,java.util.function.Function)>(v, v, v);
return v;
}
public static java.util.List concatLists(java.util.List, java.util.List, java.util.function.Function)
{
java.util.function.Function v;
java.util.List v, v;
java.util.stream.Stream v, v, v;
java.lang.Object v;
java.util.stream.Collector v, v;
v := @parameter: java.util.List;
v := @parameter: java.util.List;
v := @parameter: java.util.function.Function;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <java.util.stream.Stream: java.util.stream.Stream concat(java.util.stream.Stream,java.util.stream.Stream)>(v, v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector collectingAndThen(java.util.stream.Collector,java.util.function.Function)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
public static int to32BitField(java.util.Set)
{
java.util.Iterator v;
java.util.Set v;
byte v, v;
int v, v;
java.lang.Object v;
boolean v;
v := @parameter: java.util.Set;
v = 0;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = virtualinvoke v.<java.lang.Byte: byte byteValue()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils: byte checkRange(byte)>(v);
v = 1 << v;
v = v | v;
goto label;
label:
return v;
}
private static byte checkRange(byte)
{
byte v;
java.lang.String v, v;
java.lang.IllegalArgumentException v, v;
v := @parameter: byte;
if v <= 31 goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (byte)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("out of range: i>31, i = \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
if v >= 0 goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (byte)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("out of range: i<0, i = \u0001");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public static java.util.Set from32BitField(int)
{
java.util.HashSet v;
int v, v, v, v;
java.lang.Byte v;
v := @parameter: int;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v;
v = 0;
label:
if v == 0 goto label;
v = v & 1;
if v == 0 goto label;
v = staticinvoke <java.lang.Byte: java.lang.Byte valueOf(byte)>(v);
interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
label:
v = v + 1;
v = v >>> 1;
goto label;
label:
return v;
}
public static java.util.Map transformMap(java.util.Map, java.util.function.Function, java.util.function.Function)
{
java.util.Set v;
java.util.function.Function v, v, v, v;
java.util.stream.Stream v;
java.util.Map v;
java.lang.Object v;
java.util.stream.Collector v;
v := @parameter: java.util.Map;
v := @parameter: java.util.function.Function;
v := @parameter: java.util.function.Function;
v = interfaceinvoke v.<java.util.Map: java.util.Set entrySet()>();
v = interfaceinvoke v.<java.util.Set: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils$lambda_transformMap_1__658: java.util.function.Function bootstrap$(java.util.function.Function)>(v);
v = staticinvoke <org.apache.kafkaesqueesque.common.utils.Utils$lambda_transformMap_2__659: java.util.function.Function bootstrap$(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toMap(java.util.function.Function,java.util.function.Function)>(v, v);
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
java.text.DecimalFormatSymbols v;
java.text.DecimalFormat v;
java.lang.String[] v;
java.util.Locale v;
java.lang.String v;
java.util.regex.Pattern v, v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>(".*?\\[?([0-9a-zA-Z\\-%._:]*)\\]?:([0-9]+)");
<org.apache.kafkaesqueesque.common.utils.Utils: java.util.regex.Pattern HOST_PORT_PATTERN> = v;
v = staticinvoke <java.util.regex.Pattern: java.util.regex.Pattern compile(java.lang.String)>("([0-9a-zA-Z\\-%._:]*)");
<org.apache.kafkaesqueesque.common.utils.Utils: java.util.regex.Pattern VALID_HOST_CHARACTERS> = v;
v = new java.text.DecimalFormat;
v = <java.util.Locale: java.util.Locale ENGLISH>;
v = staticinvoke <java.text.DecimalFormatSymbols: java.text.DecimalFormatSymbols getInstance(java.util.Locale)>(v);
specialinvoke v.<java.text.DecimalFormat: void <init>(java.lang.String,java.text.DecimalFormatSymbols)>("0.##", v);
<org.apache.kafkaesqueesque.common.utils.Utils: java.text.DecimalFormat TWO_DIGIT_FORMAT> = v;
v = newarray (java.lang.String)[9];
v[0] = "B";
v[1] = "KB";
v[2] = "MB";
v[3] = "GB";
v[4] = "TB";
v[5] = "PB";
v[6] = "EB";
v[7] = "ZB";
v[8] = "YB";
<org.apache.kafkaesqueesque.common.utils.Utils: java.lang.String[] BYTE_SCALE_SUFFIXES> = v;
v = staticinvoke <java.lang.System: java.lang.String getProperty(java.lang.String)>("line.separator");
<org.apache.kafkaesqueesque.common.utils.Utils: java.lang.String NL> = v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/kafkaesqueesque/common/utils/Utils;");
<org.apache.kafkaesqueesque.common.utils.Utils: org.slf4j.Logger log> = v;
return;
}
}