Attachment 593763 Details for Bug 821058 – patch to measurement subsystem in PC

[patch] patch to measurement subsystem in PC

bz821058.patch (text/plain), 2.13 KB, created by John Mazzitelli on 2012-06-22 14:11:30 UTC

(hide)

Description:

Filename:

MIME Type:

Creator: John Mazzitelli

Created: 2012-06-22 14:11:30 UTC

Size: 2.13 KB

patch

obsolete

>diff --git a/modules/core/plugin-container/src/main/java/org/rhq/core/pc/measurement/MeasurementCollectorRunner.java b/modules/core/plugin-container/src/main/java/org/rhq/core/pc/measurement/MeasurementCollectorRunner.java
>index 3714ad9..ac13b06 100644
>--- a/modules/core/plugin-container/src/main/java/org/rhq/core/pc/measurement/MeasurementCollectorRunner.java
>+++ b/modules/core/plugin-container/src/main/java/org/rhq/core/pc/measurement/MeasurementCollectorRunner.java
>@@ -23,6 +23,7 @@
> package org.rhq.core.pc.measurement;
> 
> import java.util.ArrayDeque;
>+import java.util.Collections;
> import java.util.Date;
> import java.util.Set;
> import java.util.concurrent.Callable;
>@@ -130,7 +131,7 @@ public class MeasurementCollectorRunner implements Callable<MeasurementReport>,
>         Set<? extends MeasurementScheduleRequest> requests, Resource resource) {
>         try {
>             long start = System.currentTimeMillis();
>-            measurementComponent.getValues(report, (Set<MeasurementScheduleRequest>) requests);
>+            measurementComponent.getValues(report, Collections.unmodifiableSet(requests));
>             long duration = (System.currentTimeMillis() - start);
>             if (duration > 2000L) {
>                 String message = "[PERF] Collection of measurements for [" + resource + "] (component=["
>diff --git a/modules/core/plugin-container/src/main/java/org/rhq/core/pc/measurement/MeasurementManager.java b/modules/core/plugin-container/src/main/java/org/rhq/core/pc/measurement/MeasurementManager.java
>index 9ab82cb..dc7d0ca 100644
>--- a/modules/core/plugin-container/src/main/java/org/rhq/core/pc/measurement/MeasurementManager.java
>+++ b/modules/core/plugin-container/src/main/java/org/rhq/core/pc/measurement/MeasurementManager.java
>@@ -469,7 +469,7 @@ public class MeasurementManager extends AgentService implements MeasurementAgent
>         }
> 
>         try {
>-            measurementFacet.getValues(report, requests);
>+            measurementFacet.getValues(report, Collections.unmodifiableSet(requests));
>         } catch (Throwable t) {
>             LOG.error("Could not get measurement values", t);
>             return Collections.emptySet();

Actions: View | Diff

Attachments on bug 821058: 593763