public class oadd.org.apache.hadoop.metrics.sink.StatsDSink extends java.lang.Object implements oadd.org.apache.hadoop.metrics.MetricsSink, java.io.Closeable { private static final org.slf4j.Logger LOG; private static final java.lang.String PERIOD; private static final java.lang.String SERVER_HOST_KEY; private static final java.lang.String SERVER_PORT_KEY; private static final java.lang.String HOST_NAME_KEY; private static final java.lang.String SERVICE_NAME_KEY; private static final java.lang.String SKIP_HOSTNAME_KEY; private boolean skipHostname; private java.lang.String hostName; private java.lang.String serviceName; private oadd.org.apache.hadoop.metrics.sink.StatsDSink$StatsD statsd; public void () { oadd.org.apache.hadoop.metrics.sink.StatsDSink v; v := @this: oadd.org.apache.hadoop.metrics.sink.StatsDSink; specialinvoke v.()>(); v. = 0; v. = null; v. = null; v. = null; return; } public void init(oadd.org.apache.commons.configuration.SubsetConfiguration) { oadd.org.apache.hadoop.metrics.sink.StatsDSink v; oadd.org.apache.hadoop.metrics.sink.StatsDSink$StatsD v; oadd.org.apache.commons.configuration.SubsetConfiguration v; int v; java.lang.String v, v, v, v, v, v; boolean v, v; v := @this: oadd.org.apache.hadoop.metrics.sink.StatsDSink; v := @parameter: oadd.org.apache.commons.configuration.SubsetConfiguration; v = virtualinvoke v.("server.host"); v = virtualinvoke v.("server.port"); v = staticinvoke (v); v = virtualinvoke v.("skip.hostname", 0); v. = v; v = v.; if v != 0 goto label; v = virtualinvoke v.("host.name", null); v. = v; v = v.; if null != v goto label; v = staticinvoke (); v. = v; label: v = virtualinvoke v.("service.name", null); v. = v; v = new oadd.org.apache.hadoop.metrics.sink.StatsDSink$StatsD; specialinvoke v.(java.lang.String,int)>(v, v); v. = v; return; } public void putMetrics(oadd.org.apache.hadoop.metrics.MetricsRecord) { oadd.org.apache.hadoop.metrics.sink.StatsDSink v; boolean v, v, v, v, v, v, v, v; java.util.Collection v; oadd.org.apache.hadoop.metrics.MetricsInfo v, v, v; oadd.org.apache.hadoop.metrics.MetricsRecord v; java.lang.StringBuilder v, v, v, v, v, v, v, v, v, v, v, v; oadd.org.apache.hadoop.metrics.impl.MsInfo v, v, v; java.lang.Iterable v; int v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.Number v; java.util.Iterator v, v; oadd.org.apache.hadoop.metrics.MetricType v, v, v, v; java.lang.Object v, v; v := @this: oadd.org.apache.hadoop.metrics.sink.StatsDSink; v := @parameter: oadd.org.apache.hadoop.metrics.MetricsRecord; v = v.; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); goto label; label: v = new java.lang.StringBuilder; specialinvoke v.()>(); v = v.; if v != 0 goto label; if v == null goto label; v = virtualinvoke v.("."); v = (int) -1; if v != v goto label; v = virtualinvoke v.(v); virtualinvoke v.("."); goto label; label: v = virtualinvoke v.(0, v); v = virtualinvoke v.(v); virtualinvoke v.("."); label: v = virtualinvoke v.(v); virtualinvoke v.("."); v = virtualinvoke v.(v); virtualinvoke v.("."); v = interfaceinvoke v.(); v = virtualinvoke v.("\\.", "-"); v = virtualinvoke v.(v); virtualinvoke v.("."); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = null; v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = "c"; goto label; label: v = virtualinvoke v.(); v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = "g"; label: v = new java.lang.StringBuilder; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(32, 95); v = virtualinvoke v.(v); v = virtualinvoke v.(":"); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.("|"); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: return; } public void writeMetric(java.lang.String) { oadd.org.apache.hadoop.metrics.MetricsException v; oadd.org.apache.hadoop.metrics.sink.StatsDSink$StatsD v; org.slf4j.Logger v; java.io.IOException v; java.lang.String v; oadd.org.apache.hadoop.metrics.sink.StatsDSink v; v := @this: oadd.org.apache.hadoop.metrics.sink.StatsDSink; v := @parameter: java.lang.String; label: v = v.; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error sending metrics to StatsD", v); v = new oadd.org.apache.hadoop.metrics.MetricsException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Error writing metric to StatsD", v); throw v; label: return; catch java.io.IOException from label to label with label; } public void flush() { oadd.org.apache.hadoop.metrics.sink.StatsDSink v; v := @this: oadd.org.apache.hadoop.metrics.sink.StatsDSink; return; } public void close() throws java.io.IOException { oadd.org.apache.hadoop.metrics.sink.StatsDSink$StatsD v; oadd.org.apache.hadoop.metrics.sink.StatsDSink v; v := @this: oadd.org.apache.hadoop.metrics.sink.StatsDSink; v = v.; virtualinvoke v.(); return; } static void () { org.slf4j.Logger v; v = staticinvoke (class "Loadd/org/apache/hadoop/metrics2/sink/StatsDSink;"); = v; return; } }