public class oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl extends oadd.org.apache.hadoop.metrics.MetricsSystem implements oadd.org.apache.hadoop.metrics.MetricsSource { static final org.slf4j.Logger LOG; static final java.lang.String MS_NAME; static final java.lang.String MS_STATS_NAME; static final java.lang.String MS_STATS_DESC; static final java.lang.String MS_CONTROL_NAME; static final java.lang.String MS_INIT_MODE_KEY; private final java.util.Map sources; private final java.util.Map allSources; private final java.util.Map sinks; private final java.util.Map allSinks; private final java.util.List callbacks; private final java.util.Map namedCallbacks; private final oadd.org.apache.hadoop.metrics.impl.MetricsCollectorImpl collector; private final oadd.org.apache.hadoop.metrics.lib.MetricsRegistry registry; oadd.org.apache.hadoop.metrics.lib.MutableStat snapshotStat; oadd.org.apache.hadoop.metrics.lib.MutableStat publishStat; oadd.org.apache.hadoop.metrics.lib.MutableCounterLong droppedPubAll; private final java.util.List injectedTags; private java.lang.String prefix; private oadd.org.apache.hadoop.metrics.MetricsFilter sourceFilter; private oadd.org.apache.hadoop.metrics.impl.MetricsConfig config; private java.util.Map sourceConfigs; private java.util.Map sinkConfigs; private boolean monitoring; private java.util.Timer timer; private long period; private long logicalTime; private javax.management.ObjectName mbeanName; private boolean publishSelfMetrics; private oadd.org.apache.hadoop.metrics.impl.MetricsSourceAdapter sysSource; private int refCount; public void (java.lang.String) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.util.HashMap v, v, v, v, v; oadd.org.apache.hadoop.metrics.lib.MetricsRegistry v; oadd.org.apache.hadoop.metrics.impl.MetricsCollectorImpl v; java.util.ArrayList v, v; java.util.LinkedHashMap v, v; java.lang.String v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: java.lang.String; specialinvoke v.()>(); v = new oadd.org.apache.hadoop.metrics.lib.MetricsRegistry; specialinvoke v.(java.lang.String)>("MetricsSystem"); v. = v; v. = 0; v. = 1; v. = 0; v. = v; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v = staticinvoke (); v. = v; v = new oadd.org.apache.hadoop.metrics.impl.MetricsCollectorImpl; specialinvoke v.()>(); v. = v; if v == null goto label; specialinvoke v.(); label: return; } public void () { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; specialinvoke v.(java.lang.String)>(null); return; } public synchronized oadd.org.apache.hadoop.metrics.MetricsSystem init(java.lang.String) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl$InitMode v; int[] v; int v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; boolean v, v, v; org.slf4j.Logger v, v, v, v, v; oadd.org.apache.hadoop.metrics.impl.MetricsConfigException v; java.lang.Object v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: java.lang.String; v = v.; if v == 0 goto label; v = staticinvoke (); if v != 0 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system already initialized!"); interfaceinvoke v.(v); return v; label: v = staticinvoke (v, "prefix"); v. = v; v = v.; v = v + 1; v. = v; v = v.; if v == 0 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system started (again)"); interfaceinvoke v.(v); return v; label: v = ; v = specialinvoke v.(); v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; case 2: goto label; default: goto label; }; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Metrics system not started: \u0001"); interfaceinvoke v.(v); v = ; interfaceinvoke v.("Stacktrace: ", v); goto label; label: v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system started in standby mode"); interfaceinvoke v.(v); label: specialinvoke v.(); return v; catch oadd.org.apache.hadoop.metrics.impl.MetricsConfigException from label to label with label; } public synchronized void start() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.util.Map v, v; java.lang.String v, v, v, v, v, v; boolean v, v, v, v, v; oadd.org.apache.hadoop.metrics.MetricsException v; org.slf4j.Logger v, v; java.util.Iterator v, v, v, v; java.util.Collection v, v; java.util.List v, v; java.lang.Object v, v, v, v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; staticinvoke (v, "prefix"); v = v.; if v == 0 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system already started!"); v = new oadd.org.apache.hadoop.metrics.MetricsException; specialinvoke v.(java.lang.String)>("Illegal start"); interfaceinvoke v.(v, v); return; label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: v = v.; specialinvoke v.(v); specialinvoke v.(); v. = 1; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system started"); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: return; } public synchronized void stop() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.util.Map v, v; boolean v, v, v, v, v, v, v; oadd.org.apache.hadoop.metrics.MetricsException v; java.util.Collection v, v; java.util.List v, v; java.lang.String v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v; java.util.Iterator v, v, v, v; java.lang.Object v, v, v, v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; if v != 0 goto label; v = staticinvoke (); if v != 0 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system not yet started!"); v = new oadd.org.apache.hadoop.metrics.MetricsException; specialinvoke v.(java.lang.String)>("Illegal stop"); interfaceinvoke v.(v, v); return; label: v = v.; if v != 0 goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system stopped (again)"); interfaceinvoke v.(v); return; label: v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Stopping \u metrics system..."); interfaceinvoke v.(v); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); v. = 0; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system stopped."); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); interfaceinvoke v.(); goto label; label: return; } public synchronized java.lang.Object register(java.lang.String, java.lang.String, java.lang.Object) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; oadd.org.apache.hadoop.metrics.MetricsSource v; oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl$1 v; java.util.Map v; java.lang.String v, v, v, v, v, v, v, v; boolean v, v, v; oadd.org.apache.hadoop.metrics.lib.MetricsSourceBuilder v; org.slf4j.Logger v; oadd.org.apache.hadoop.metrics.MetricsInfo v; java.lang.Object v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: java.lang.Object; v = staticinvoke (v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != null goto label; v = interfaceinvoke v.(); goto label; label: v = v; label: v = v; if v != null goto label; v = interfaceinvoke v.(); goto label; label: v = v; label: v = v; v = v.; if v != 0 goto label; v = 1; goto label; label: v = 0; label: v = staticinvoke (v, v); v = v.; interfaceinvoke v.(v, v); v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u, \u0001"); interfaceinvoke v.(v); v = v.; if v == 0 goto label; virtualinvoke v.(v, v, v); label: v = new oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl$1; specialinvoke v.(oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl,java.lang.String,java.lang.String,oadd.org.apache.hadoop.metrics.MetricsSource)>(v, v, v, v); specialinvoke v.(v, v); return v; } public synchronized void unregisterSource(java.lang.String) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.util.Map v, v, v, v, v, v, v; java.lang.Object v; java.lang.String v; boolean v, v, v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: java.lang.String; v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); virtualinvoke v.(); v = v.; interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; interfaceinvoke v.(v); label: staticinvoke (v); return; } synchronized void registerSource(java.lang.String, java.lang.String, oadd.org.apache.hadoop.metrics.MetricsSource) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; long v; oadd.org.apache.hadoop.metrics.MetricsSource v; java.util.Map v, v; java.lang.String v, v, v, v; oadd.org.apache.hadoop.metrics.impl.MetricsSourceAdapter v; org.slf4j.Logger v; oadd.org.apache.hadoop.metrics.impl.MetricsConfig v, v, v; java.util.List v; java.lang.Object v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: oadd.org.apache.hadoop.metrics.MetricsSource; v = v.; staticinvoke (v, "config"); v = v.; v = interfaceinvoke v.(v); v = new oadd.org.apache.hadoop.metrics.impl.MetricsSourceAdapter; v = v.; v = v.; v = v.; if v == null goto label; v = v; goto label; label: v = v.; v = virtualinvoke v.("source"); label: specialinvoke v.(java.lang.String,java.lang.String,java.lang.String,oadd.org.apache.hadoop.metrics.MetricsSource,java.lang.Iterable,long,oadd.org.apache.hadoop.metrics.impl.MetricsConfig)>(v, v, v, v, v, v, v); v = v.; interfaceinvoke v.(v, v); virtualinvoke v.(); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Registered source \u0001"); interfaceinvoke v.(v); return; } public synchronized oadd.org.apache.hadoop.metrics.MetricsSink register(java.lang.String, java.lang.String, oadd.org.apache.hadoop.metrics.MetricsSink) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; org.slf4j.Logger v, v; oadd.org.apache.hadoop.metrics.impl.MetricsConfig v; oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl$2 v; oadd.org.apache.hadoop.metrics.MetricsSink v; java.util.Map v, v, v; java.lang.Object v; java.lang.String v, v, v, v; boolean v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: oadd.org.apache.hadoop.metrics.MetricsSink; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u, \u0001"); interfaceinvoke v.(v); v = v.; v = interfaceinvoke v.(v); if v == 0 goto label; v = v.; v = interfaceinvoke v.(v); if v != null goto label; virtualinvoke v.(v, v, v); goto label; label: v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Sink \u already exists!"); interfaceinvoke v.(v); label: return v; label: v = v.; interfaceinvoke v.(v, v); v = v.; if v == null goto label; virtualinvoke v.(v, v, v); label: v = new oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl$2; specialinvoke v.(oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl,java.lang.String,java.lang.String,oadd.org.apache.hadoop.metrics.MetricsSink)>(v, v, v, v); specialinvoke v.(v, v); return v; } synchronized void registerSink(java.lang.String, java.lang.String, oadd.org.apache.hadoop.metrics.MetricsSink) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; org.slf4j.Logger v; oadd.org.apache.hadoop.metrics.impl.MetricsConfig v, v, v; oadd.org.apache.hadoop.metrics.MetricsSink v; oadd.org.apache.hadoop.metrics.impl.MetricsSinkAdapter v; java.util.Map v, v; java.lang.Object v; java.lang.String v, v, v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: oadd.org.apache.hadoop.metrics.MetricsSink; v = v.; staticinvoke (v, "config"); v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = staticinvoke (v, v, v, v); goto label; label: v = v.; v = virtualinvoke v.("sink"); v = staticinvoke (v, v, v, v); label: v = v.; interfaceinvoke v.(v, v); virtualinvoke v.(); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Registered sink \u0001"); interfaceinvoke v.(v); return; } public synchronized void register(oadd.org.apache.hadoop.metrics.MetricsSystem$Callback) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.util.List v; oadd.org.apache.hadoop.metrics.MetricsSystem$Callback v; java.lang.Object v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: oadd.org.apache.hadoop.metrics.MetricsSystem$Callback; v = v.; v = specialinvoke v.(v); interfaceinvoke v.(v); return; } private synchronized void register(java.lang.String, oadd.org.apache.hadoop.metrics.MetricsSystem$Callback) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; oadd.org.apache.hadoop.metrics.MetricsSystem$Callback v; java.util.Map v; java.lang.Object v; java.lang.String v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: java.lang.String; v := @parameter: oadd.org.apache.hadoop.metrics.MetricsSystem$Callback; v = v.; v = specialinvoke v.(v); interfaceinvoke v.(v, v); return; } private java.lang.Object getProxyForCallback(oadd.org.apache.hadoop.metrics.MetricsSystem$Callback) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl$3 v; oadd.org.apache.hadoop.metrics.MetricsSystem$Callback v; java.lang.Class[] v; java.lang.Class v; java.lang.Object v; java.lang.ClassLoader v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: oadd.org.apache.hadoop.metrics.MetricsSystem$Callback; v = virtualinvoke v.(); v = virtualinvoke v.(); v = newarray (java.lang.Class)[1]; v[0] = class "Loadd/org/apache/hadoop/metrics2/MetricsSystem$Callback;"; v = new oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl$3; specialinvoke v.(oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl,oadd.org.apache.hadoop.metrics.MetricsSystem$Callback)>(v, v); v = staticinvoke (v, v, v); return v; } public synchronized void startMetricsMBeans() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.util.Iterator v; java.util.Collection v; java.util.Map v; java.lang.Object v; boolean v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: return; } public synchronized void stopMetricsMBeans() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.util.Iterator v; java.util.Collection v; java.util.Map v; java.lang.Object v; boolean v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(); goto label; label: return; } public synchronized java.lang.String currentConfig() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.io.StringWriter v; oadd.org.apache.commons.configuration.PropertiesConfiguration v; java.lang.String v; oadd.org.apache.hadoop.metrics.impl.MetricsConfigException v; oadd.org.apache.hadoop.metrics.impl.MetricsConfig v; java.lang.Exception v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = new oadd.org.apache.commons.configuration.PropertiesConfiguration; specialinvoke v.()>(); v = new java.io.StringWriter; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); label: virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = new oadd.org.apache.hadoop.metrics.impl.MetricsConfigException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Error stringify config", v); throw v; label: v = virtualinvoke v.(); return v; catch java.lang.Exception from label to label with label; } private synchronized void startTimer() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; org.slf4j.Logger v, v; java.util.Timer v, v, v; long v, v, v; oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl$4 v; java.lang.String v, v, v, v, v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; if v == null goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system timer already started!"); interfaceinvoke v.(v); return; label: v. = 0L; v = v.; v = new java.util.Timer; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("Timer for \'\u0001\' metrics system"); specialinvoke v.(java.lang.String,boolean)>(v, 1); v. = v; v = v.; v = new oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl$4; specialinvoke v.(oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl)>(v); virtualinvoke v.(v, v, v); v = ; v = v.; v = v / 1000L; v = dynamicinvoke "makeConcatWithConstants" (v) ("Scheduled Metric snapshot period at \u second(s)."); interfaceinvoke v.(v); return; } synchronized void onTimerEvent() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; oadd.org.apache.hadoop.metrics.impl.MetricsBuffer v; java.util.Map v; int v; long v, v, v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; v = v.; v = v + v; v. = v; v = v.; v = interfaceinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v, 0); label: return; } public synchronized void publishMetricsNow() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; oadd.org.apache.hadoop.metrics.impl.MetricsBuffer v; java.util.Map v; int v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; v = interfaceinvoke v.(); if v <= 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v, 1); label: return; } public synchronized oadd.org.apache.hadoop.metrics.impl.MetricsBuffer sampleMetrics() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; oadd.org.apache.hadoop.metrics.impl.MetricsBuffer v; oadd.org.apache.hadoop.metrics.impl.MetricsCollectorImpl v; oadd.org.apache.hadoop.metrics.MetricsFilter v, v; java.util.Map v; oadd.org.apache.hadoop.metrics.impl.MetricsSourceAdapter v; boolean v, v, v; java.util.Iterator v; java.util.Set v; oadd.org.apache.hadoop.metrics.impl.MetricsBufferBuilder v; java.lang.Object v, v, v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; virtualinvoke v.(); v = new oadd.org.apache.hadoop.metrics.impl.MetricsBufferBuilder; specialinvoke v.()>(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = interfaceinvoke v.(); specialinvoke v.(v, v); goto label; label: v = v.; if v == 0 goto label; v = v.; specialinvoke v.(v, v); label: v = virtualinvoke v.(); return v; } private void snapshotMetrics(oadd.org.apache.hadoop.metrics.impl.MetricsSourceAdapter, oadd.org.apache.hadoop.metrics.impl.MetricsBufferBuilder) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; org.slf4j.Logger v; oadd.org.apache.hadoop.metrics.impl.MetricsBufferBuilder v; long v, v, v; oadd.org.apache.hadoop.metrics.impl.MetricsCollectorImpl v, v; java.lang.Iterable v; oadd.org.apache.hadoop.metrics.lib.MutableStat v; java.lang.String v, v, v; oadd.org.apache.hadoop.metrics.impl.MetricsSourceAdapter v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: oadd.org.apache.hadoop.metrics.impl.MetricsSourceAdapter; v := @parameter: oadd.org.apache.hadoop.metrics.impl.MetricsBufferBuilder; v = staticinvoke (); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v, 1); virtualinvoke v.(v, v); v = v.; virtualinvoke v.(); v = v.; v = staticinvoke (); v = v - v; virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Snapshotted source \u0001"); interfaceinvoke v.(v); return; } synchronized void publishMetrics(oadd.org.apache.hadoop.metrics.impl.MetricsBuffer, boolean) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; oadd.org.apache.hadoop.metrics.impl.MetricsBuffer v; long v, v, v, v; oadd.org.apache.hadoop.metrics.lib.MutableCounterLong v; java.util.Map v; int v, v; boolean v, v, v, v; java.util.Iterator v; java.util.Collection v; oadd.org.apache.hadoop.metrics.lib.MutableStat v; java.lang.Object v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: oadd.org.apache.hadoop.metrics.impl.MetricsBuffer; v := @parameter: boolean; v = 0; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = staticinvoke (); if v == 0 goto label; v = virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(v, v); label: v = v; if v == 0 goto label; v = 0; goto label; label: v = 1; label: v = v + v; v = v.; v = staticinvoke (); v = v - v; virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(v); return; } private synchronized void stopTimer() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; org.slf4j.Logger v; java.util.Timer v, v; java.lang.String v, v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; if v != null goto label; v = ; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("\u metrics system timer already stopped!"); interfaceinvoke v.(v); return; label: v = v.; virtualinvoke v.(); v. = null; return; } private synchronized void stopSources() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; org.slf4j.Logger v; java.util.Iterator v; java.util.Set v; oadd.org.apache.hadoop.metrics.MetricsSource v; java.util.Map v, v; java.lang.Class v; java.lang.Object v, v, v; java.lang.String v; oadd.org.apache.hadoop.metrics.impl.MetricsSourceAdapter v; boolean v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Stopping metrics source \u0001: class=\u0001"); interfaceinvoke v.(v); virtualinvoke v.(); goto label; label: v = v.; virtualinvoke v.(); v = v.; interfaceinvoke v.(); return; } private synchronized void stopSinks() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; org.slf4j.Logger v; java.util.Iterator v; java.util.Set v; oadd.org.apache.hadoop.metrics.MetricsSink v; java.util.Map v, v; java.lang.Class v; java.lang.Object v, v, v; java.lang.String v; boolean v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Stopping metrics sink \u0001: class=\u0001"); interfaceinvoke v.(v); virtualinvoke v.(); goto label; label: v = v.; interfaceinvoke v.(); return; } private synchronized void configure(java.lang.String) { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.lang.String v; oadd.org.apache.hadoop.metrics.impl.MetricsConfig v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v := @parameter: java.lang.String; v = staticinvoke (v); v. = v; specialinvoke v.(); specialinvoke v.(); specialinvoke v.(); return; } private synchronized void configureSystem() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; java.util.List v; oadd.org.apache.hadoop.metrics.MetricsTag v; java.lang.String v; oadd.org.apache.hadoop.metrics.impl.MsInfo v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.; v = ; v = staticinvoke (); v = staticinvoke (v, v); interfaceinvoke v.(v); return; } private synchronized void configureSinks() { oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl v; long v, v, v, v, v; byte v, v; oadd.org.apache.hadoop.metrics.impl.MetricsSinkAdapter v; java.util.Map v, v, v; int v, v, v; java.lang.String v, v, v; boolean v; org.slf4j.Logger v; java.util.Iterator v; java.util.Set v; oadd.org.apache.hadoop.metrics.impl.MetricsConfig v, v, v; java.lang.Exception v; java.lang.Object v, v, v; v := @this: oadd.org.apache.hadoop.metrics.impl.MetricsSystemImpl; v = v.