Fix GCPerformanceCounter not working

Author: trask

core/src/main/java/com/microsoft/applicationinsights/internal/perfcounter/JvmPerformanceCountersFactory.java

@@ -27,6 +27,7 @@
 
 import com.microsoft.applicationinsights.internal.logger.InternalLogger;
 import com.microsoft.applicationinsights.internal.perfcounter.jvm.DeadLockDetectorPerformanceCounter;
+import com.microsoft.applicationinsights.internal.perfcounter.jvm.GCPerformanceCounter;
 import com.microsoft.applicationinsights.internal.perfcounter.jvm.JvmHeapMemoryUsedPerformanceCounter;
 import org.apache.commons.lang3.exception.ExceptionUtils;
 
@@ -45,6 +46,7 @@ public Collection<PerformanceCounter> getPerformanceCounters() {
         if (isEnabled) {
             addDeadLockDetector(pcs);
             addJvmMemoryPerformanceCounter(pcs);
+            addGCPerformanceCounter(pcs);
         } else {
             InternalLogger.INSTANCE.trace("JvmPerformanceCountersFactory is disabled");
         }
@@ -99,7 +101,28 @@ private void addJvmMemoryPerformanceCounter(ArrayList<PerformanceCounter> pcs) {
             } catch (Throwable t2) {
                 // chomp
             }
+        }
+    }
 
+    private void addGCPerformanceCounter(ArrayList<PerformanceCounter> pcs) {
+        try {
+            if (disabledJvmPCs.contains(GCPerformanceCounter.NAME)) {
+                return;
+            }
+
+            GCPerformanceCounter mpc = new GCPerformanceCounter();
+            pcs.add(mpc);
+        } catch (ThreadDeath td) {
+            throw td;
+        } catch (Throwable t) {
+            try {
+                InternalLogger.INSTANCE.error("Failed to create GCPerformanceCounter, exception: %s",
+                        ExceptionUtils.getStackTrace(t));
+            } catch (ThreadDeath td) {
+                throw td;
+            } catch (Throwable t2) {
+                // chomp
+            }
         }
     }
 

core/src/main/java/com/microsoft/applicationinsights/internal/perfcounter/jvm/GCPerformanceCounter.java

@@ -80,7 +80,7 @@ public void report(TelemetryClient telemetryClient) {
             MetricTelemetry mtTotalTime = new MetricTelemetry(GC_TOTAL_TIME, timeToReport);
 
             mtTotalCount.markAsCustomPerfCounter();
-            mtTotalCount.markAsCustomPerfCounter();
+            mtTotalTime.markAsCustomPerfCounter();
 
             telemetryClient.track(mtTotalCount);
             telemetryClient.track(mtTotalTime);

test/smoke/testApps/AutoPerfCounters/src/smokeTest/java/com/microsoft/applicationinsights/smoketest/PerfCountersDataTest.java

@@ -26,8 +26,10 @@ public void testPerformanceCounterData() throws Exception {
 
         // we should get these envelopes:
         //      MetricData, metrics.name="Suspected Deadlocked Threads"
-        //      PerformanceCounterData, categoryName=Memory, counterName=Available Bytes
         //      MetricData, metrics.name="Heap Memory Used (MB)"
+        //      MetricData, metrics.name="GC Total Count"
+        //      MetricData, metrics.name="GC Total Time"
+        //      PerformanceCounterData, categoryName=Memory, counterName=Available Bytes
         //      PerformanceCounterData, category=Process, counter="IO Data Bytes/sec"
         //      PerformanceCounterData, category=Processor, counter="% Processor Time", instance="_Total"
         //      PerformanceCounterData, category=Process, counter=Private Bytes
@@ -59,6 +61,10 @@ public void testPerformanceCounterData() throws Exception {
         System.out.println("Waiting for metric data...");
         Envelope deadlocks = mockedIngestion.waitForItem(getPerfMetricPredicate("Suspected Deadlocked Threads"), 150, TimeUnit.SECONDS);
         Envelope heapUsed = mockedIngestion.waitForItem(getPerfMetricPredicate("Heap Memory Used (MB)"), 150, TimeUnit.SECONDS);
+        Envelope gcTotalCount = mockedIngestion.waitForItem(getPerfMetricPredicate("GC Total Count"), 150,
+                TimeUnit.SECONDS);
+        Envelope gcTotalTime = mockedIngestion.waitForItem(getPerfMetricPredicate("GC Total Time"), 150,
+                TimeUnit.SECONDS);
         System.out.println("MetricData are good: " + (System.currentTimeMillis() - start));
 
         MetricData mdDeadlocks = getBaseData(deadlocks);
@@ -68,6 +74,12 @@ public void testPerformanceCounterData() throws Exception {
         MetricData mdHeapUsed = getBaseData(heapUsed);
         assertPerfMetric(mdHeapUsed);
         assertTrue(mdHeapUsed.getMetrics().get(0).getValue() > 0.0);
+
+        MetricData mdGcTotalCount = getBaseData(gcTotalCount);
+        assertPerfMetric(mdGcTotalCount);
+
+        MetricData mdGcTotalTime = getBaseData(gcTotalTime);
+        assertPerfMetric(mdGcTotalTime);
     }
 
     private void assertSameInstanceName(Envelope... envelopes) {