public class oadd.org.apache.hadoop.io.compress.CodecPool extends java.lang.Object
{
private static final org.slf4j.Logger LOG;
private static final java.util.Map compressorPool;
private static final java.util.Map decompressorPool;
private static final oadd.com.google.common.cache.LoadingCache compressorCounts;
private static final oadd.com.google.common.cache.LoadingCache decompressorCounts;
public void <init>()
{
oadd.org.apache.hadoop.io.compress.CodecPool v;
v := @this: oadd.org.apache.hadoop.io.compress.CodecPool;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
private static oadd.com.google.common.cache.LoadingCache createCache(java.lang.Class)
{
oadd.org.apache.hadoop.io.compress.CodecPool$1 v;
oadd.com.google.common.cache.CacheBuilder v;
java.lang.Class v;
oadd.com.google.common.cache.LoadingCache v;
v := @parameter: java.lang.Class;
v = staticinvoke <oadd.com.google.common.cache.CacheBuilder: oadd.com.google.common.cache.CacheBuilder newBuilder()>();
v = new oadd.org.apache.hadoop.io.compress.CodecPool$1;
specialinvoke v.<oadd.org.apache.hadoop.io.compress.CodecPool$1: void <init>()>();
v = virtualinvoke v.<oadd.com.google.common.cache.CacheBuilder: oadd.com.google.common.cache.LoadingCache build(oadd.com.google.common.cache.CacheLoader)>(v);
return v;
}
private static java.lang.Object borrow(java.util.Map, java.lang.Class)
{
java.lang.Throwable v, v;
java.util.Iterator v;
java.util.Map v;
java.lang.Class v;
java.lang.Object v, v;
boolean v;
v := @parameter: java.util.Map;
v := @parameter: java.lang.Class;
v = null;
entermonitor v;
label:
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
if v == null goto label;
entermonitor v;
label:
v = interfaceinvoke v.<java.util.Set: boolean isEmpty()>();
if v != 0 goto label;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
interfaceinvoke v.<java.util.Set: boolean remove(java.lang.Object)>(v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return v;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private static boolean payback(java.util.Map, java.lang.Object)
{
java.lang.Throwable v, v;
java.util.Set v;
java.util.HashSet v;
java.util.Map v;
java.lang.Class v;
java.lang.Object v, v;
boolean v;
v := @parameter: java.util.Map;
v := @parameter: java.lang.Object;
if v == null goto label;
v = staticinvoke <oadd.org.apache.hadoop.util.ReflectionUtils: java.lang.Class getClass(java.lang.Object)>(v);
entermonitor v;
label:
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.util.HashSet;
specialinvoke v.<java.util.HashSet: void <init>()>();
v = v;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
label:
exitmonitor v;
label:
goto label;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
v = v;
entermonitor v;
label:
v = interfaceinvoke v.<java.util.Set: boolean add(java.lang.Object)>(v);
exitmonitor v;
label:
return v;
label:
v := @caughtexception;
exitmonitor v;
throw v;
label:
return 0;
catch java.lang.Throwable from label to label with label;
catch java.lang.Throwable from label to label with label;
}
private static int getLeaseCount(oadd.com.google.common.cache.LoadingCache, java.lang.Class)
{
int v;
java.lang.Class v;
java.lang.Object v;
oadd.com.google.common.cache.LoadingCache v;
v := @parameter: oadd.com.google.common.cache.LoadingCache;
v := @parameter: java.lang.Class;
v = interfaceinvoke v.<oadd.com.google.common.cache.LoadingCache: java.lang.Object getUnchecked(java.lang.Object)>(v);
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int get()>();
return v;
}
private static void updateLeaseCount(oadd.com.google.common.cache.LoadingCache, java.lang.Object, int)
{
int v;
java.lang.Class v;
java.lang.Object v, v;
oadd.com.google.common.cache.LoadingCache v;
v := @parameter: oadd.com.google.common.cache.LoadingCache;
v := @parameter: java.lang.Object;
v := @parameter: int;
if v == null goto label;
v = staticinvoke <oadd.org.apache.hadoop.util.ReflectionUtils: java.lang.Class getClass(java.lang.Object)>(v);
v = interfaceinvoke v.<oadd.com.google.common.cache.LoadingCache: java.lang.Object getUnchecked(java.lang.Object)>(v);
virtualinvoke v.<java.util.concurrent.atomic.AtomicInteger: int addAndGet(int)>(v);
label:
return;
}
public static oadd.org.apache.hadoop.io.compress.Compressor getCompressor(oadd.org.apache.hadoop.io.compress.CompressionCodec, oadd.org.apache.hadoop.conf.Configuration)
{
org.slf4j.Logger v, v, v;
oadd.org.apache.hadoop.io.compress.CompressionCodec v;
oadd.com.google.common.cache.LoadingCache v;
java.util.Map v;
java.lang.Class v, v;
java.lang.Object v;
oadd.org.apache.hadoop.conf.Configuration v;
java.lang.String v, v;
boolean v, v;
v := @parameter: oadd.org.apache.hadoop.io.compress.CompressionCodec;
v := @parameter: oadd.org.apache.hadoop.conf.Configuration;
v = <oadd.org.apache.hadoop.io.compress.CodecPool: java.util.Map compressorPool>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionCodec: java.lang.Class getCompressorType()>();
v = staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: java.lang.Object borrow(java.util.Map,java.lang.Class)>(v, v);
if v != null goto label;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionCodec: oadd.org.apache.hadoop.io.compress.Compressor createCompressor()>();
v = <oadd.org.apache.hadoop.io.compress.CodecPool: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionCodec: java.lang.String getDefaultExtension()>();
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[])>("Got brand-new compressor [\u]");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
goto label;
label:
interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: void reinit(oadd.org.apache.hadoop.conf.Configuration)>(v);
v = <oadd.org.apache.hadoop.io.compress.CodecPool: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.hadoop.io.compress.CodecPool: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Got recycled compressor");
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: boolean isAnnotationPresent(java.lang.Class)>(class "Loadd/org/apache/hadoop/io/compress/DoNotPool;");
if v != 0 goto label;
v = <oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache compressorCounts>;
staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: void updateLeaseCount(oadd.com.google.common.cache.LoadingCache,java.lang.Object,int)>(v, v, 1);
label:
return v;
}
public static oadd.org.apache.hadoop.io.compress.Compressor getCompressor(oadd.org.apache.hadoop.io.compress.CompressionCodec)
{
oadd.org.apache.hadoop.io.compress.CompressionCodec v;
oadd.org.apache.hadoop.io.compress.Compressor v;
v := @parameter: oadd.org.apache.hadoop.io.compress.CompressionCodec;
v = staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: oadd.org.apache.hadoop.io.compress.Compressor getCompressor(oadd.org.apache.hadoop.io.compress.CompressionCodec,oadd.org.apache.hadoop.conf.Configuration)>(v, null);
return v;
}
public static oadd.org.apache.hadoop.io.compress.Decompressor getDecompressor(oadd.org.apache.hadoop.io.compress.CompressionCodec)
{
org.slf4j.Logger v, v, v;
oadd.org.apache.hadoop.io.compress.CompressionCodec v;
oadd.com.google.common.cache.LoadingCache v;
java.util.Map v;
java.lang.Class v, v;
java.lang.Object v;
java.lang.String v, v;
boolean v, v;
v := @parameter: oadd.org.apache.hadoop.io.compress.CompressionCodec;
v = <oadd.org.apache.hadoop.io.compress.CodecPool: java.util.Map decompressorPool>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionCodec: java.lang.Class getDecompressorType()>();
v = staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: java.lang.Object borrow(java.util.Map,java.lang.Class)>(v, v);
if v != null goto label;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionCodec: oadd.org.apache.hadoop.io.compress.Decompressor createDecompressor()>();
v = <oadd.org.apache.hadoop.io.compress.CodecPool: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionCodec: java.lang.String getDefaultExtension()>();
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[])>("Got brand-new decompressor [\u]");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
goto label;
label:
v = <oadd.org.apache.hadoop.io.compress.CodecPool: org.slf4j.Logger LOG>;
v = interfaceinvoke v.<org.slf4j.Logger: boolean isDebugEnabled()>();
if v == 0 goto label;
v = <oadd.org.apache.hadoop.io.compress.CodecPool: org.slf4j.Logger LOG>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Got recycled decompressor");
label:
if v == null goto label;
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: boolean isAnnotationPresent(java.lang.Class)>(class "Loadd/org/apache/hadoop/io/compress/DoNotPool;");
if v != 0 goto label;
v = <oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache decompressorCounts>;
staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: void updateLeaseCount(oadd.com.google.common.cache.LoadingCache,java.lang.Object,int)>(v, v, 1);
label:
return v;
}
public static void returnCompressor(oadd.org.apache.hadoop.io.compress.Compressor)
{
java.util.Map v;
int v;
java.lang.Class v;
oadd.org.apache.hadoop.io.compress.Compressor v;
boolean v, v;
oadd.com.google.common.cache.LoadingCache v;
v := @parameter: oadd.org.apache.hadoop.io.compress.Compressor;
if v != null goto label;
return;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: boolean isAnnotationPresent(java.lang.Class)>(class "Loadd/org/apache/hadoop/io/compress/DoNotPool;");
if v == 0 goto label;
return;
label:
interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Compressor: void reset()>();
v = <oadd.org.apache.hadoop.io.compress.CodecPool: java.util.Map compressorPool>;
v = staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: boolean payback(java.util.Map,java.lang.Object)>(v, v);
if v == 0 goto label;
v = <oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache compressorCounts>;
v = (int) -1;
staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: void updateLeaseCount(oadd.com.google.common.cache.LoadingCache,java.lang.Object,int)>(v, v, v);
label:
return;
}
public static void returnDecompressor(oadd.org.apache.hadoop.io.compress.Decompressor)
{
oadd.org.apache.hadoop.io.compress.Decompressor v;
java.util.Map v;
int v;
java.lang.Class v;
boolean v, v;
oadd.com.google.common.cache.LoadingCache v;
v := @parameter: oadd.org.apache.hadoop.io.compress.Decompressor;
if v != null goto label;
return;
label:
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = virtualinvoke v.<java.lang.Class: boolean isAnnotationPresent(java.lang.Class)>(class "Loadd/org/apache/hadoop/io/compress/DoNotPool;");
if v == 0 goto label;
return;
label:
interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.Decompressor: void reset()>();
v = <oadd.org.apache.hadoop.io.compress.CodecPool: java.util.Map decompressorPool>;
v = staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: boolean payback(java.util.Map,java.lang.Object)>(v, v);
if v == 0 goto label;
v = <oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache decompressorCounts>;
v = (int) -1;
staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: void updateLeaseCount(oadd.com.google.common.cache.LoadingCache,java.lang.Object,int)>(v, v, v);
label:
return;
}
public static int getLeasedCompressorsCount(oadd.org.apache.hadoop.io.compress.CompressionCodec)
{
int v;
java.lang.Class v;
oadd.org.apache.hadoop.io.compress.CompressionCodec v;
oadd.com.google.common.cache.LoadingCache v;
v := @parameter: oadd.org.apache.hadoop.io.compress.CompressionCodec;
if v != null goto label;
v = 0;
goto label;
label:
v = <oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache compressorCounts>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionCodec: java.lang.Class getCompressorType()>();
v = staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: int getLeaseCount(oadd.com.google.common.cache.LoadingCache,java.lang.Class)>(v, v);
label:
return v;
}
public static int getLeasedDecompressorsCount(oadd.org.apache.hadoop.io.compress.CompressionCodec)
{
int v;
java.lang.Class v;
oadd.org.apache.hadoop.io.compress.CompressionCodec v;
oadd.com.google.common.cache.LoadingCache v;
v := @parameter: oadd.org.apache.hadoop.io.compress.CompressionCodec;
if v != null goto label;
v = 0;
goto label;
label:
v = <oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache decompressorCounts>;
v = interfaceinvoke v.<oadd.org.apache.hadoop.io.compress.CompressionCodec: java.lang.Class getDecompressorType()>();
v = staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: int getLeaseCount(oadd.com.google.common.cache.LoadingCache,java.lang.Class)>(v, v);
label:
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
java.util.HashMap v, v;
oadd.com.google.common.cache.LoadingCache v, v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Loadd/org/apache/hadoop/io/compress/CodecPool;");
<oadd.org.apache.hadoop.io.compress.CodecPool: org.slf4j.Logger LOG> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
<oadd.org.apache.hadoop.io.compress.CodecPool: java.util.Map compressorPool> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
<oadd.org.apache.hadoop.io.compress.CodecPool: java.util.Map decompressorPool> = v;
v = staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache createCache(java.lang.Class)>(class "Loadd/org/apache/hadoop/io/compress/Compressor;");
<oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache compressorCounts> = v;
v = staticinvoke <oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache createCache(java.lang.Class)>(class "Loadd/org/apache/hadoop/io/compress/Decompressor;");
<oadd.org.apache.hadoop.io.compress.CodecPool: oadd.com.google.common.cache.LoadingCache decompressorCounts> = v;
return;
}
}