integration-test/src/test/groovy/org/onap/cps/integration/performance/cps/UpdatePerfTest.groovy

   1 /*
   2  *  ============LICENSE_START=======================================================
   3  *  Copyright (C) 2023 Nordix Foundation
   4  *  ================================================================================
   5  *  Licensed under the Apache License, Version 2.0 (the 'License');
   6  *  you may not use this file except in compliance with the License.
   7  *  You may obtain a copy of the License at
   8  *
   9  *        http://www.apache.org/licenses/LICENSE-2.0
  10  *
  11  *  Unless required by applicable law or agreed to in writing, software
  12  *  distributed under the License is distributed on an 'AS IS' BASIS,
  13  *  WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  14  *  See the License for the specific language governing permissions and
  15  *  limitations under the License.
  16  *
  17  *  SPDX-License-Identifier: Apache-2.0
  18  *  ============LICENSE_END=========================================================
  19  */
  20
  21 package org.onap.cps.integration.performance.cps
  22
  23 import java.time.OffsetDateTime
  24 import org.onap.cps.api.CpsDataService
  25 import org.onap.cps.integration.performance.base.CpsPerfTestBase
  26 import java.util.concurrent.TimeUnit
  27
  28 class UpdatePerfTest extends CpsPerfTestBase {
  29
  30     CpsDataService objectUnderTest
  31     def now = OffsetDateTime.now()
  32
  33     def setup() { objectUnderTest = cpsDataService }
  34
  35     def 'Update 1 data node with descendants'() {
  36         given: 'a list of data nodes to update as JSON'
  37             def parentNodeXpath = "/openroadm-devices/openroadm-device[@device-id='C201-7-1A-10']"
  38             def jsonData = readResourceDataFile('openroadm/innerNode.json').replace('NODE_ID_HERE', '10')
  39         when: 'the fragment entities are updated by the data nodes'
  40             resourceMeter.start()
  41             objectUnderTest.updateDataNodeAndDescendants(CPS_PERFORMANCE_TEST_DATASPACE, 'openroadm1', parentNodeXpath, jsonData, now)
  42             resourceMeter.stop()
  43             def updateDurationInMillis = resourceMeter.getTotalTimeMillis()
  44         then: 'update completes within expected time and memory used is within limit'
  45             recordAndAssertResourceUsage('Update 1 data node', 600, updateDurationInMillis, 200, resourceMeter.getTotalMemoryUsageInMB())
  46     }
  47
  48     def 'Batch update 100 data nodes with descendants'() {
  49         given: 'a list of data nodes to update as JSON'
  50             def innerNodeJson = readResourceDataFile('openroadm/innerNode.json')
  51             def nodesJsonData = (1..100).collectEntries {[
  52                 "/openroadm-devices/openroadm-device[@device-id='C201-7-1A-" + it + "']",
  53                 innerNodeJson.replace('NODE_ID_HERE', it.toString())
  54             ]}
  55         when: 'the fragment entities are updated by the data nodes'
  56             resourceMeter.start()
  57             objectUnderTest.updateDataNodesAndDescendants(CPS_PERFORMANCE_TEST_DATASPACE, 'openroadm1', nodesJsonData, now)
  58             resourceMeter.stop()
  59             def updateDurationInMillis = resourceMeter.getTotalTimeMillis()
  60         then: 'update completes within expected time and memory used is within limit'
  61             recordAndAssertResourceUsage('Update 100 data nodes', TimeUnit.SECONDS.toMillis(30), updateDurationInMillis, 800, resourceMeter.getTotalMemoryUsageInMB())
  62     }
  63
  64     def 'Update leaves for 1 data node (twice)'() {
  65         given: 'Updated json for openroadm data'
  66             def jsonDataUpdated  = "{'openroadm-device':{'device-id':'C201-7-1A-10','status':'fail','ne-state':'jeopardy'}}"
  67             def jsonDataOriginal = "{'openroadm-device':{'device-id':'C201-7-1A-10','status':'success','ne-state':'inservice'}}"
  68         when: 'update is performed for leaves'
  69             resourceMeter.start()
  70             objectUnderTest.updateNodeLeaves(CPS_PERFORMANCE_TEST_DATASPACE, 'openroadm2', "/openroadm-devices", jsonDataUpdated, now)
  71             objectUnderTest.updateNodeLeaves(CPS_PERFORMANCE_TEST_DATASPACE, 'openroadm2', "/openroadm-devices", jsonDataOriginal, now)
  72             resourceMeter.stop()
  73             def updateDurationInMillis = resourceMeter.getTotalTimeMillis()
  74         then: 'update completes within expected time and memory used is within limit'
  75             recordAndAssertResourceUsage('Update leaves for 1 data node', 500, updateDurationInMillis, 300, resourceMeter.getTotalMemoryUsageInMB())
  76     }
  77
  78     def 'Batch update leaves for 100 data nodes (twice)'() {
  79         given: 'Updated json for openroadm data'
  80             def jsonDataUpdated  = "{'openroadm-device':[" + (1..100).collect { "{'device-id':'C201-7-1A-" + it + "','status':'fail','ne-state':'jeopardy'}" }.join(",") + "]}"
  81             def jsonDataOriginal = "{'openroadm-device':[" + (1..100).collect { "{'device-id':'C201-7-1A-" + it + "','status':'success','ne-state':'inservice'}" }.join(",") + "]}"
  82         when: 'update is performed for leaves'
  83             resourceMeter.start()
  84             objectUnderTest.updateNodeLeaves(CPS_PERFORMANCE_TEST_DATASPACE, 'openroadm2', "/openroadm-devices", jsonDataUpdated, now)
  85             objectUnderTest.updateNodeLeaves(CPS_PERFORMANCE_TEST_DATASPACE, 'openroadm2', "/openroadm-devices", jsonDataOriginal, now)
  86             resourceMeter.stop()
  87             def updateDurationInMillis = resourceMeter.getTotalTimeMillis()
  88         then: 'update completes within expected time and memory used is within limit'
  89             recordAndAssertResourceUsage('Batch update leaves for 100 data nodes', TimeUnit.SECONDS.toMillis(1), updateDurationInMillis, 300, resourceMeter.getTotalMemoryUsageInMB())
  90     }
  91
  92 }