/*
* ============LICENSE_START=======================================================
- * Copyright (C) 2023 Nordix Foundation
+ * Copyright (C) 2023-2025 OpenInfra Foundation Europe. All rights reserved.
* ================================================================================
* Licensed under the Apache License, Version 2.0 (the 'License');
* you may not use this file except in compliance with the License.
package org.onap.cps.integration.performance.ncmp
-import org.onap.cps.integration.ResourceMeter
-import java.util.stream.Collectors
import org.onap.cps.api.CpsQueryService
import org.onap.cps.integration.performance.base.NcmpPerfTestBase
-import static org.onap.cps.spi.FetchDescendantsOption.OMIT_DESCENDANTS
-import static org.onap.cps.spi.FetchDescendantsOption.INCLUDE_ALL_DESCENDANTS
+
+import java.util.stream.Collectors
+
+import static org.onap.cps.api.parameters.FetchDescendantsOption.INCLUDE_ALL_DESCENDANTS
+import static org.onap.cps.api.parameters.FetchDescendantsOption.OMIT_DESCENDANTS
class CmHandleQueryPerfTest extends NcmpPerfTestBase {
CpsQueryService objectUnderTest
- ResourceMeter resourceMeter = new ResourceMeter()
def setup() { objectUnderTest = cpsQueryService }
+ def 'JVM warmup.'() {
+ when: 'the JVM is warmed up'
+ def iterations = TOTAL_CM_HANDLES * 0.1
+ resourceMeter.start()
+ (1..iterations).forEach {
+ cpsDataService.getDataNodes(NCMP_PERFORMANCE_TEST_DATASPACE, REGISTRY_ANCHOR, "/dmi-registry/cm-handles[@id='cm-${it}']", OMIT_DESCENDANTS)
+ objectUnderTest.queryDataNodes(NCMP_PERFORMANCE_TEST_DATASPACE, REGISTRY_ANCHOR, "/dmi-registry/cm-handles[@alternate-id='alt-${it}']", OMIT_DESCENDANTS)
+ }
+ resourceMeter.stop()
+ then: 'resource usage is as expected'
+ recordAndAssertResourceUsage('NCMP:JVM warmup for CmHandleQueryPerfTest', 42, resourceMeter.totalTimeInSeconds, resourceMeter.totalMemoryUsageInMB)
+ }
+
def 'Query CM Handle IDs by a property name and value.'() {
when: 'a cps-path query on name-value pair is performed (without getting descendants)'
resourceMeter.start()
def result = cpsDataService.getDataNodesForMultipleXpaths(NCMP_PERFORMANCE_TEST_DATASPACE, REGISTRY_ANCHOR, xpaths, INCLUDE_ALL_DESCENDANTS)
resourceMeter.stop()
def durationInSeconds = resourceMeter.getTotalTimeInSeconds()
- then: 'the required operations are performed within 1200 ms'
- recordAndAssertResourceUsage("CpsPath Registry attributes Query", 0.25, durationInSeconds, 150, resourceMeter.getTotalMemoryUsageInMB())
- and: 'all but 1 (other node) are returned'
- result.size() == 999
+ then: 'the required operations are performed within required time'
+ recordAndAssertResourceUsage('NCMP:CpsPath Registry attributes Query', 3, durationInSeconds, resourceMeter.getTotalMemoryUsageInMB(), REFERENCE_GRAPH)
+ and: 'all nodes are returned'
+ result.size() == TOTAL_CM_HANDLES
and: 'the tree contains all the expected descendants too'
- assert countDataNodesInTree(result) == 5 * 999
+ assert countDataNodesInTree(result) == 5 * TOTAL_CM_HANDLES
+ }
+
+ def 'CM-handle is looked up by id.'() {
+ when: 'CM-handles are looked up by cm-handle-id 100 times'
+ int count = 0
+ resourceMeter.start()
+ (1..100).each {
+ count += cpsDataService.getDataNodes(NCMP_PERFORMANCE_TEST_DATASPACE, REGISTRY_ANCHOR,
+ '/dmi-registry/cm-handles[@id="cm-' + it + '"]', OMIT_DESCENDANTS).size()
+ }
+ resourceMeter.stop()
+ then: '100 data node have been found'
+ assert count == 100
+ and: 'average performance is as expected'
+ recordAndAssertResourceUsage('NCMP:Look up CM-handle by id', 0.58, resourceMeter.totalTimeInSeconds, resourceMeter.totalMemoryUsageInMB)
+ }
+
+ def 'CM-handle is looked up by alternate id.'() {
+ when: 'CM-handles are looked up by alternate id 100 times'
+ int count = 0
+ resourceMeter.start()
+ (1..100).each {
+ count += cpsQueryService.queryDataNodes(NCMP_PERFORMANCE_TEST_DATASPACE, REGISTRY_ANCHOR,
+ "/dmi-registry/cm-handles[@alternate-id='alt-${it}']", OMIT_DESCENDANTS).size()
+ }
+ resourceMeter.stop()
+ then: 'all alternate ids are resolved correctly'
+ assert count == 100
+ and: 'average performance is as expected'
+ recordAndAssertResourceUsage('NCMP:Look up CM-handle by alternate-id', 1.6, resourceMeter.totalTimeInSeconds, resourceMeter.totalMemoryUsageInMB, REFERENCE_GRAPH)
+ }
+
+ def 'A batch of CM-handles is looked up by alternate id.'() {
+ given: 'a CPS Path Query to look up 100 alternate ids in a single operation'
+ def cpsPathQuery = '/dmi-registry/cm-handles[' + (1..100).collect { "@alternate-id='alt-${it}'" }.join(' or ') + ']'
+ when: 'CM-handles are looked up by alternate ids in a single query'
+ resourceMeter.start()
+ def count = cpsQueryService.queryDataNodes(NCMP_PERFORMANCE_TEST_DATASPACE, REGISTRY_ANCHOR, cpsPathQuery, OMIT_DESCENDANTS).size()
+ resourceMeter.stop()
+ then: 'expected amount of data was returned'
+ assert count == 100
+ then: 'average performance is as expected'
+ recordAndAssertResourceUsage('NCMP:Batch look up CM-handle by alternate-id', 0.24, resourceMeter.totalTimeInSeconds, resourceMeter.totalMemoryUsageInMB)
+ }
+
+ def 'Find any CM-handle given moduleSetTag when there are 20K READY handles with same moduleSetTag.'() {
+ given:
+ def cpsPathQuery = "/dmi-registry/cm-handles[@module-set-tag='my-module-set-tag']"
+ when: 'CM-handles are looked up by module-set-tag 100 times'
+ int count = 0
+ resourceMeter.start()
+ (1..100).each {
+ count += cpsQueryService.queryDataNodes(NCMP_PERFORMANCE_TEST_DATASPACE, REGISTRY_ANCHOR, cpsPathQuery, OMIT_DESCENDANTS).size()
+ }
+ resourceMeter.stop()
+ then:
+ assert count == TOTAL_CM_HANDLES * 100
+ then: 'average performance is as expected'
+ def averageResponseTime = resourceMeter.totalTimeInSeconds / 100
+ recordAndAssertResourceUsage('NCMP:Look up CM-handles by module-set-tag', 0.26, averageResponseTime, resourceMeter.totalMemoryUsageInMB)
}
}
Code Review / cps.git / blobdiff