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