Examples of MeasurementFacet

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

455
456
457
458
459
460
461
462
463
464
465
466
467
468
469
470
471
472
473
474
475
476
477
478
479
480
481
482
483
484
485
486
487
488
489
490
    public Set<MeasurementData> getRealTimeMeasurementValue(int resourceId, Set<MeasurementScheduleRequest> requests) {
        if (requests.size() == 0) {
            // There's no need to even call getValues() on the ResourceComponent if the list of metric names is empty.
            return Collections.emptySet();
        }
        MeasurementFacet measurementFacet;
        ResourceContainer resourceContainer = inventoryManager.getResourceContainer(resourceId);
        if (resourceContainer == null) {
            LOG.warn("Can not get resource container for resource with id " + resourceId);
            return Collections.emptySet();
        }
        Resource resource = resourceContainer.getResource();
        ResourceType resourceType = resource.getResourceType();
        if (resourceType.getMetricDefinitions().isEmpty())
            return Collections.emptySet();

        try {
            measurementFacet = ComponentUtil.getComponent(resourceId, MeasurementFacet.class, FacetLockType.READ,
                FACET_METHOD_TIMEOUT, true, true, true);
        } catch (Exception e) {
            LOG.warn("Cannot get measurement facet for Resource [" + resourceId + "]. Cause: " + e);
            return Collections.emptySet();
        }

        MeasurementReport report = new MeasurementReport();
        for (MeasurementScheduleRequest request : requests) {
            request.setEnabled(true);
        }

        try {
            measurementFacet.getValues(report, Collections.unmodifiableSet(requests));
        } catch (Throwable t) {
            LOG.error("Could not get measurement values", t);
            return Collections.emptySet();
        }
View Full Code Here

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

98
99
100
101
102
103
104
105
106
107
108
                    if (log.isDebugEnabled()) {
                        log.debug("Measurements not collected for inactive resource component: "
                            + container.getResource());
                    }
                } else {
                    MeasurementFacet measurementComponent = ComponentUtil
                        .getComponent(resourceId, MeasurementFacet.class, FacetLockType.READ,
                            MeasurementManager.FACET_METHOD_TIMEOUT, true, true, true);

                    if (log.isDebugEnabled()) {
                        scheduleHistory.addRequests(requests);
View Full Code Here

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

641
642
643
644
645
646
647
648
649
650
651
652
653
654
655
656
657
658
659
        ResourceContainer resourceContainer = this.pluginContainer.getInventoryManager().getResourceContainer(resource);
        long timeoutMillis = 5000;
        if (resourceContainer.getResourceComponentState() != ResourceContainer.ResourceComponentState.STARTED) {
            throw new IllegalStateException("Resource component for " + resource + " has not yet been started.");
        }
        MeasurementFacet measurementFacet = resourceContainer.createResourceComponentProxy(MeasurementFacet.class,
            FacetLockType.READ, timeoutMillis, false, false, false);
        MeasurementReport report = new MeasurementReport();
        MeasurementScheduleRequest request = new MeasurementScheduleRequest(-1, metricName, -1, true,
            measurementDefinition.getDataType(), measurementDefinition.getRawNumericType());
        Set<MeasurementScheduleRequest> requests = new HashSet<MeasurementScheduleRequest>();
        requests.add(request);
        try {
            measurementFacet.getValues(report, requests);
        } catch (Exception e) {
            System.out.println("====== Error occurred during collection of metric [" + metricName + "] on " + resource
                + ": " + e);
            throw new RuntimeException("Error occurred during collection of metric [" + metricName + "] on " + resource
                + ": " + e);
View Full Code Here

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

235
236
237
238
239
240
241
242
243
244
245
246
247
248
249
250
251
252
    private void testRuntimeResourceMeasurements(RuntimeServiceType runtimeServiceType) throws Exception {
        Set<Resource> resources = getChildResourcesOfType(getDeploymentResource(),
            runtimeServiceType.getServiceTypeName());
        for (Resource resource : resources) {
            MeasurementFacet measurementFacet = getMeasurementFacet(resource);
            // TODO (jshaughn) see why we get into this occasionally
            System.out.println("--->>> " + resource + " MeasurementFacet=" + measurementFacet);
            if (null == measurementFacet)
                continue;
            MeasurementReport report = new MeasurementReport();
            Set<MeasurementScheduleRequest> measurementScheduleRequests = getMeasurementScheduleRequests(resource);
            measurementFacet.getValues(report, measurementScheduleRequests);
            assertEquals(report.getCallTimeData().size(), 0, runtimeServiceType.getServiceTypeName()
                + ": no calltime data was requested");
            assertEquals(
                report.getNumericData().size() + report.getTraitData().size(),
                measurementScheduleRequests.size(),
View Full Code Here

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
    @Test(dependsOnMethods = "testServiceDiscovery")
    public void testMeasurement() throws Exception {
        Set<Resource> childResources = getChildResourcesOfType(jmxServerResource, OPERATING_SYSTEM_RESOURCE_TYPE);
        assertEquals(childResources.size(), 1, String.valueOf(childResources));

        MeasurementFacet measurementFacet = getResourceComponentFacet(childResources.iterator().next(),
            MeasurementFacet.class);
        Set<MeasurementScheduleRequest> metricList = new HashSet<MeasurementScheduleRequest>();
        metricList.add(new MeasurementScheduleRequest(1, "CommittedVirtualMemorySize", 1000, true, MEASUREMENT));

        MeasurementReport report = new MeasurementReport();
        measurementFacet.getValues(report, metricList);
        Map<String, Object> metricsData = getMetricsData(report);

        assertTrue(getMetric(metricsData, "CommittedVirtualMemorySize") > 0);
    }
View Full Code Here

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

224
225
226
227
228
229
230
231
232
233
234
235
236
237
238
        assertEquals(webRuntimeResources.size(), 1, "Found more than one Web Runtime resource: " + webRuntimeResources);

        Resource webRuntimeResource = webRuntimeResources.iterator().next();
        ResourceContainer webRuntimeResourceContainer = pluginContainer.getInventoryManager().getResourceContainer(
            webRuntimeResource);
        MeasurementFacet measurementFacet = webRuntimeResourceContainer.createResourceComponentProxy(
            MeasurementFacet.class, FacetLockType.READ, SECONDS.toMillis(5), false, false, false);
        MeasurementReport report = new MeasurementReport();
        Set<MeasurementScheduleRequest> measurementScheduleRequests = getMeasurementScheduleRequests(webRuntimeResource);
        measurementFacet.getValues(report, measurementScheduleRequests);
        assertEquals(report.getCallTimeData().size(), 0, "No calltime data was requested");
        assertTrue(
            report.getNumericData().size() + report.getTraitData().size() == measurementScheduleRequests.size(),
            "Some requested measurements are missing: "
                + getMissingMeasurements(measurementScheduleRequests, report.getNumericData(), report.getTraitData()));
View Full Code Here

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

274
275
276
277
278
279
280
281
282
283
284
285
286
287
288
289
290
    public void testMeasurement() throws Exception {
        for (Resource jmxServer : jmxServers) {
            Set<Resource> childResources = getChildResourcesOfType(jmxServer, OPERATING_SYSTEM_RESOURCE_TYPE);
            assertEquals(childResources.size(), 1, String.valueOf(childResources));

            MeasurementFacet measurementFacet = getResourceComponentFacet(childResources.iterator().next(),
                MeasurementFacet.class);
            Set<MeasurementScheduleRequest> metricList = new HashSet<MeasurementScheduleRequest>();
            metricList.add(new MeasurementScheduleRequest(1, "CommittedVirtualMemorySize", 1000, true, MEASUREMENT));

            MeasurementReport report = new MeasurementReport();
            measurementFacet.getValues(report, metricList);
            Map<String, Object> metricsData = getMetricsData(report);

            assertTrue(getMetric(metricsData, "CommittedVirtualMemorySize") > 0);
        }
    }
View Full Code Here

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
        if (supportsFacet(MeasurementFacet.class)) {
            Set<MeasurementDefinition> metricDefinitions = getResourceType().getMetricDefinitions();
            Set<Resource> resources = getResources();
            for (Resource resource : resources) {
                System.out.println("Validating metrics for " + resource + "...");
                MeasurementFacet measurementFacet = ComponentUtil.getComponent(resource.getId(),
                    MeasurementFacet.class, FacetLockType.READ, MEASUREMENT_FACET_METHOD_TIMEOUT, true, true, true);
                for (MeasurementDefinition metricDefinition : metricDefinitions) {
                    String name = metricDefinition.getName();
                    try {
                        DataType dataType = metricDefinition.getDataType();
                        if (dataType == DataType.MEASUREMENT || metricDefinition.getDataType() == DataType.TRAIT) {
                            MeasurementReport report = new MeasurementReport();
                            Set<MeasurementScheduleRequest> requests = new HashSet<MeasurementScheduleRequest>();
                            MeasurementScheduleRequest request = new MeasurementScheduleRequest(1, metricDefinition
                                .getName(), 0, true, metricDefinition.getDataType());
                            requests.add(request);
                            measurementFacet.getValues(report, requests);
                            if (dataType == DataType.MEASUREMENT) {
                                assert report.getNumericData().isEmpty() || report.getNumericData().size() == 1;
                                assert report.getTraitData().isEmpty();
                                assert report.getCallTimeData().isEmpty();
                                MeasurementDataNumeric dataNumeric = (report.getNumericData().isEmpty()) ? null
View Full Code Here

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

117
118
119
120
121
122
123
124
125
126
127
  }

  public static String getMetricValue(Resource resource, String metricName)
      throws Exception {

    MeasurementFacet measurementFacet = ComponentUtil
        .getComponent(resource.getId(), MeasurementFacet.class,
            FacetLockType.READ,
            CacheComponentTest.MEASUREMENT_FACET_METHOD_TIMEOUT,
            true, true, true);
    ResourceType resourceType = resource.getResourceType();
View Full Code Here

Examples of org.rhq.core.pluginapi.measurement.MeasurementFacet

178
179
180
181
182
183
184
185
186
187
188
    Set<Resource> resources = TestHelper.getResources(cacheResourceType);

    for (Resource resource : resources) {
      log.info("Validating metrics for " + resource + "...");

      MeasurementFacet measurementFacet = ComponentUtil.getComponent(
          resource.getId(), MeasurementFacet.class,
          FacetLockType.READ, MEASUREMENT_FACET_METHOD_TIMEOUT, true,
          true, true);
      EmsBean relatedBean = connection.getBean(resource.getResourceKey());
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.