ms/controllerblueprints/modules/resource-dict/src/main/kotlin/org/onap/ccsdk/cds/controllerblueprints/resource/dict/utils/BulkResourceSequencingUtils.kt

   1 /*
   2  *  Copyright © 2017-2018 AT&T Intellectual Property.
   3  *
   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
   7  *
   8  *      http://www.apache.org/licenses/LICENSE-2.0
   9  *
  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.
  15  */
  16
  17 package org.onap.ccsdk.cds.controllerblueprints.resource.dict.utils
  18
  19 import org.apache.commons.collections.CollectionUtils
  20 import org.onap.ccsdk.cds.controllerblueprints.core.utils.TopologicalSortingUtils
  21 import org.onap.ccsdk.cds.controllerblueprints.resource.dict.ResourceAssignment
  22 import org.slf4j.LoggerFactory
  23 import java.util.ArrayList
  24 /**
  25  * BulkResourceSequencingUtils.
  26  *
  27  * @author Brinda Santh
  28  */
  29 object BulkResourceSequencingUtils {
  30     private val log= LoggerFactory.getLogger(BulkResourceSequencingUtils::class.java)
  31
  32     @JvmStatic
  33     fun process(resourceAssignments: MutableList<ResourceAssignment>): List<List<ResourceAssignment>> {
  34         val resourceAssignmentMap: MutableMap<String, ResourceAssignment> = hashMapOf()
  35         val sequenceBatchResourceAssignment = ArrayList<List<ResourceAssignment>>()
  36         log.info("Assignments ({})", resourceAssignments)
  37         // Prepare Map
  38         resourceAssignments.forEach { resourceAssignment ->
  39             log.trace("Processing Key ({})", resourceAssignment.name)
  40             resourceAssignmentMap.put(resourceAssignment.name, resourceAssignment)
  41         }
  42
  43         val startResourceAssignment = ResourceAssignment()
  44         startResourceAssignment.name = "*"
  45
  46         // Preepare Sorting Map
  47         val topologySorting = TopologicalSortingUtils<ResourceAssignment>()
  48         resourceAssignmentMap.forEach { _, resourceAssignment ->
  49             if (CollectionUtils.isNotEmpty(resourceAssignment.dependencies)) {
  50                 for (dependency in resourceAssignment.dependencies!!) {
  51                     topologySorting.add(resourceAssignmentMap[dependency]!!, resourceAssignment)
  52                 }
  53             } else {
  54                 topologySorting.add(startResourceAssignment, resourceAssignment)
  55             }
  56         }
  57
  58         val sequencedResourceAssignments: MutableList<ResourceAssignment> = topologySorting.topSort()!! as MutableList<ResourceAssignment>
  59         log.info("Sorted Sequenced Assignments ({})", sequencedResourceAssignments)
  60
  61         var batchResourceAssignment: MutableList<ResourceAssignment>? = null
  62         var batchAssignmentName: MutableList<String>? = null
  63
  64         // Prepare Sorting
  65         sequencedResourceAssignments.forEachIndexed { index, resourceAssignment ->
  66
  67             var previousResourceAssignment: ResourceAssignment? = null
  68
  69             if (index > 0) {
  70                 previousResourceAssignment = sequencedResourceAssignments[index - 1]
  71             }
  72
  73             var dependencyPresence = false
  74             if (batchAssignmentName != null && resourceAssignment.dependencies != null) {
  75                 dependencyPresence = CollectionUtils.containsAny(batchAssignmentName, resourceAssignment.dependencies)
  76             }
  77
  78             log.trace("({}) -> Checking ({}), with ({}), result ({})", resourceAssignment.name,
  79                     batchAssignmentName, resourceAssignment.dependencies, dependencyPresence)
  80
  81             if (previousResourceAssignment != null && resourceAssignment.dictionarySource != null
  82                     && resourceAssignment.dictionarySource!!.equals(previousResourceAssignment.dictionarySource, true)
  83                     && !dependencyPresence) {
  84                 batchResourceAssignment!!.add(resourceAssignment)
  85                 batchAssignmentName!!.add(resourceAssignment.name)
  86             } else {
  87                 if (batchResourceAssignment != null) {
  88                     sequenceBatchResourceAssignment.add(batchResourceAssignment!!)
  89                     log.trace("Created old Set ({})", batchAssignmentName)
  90                 }
  91                 batchResourceAssignment = arrayListOf()
  92                 batchResourceAssignment!!.add(resourceAssignment)
  93
  94                 batchAssignmentName = arrayListOf()
  95                 batchAssignmentName!!.add(resourceAssignment.name)
  96             }
  97
  98             if (index == sequencedResourceAssignments.size - 1) {
  99                 log.trace("Created old Set ({})", batchAssignmentName)
 100                 sequenceBatchResourceAssignment.add(batchResourceAssignment!!)
 101             }
 102         }
 103         log.info("Batched Sequence : ({})", sequenceBatchResourceAssignment)
 104
 105         return sequenceBatchResourceAssignment
 106     }
 107
 108 }