2 * Copyright © 2017-2018 AT&T Intellectual Property.
4 * Licensed under the Apache License, Version 2.0 (the "License");
5 * you may not use this file except in compliance with the License.
6 * You may obtain a copy of the License at
8 * http://www.apache.org/licenses/LICENSE-2.0
10 * Unless required by applicable law or agreed to in writing, software
11 * distributed under the License is distributed on an "AS IS" BASIS,
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
13 * See the License for the specific language governing permissions and
14 * limitations under the License.
17 package org.onap.ccsdk.cds.controllerblueprints.resource.dict.utils
19 import org.apache.commons.collections.CollectionUtils
20 import org.onap.ccsdk.cds.controllerblueprints.core.asListOfString
21 import org.onap.ccsdk.cds.controllerblueprints.core.utils.TopologicalSortingUtils
22 import org.onap.ccsdk.cds.controllerblueprints.resource.dict.ResourceAssignment
23 import org.slf4j.LoggerFactory
27 * BulkResourceSequencingUtils.
29 * @author Brinda Santh
31 object BulkResourceSequencingUtils {
32 private val log = LoggerFactory.getLogger(BulkResourceSequencingUtils::class.java)
35 fun process(resourceAssignments: MutableList<ResourceAssignment>): List<List<ResourceAssignment>> {
36 val resourceAssignmentMap: MutableMap<String, ResourceAssignment> = hashMapOf()
37 val sequenceBatchResourceAssignment = ArrayList<List<ResourceAssignment>>()
38 log.trace("Assignments ({})", resourceAssignments)
40 resourceAssignments.forEach { resourceAssignment ->
41 log.trace("Processing Key ({})", resourceAssignment.name)
42 resourceAssignmentMap.put(resourceAssignment.name, resourceAssignment)
45 val startResourceAssignment = ResourceAssignment()
46 startResourceAssignment.name = "*"
48 // Preepare Sorting Map
49 val topologySorting = TopologicalSortingUtils<ResourceAssignment>()
50 resourceAssignmentMap.forEach { _, resourceAssignment ->
51 // Get the dependencies from the assignment sources, if not get from the Resource Assignment dependencies
52 if (resourceAssignment.dictionarySourceDefinition != null) {
53 val dependencies = resourceAssignment.dictionarySourceDefinition?.properties?.get("key-dependencies")?.asListOfString()
54 dependencies?.forEach { dependency ->
55 topologySorting.add(resourceAssignmentMap[dependency]!!, resourceAssignment)
57 } else if (CollectionUtils.isNotEmpty(resourceAssignment.dependencies)) {
58 for (dependency in resourceAssignment.dependencies!!) {
59 topologySorting.add(resourceAssignmentMap[dependency]!!, resourceAssignment)
62 topologySorting.add(startResourceAssignment, resourceAssignment)
66 val sequencedResourceAssignments: MutableList<ResourceAssignment> = topologySorting.topSort()!! as MutableList<ResourceAssignment>
67 log.trace("Sorted Sequenced Assignments ({})", sequencedResourceAssignments)
69 var batchResourceAssignment: MutableList<ResourceAssignment>? = null
70 var batchAssignmentName: MutableList<String>? = null
73 sequencedResourceAssignments.forEachIndexed { index, resourceAssignment ->
75 var previousResourceAssignment: ResourceAssignment? = null
78 previousResourceAssignment = sequencedResourceAssignments[index - 1]
81 var dependencyPresence = false
82 if (batchAssignmentName != null && resourceAssignment.dependencies != null) {
83 dependencyPresence = CollectionUtils.containsAny(batchAssignmentName, resourceAssignment.dependencies)
86 log.trace("({}) -> Checking ({}), with ({}), result ({})", resourceAssignment.name,
87 batchAssignmentName, resourceAssignment.dependencies, dependencyPresence)
89 if (previousResourceAssignment != null && resourceAssignment.dictionarySource != null
90 && resourceAssignment.dictionarySource!!.equals(previousResourceAssignment.dictionarySource, true)
91 && !dependencyPresence) {
92 batchResourceAssignment!!.add(resourceAssignment)
93 batchAssignmentName!!.add(resourceAssignment.name)
95 if (batchResourceAssignment != null) {
96 sequenceBatchResourceAssignment.add(batchResourceAssignment!!)
97 log.trace("Created old Set ({})", batchAssignmentName)
99 batchResourceAssignment = arrayListOf()
100 batchResourceAssignment!!.add(resourceAssignment)
102 batchAssignmentName = arrayListOf()
103 batchAssignmentName!!.add(resourceAssignment.name)
106 if (index == sequencedResourceAssignments.size - 1) {
107 log.trace("Created old Set ({})", batchAssignmentName)
108 sequenceBatchResourceAssignment.add(batchResourceAssignment!!)
111 log.info("Batched Sequence : ({})", sequenceBatchResourceAssignment)
113 return sequenceBatchResourceAssignment