class oadd.org.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReferenceCleaner extends java.lang.Object implements java.lang.Runnable
{
private void <init>()
{
oadd.org.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReferenceCleaner v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReferenceCleaner;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void run()
{
java.lang.Throwable v;
org.slf4j.Logger v, v;
java.lang.ref.ReferenceQueue v;
java.lang.ref.Reference v;
java.lang.InterruptedException v;
java.lang.Thread v;
oadd.org.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReferenceCleaner v;
boolean v;
v := @this: oadd.org.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReferenceCleaner;
label:
v = staticinvoke <java.lang.Thread: boolean interrupted()>();
if v != 0 goto label;
label:
v = <oadd.org.apache.hadoop.fs.FileSystem$Statistics: java.lang.ref.ReferenceQueue STATS_DATA_REF_QUEUE>;
v = virtualinvoke v.<java.lang.ref.ReferenceQueue: java.lang.ref.Reference remove()>();
virtualinvoke v.<oadd.org.apache.hadoop.fs.FileSystem$Statistics$StatisticsDataReference: void cleanUp()>();
label:
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Cleaner thread interrupted, will stop", v);
v = staticinvoke <java.lang.Thread: java.lang.Thread currentThread()>();
virtualinvoke v.<java.lang.Thread: void interrupt()>();
goto label;
label:
v := @caughtexception;
v = <oadd.org.apache.hadoop.fs.FileSystem: org.slf4j.Logger LOGGER>;
interfaceinvoke v.<org.slf4j.Logger: void warn(java.lang.String,java.lang.Throwable)>("Exception in the cleaner thread but it will continue to run", v);
goto label;
label:
return;
catch java.lang.InterruptedException from label to label with label;
catch java.lang.Throwable from label to label with label;
}
}