2 * Copyright © 2017-2018 AT&T Intellectual Property.
\r
4 * Licensed under the Apache License, Version 2.0 (the "License");
\r
5 * you may not use this file except in compliance with the License.
\r
6 * You may obtain a copy of the License at
\r
8 * http://www.apache.org/licenses/LICENSE-2.0
\r
10 * Unless required by applicable law or agreed to in writing, software
\r
11 * distributed under the License is distributed on an "AS IS" BASIS,
\r
12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
\r
13 * See the License for the specific language governing permissions and
\r
14 * limitations under the License.
\r
17 package org.onap.ccsdk.apps.controllerblueprints.resource.dict.utils
\r
19 import com.att.eelf.configuration.EELFLogger
\r
20 import org.apache.commons.collections.CollectionUtils
\r
21 import org.onap.ccsdk.apps.controllerblueprints.core.utils.TopologicalSortingUtils
\r
22 import org.onap.ccsdk.apps.controllerblueprints.resource.dict.ResourceAssignment
\r
23 import com.att.eelf.configuration.EELFManager
\r
24 import java.util.ArrayList
\r
26 * BulkResourceSequencingUtils.
\r
28 * @author Brinda Santh
\r
30 object BulkResourceSequencingUtils {
\r
31 private val log: EELFLogger = EELFManager.getInstance().getLogger(BulkResourceSequencingUtils::class.java)
\r
34 fun process(resourceAssignments: MutableList<ResourceAssignment>): List<List<ResourceAssignment>> {
\r
35 val resourceAssignmentMap: MutableMap<String, ResourceAssignment> = hashMapOf()
\r
36 val sequenceBatchResourceAssignment = ArrayList<List<ResourceAssignment>>()
\r
37 log.info("Assignments ({})", resourceAssignments)
\r
39 resourceAssignments.forEach { resourceAssignment ->
\r
40 log.trace("Processing Key ({})", resourceAssignment.name)
\r
41 resourceAssignmentMap.put(resourceAssignment.name, resourceAssignment)
\r
44 val startResourceAssignment = ResourceAssignment()
\r
45 startResourceAssignment.name = "*"
\r
47 // Preepare Sorting Map
\r
48 val topologySorting = TopologicalSortingUtils<ResourceAssignment>()
\r
49 resourceAssignmentMap.forEach { _, resourceAssignment ->
\r
50 if (CollectionUtils.isNotEmpty(resourceAssignment.dependencies)) {
\r
51 for (dependency in resourceAssignment.dependencies!!) {
\r
52 topologySorting.add(resourceAssignmentMap[dependency]!!, resourceAssignment)
\r
55 topologySorting.add(startResourceAssignment, resourceAssignment)
\r
59 val sequencedResourceAssignments: MutableList<ResourceAssignment> = topologySorting.topSort()!! as MutableList<ResourceAssignment>
\r
60 log.info("Sorted Sequenced Assignments ({})", sequencedResourceAssignments)
\r
62 var batchResourceAssignment: MutableList<ResourceAssignment>? = null
\r
63 var batchAssignmentName: MutableList<String>? = null
\r
66 sequencedResourceAssignments.forEachIndexed { index, resourceAssignment ->
\r
68 var previousResourceAssignment: ResourceAssignment? = null
\r
71 previousResourceAssignment = sequencedResourceAssignments[index - 1]
\r
74 var dependencyPresence = false
\r
75 if (batchAssignmentName != null && resourceAssignment.dependencies != null) {
\r
76 dependencyPresence = CollectionUtils.containsAny(batchAssignmentName, resourceAssignment.dependencies)
\r
79 log.trace("({}) -> Checking ({}), with ({}), result ({})", resourceAssignment.name,
\r
80 batchAssignmentName, resourceAssignment.dependencies, dependencyPresence)
\r
82 if (previousResourceAssignment != null && resourceAssignment.dictionarySource != null
\r
83 && resourceAssignment.dictionarySource!!.equals(previousResourceAssignment.dictionarySource, true)
\r
84 && !dependencyPresence) {
\r
85 batchResourceAssignment!!.add(resourceAssignment)
\r
86 batchAssignmentName!!.add(resourceAssignment.name)
\r
88 if (batchResourceAssignment != null) {
\r
89 sequenceBatchResourceAssignment.add(batchResourceAssignment!!)
\r
90 log.trace("Created old Set ({})", batchAssignmentName)
\r
92 batchResourceAssignment = arrayListOf()
\r
93 batchResourceAssignment!!.add(resourceAssignment)
\r
95 batchAssignmentName = arrayListOf()
\r
96 batchAssignmentName!!.add(resourceAssignment.name)
\r
99 if (index == sequencedResourceAssignments.size - 1) {
\r
100 log.trace("Created old Set ({})", batchAssignmentName)
\r
101 sequenceBatchResourceAssignment.add(batchResourceAssignment!!)
\r
104 log.info("Batched Sequence : ({})", sequenceBatchResourceAssignment)
\r
106 return sequenceBatchResourceAssignment
\r