components/resource-dict/src/main/kotlin/org/onap/ccsdk/apps/controllerblueprints/resource/dict/utils/BulkResourceSequencingUtils.kt

   1 /*\r
   2  *  Copyright © 2017-2018 AT&T Intellectual Property.\r
   3  *\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
   7  *\r
   8  *      http://www.apache.org/licenses/LICENSE-2.0\r
   9  *\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
  15  */\r
  16 \r
  17 package org.onap.ccsdk.apps.controllerblueprints.resource.dict.utils\r
  18 \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
  25 /**\r
  26  * BulkResourceSequencingUtils.\r
  27  *\r
  28  * @author Brinda Santh\r
  29  */\r
  30 object BulkResourceSequencingUtils {\r
  31     private val log: EELFLogger = EELFManager.getInstance().getLogger(BulkResourceSequencingUtils::class.java)\r
  32 \r
  33     @JvmStatic\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
  38         // Prepare Map\r
  39         resourceAssignments.forEach { resourceAssignment ->\r
  40             log.trace("Processing Key ({})", resourceAssignment.name)\r
  41             resourceAssignmentMap.put(resourceAssignment.name, resourceAssignment)\r
  42         }\r
  43 \r
  44         val startResourceAssignment = ResourceAssignment()\r
  45         startResourceAssignment.name = "*"\r
  46 \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
  53                 }\r
  54             } else {\r
  55                 topologySorting.add(startResourceAssignment, resourceAssignment)\r
  56             }\r
  57         }\r
  58 \r
  59         val sequencedResourceAssignments: MutableList<ResourceAssignment> = topologySorting.topSort()!! as MutableList<ResourceAssignment>\r
  60         log.info("Sorted Sequenced Assignments ({})", sequencedResourceAssignments)\r
  61 \r
  62         var batchResourceAssignment: MutableList<ResourceAssignment>? = null\r
  63         var batchAssignmentName: MutableList<String>? = null\r
  64 \r
  65         // Prepare Sorting\r
  66         sequencedResourceAssignments.forEachIndexed { index, resourceAssignment ->\r
  67 \r
  68             var previousResourceAssignment: ResourceAssignment? = null\r
  69 \r
  70             if (index > 0) {\r
  71                 previousResourceAssignment = sequencedResourceAssignments[index - 1]\r
  72             }\r
  73 \r
  74             var dependencyPresence = false\r
  75             if (batchAssignmentName != null && resourceAssignment.dependencies != null) {\r
  76                 dependencyPresence = CollectionUtils.containsAny(batchAssignmentName, resourceAssignment.dependencies)\r
  77             }\r
  78 \r
  79             log.trace("({}) -> Checking ({}), with ({}), result ({})", resourceAssignment.name,\r
  80                     batchAssignmentName, resourceAssignment.dependencies, dependencyPresence)\r
  81 \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
  87             } else {\r
  88                 if (batchResourceAssignment != null) {\r
  89                     sequenceBatchResourceAssignment.add(batchResourceAssignment!!)\r
  90                     log.trace("Created old Set ({})", batchAssignmentName)\r
  91                 }\r
  92                 batchResourceAssignment = arrayListOf()\r
  93                 batchResourceAssignment!!.add(resourceAssignment)\r
  94 \r
  95                 batchAssignmentName = arrayListOf()\r
  96                 batchAssignmentName!!.add(resourceAssignment.name)\r
  97             }\r
  98 \r
  99             if (index == sequencedResourceAssignments.size - 1) {\r
 100                 log.trace("Created old Set ({})", batchAssignmentName)\r
 101                 sequenceBatchResourceAssignment.add(batchResourceAssignment!!)\r
 102             }\r
 103         }\r
 104         log.info("Batched Sequence : ({})", sequenceBatchResourceAssignment)\r
 105 \r
 106         return sequenceBatchResourceAssignment\r
 107     }\r
 108 \r
 109 }