1 files changed, 0 insertions, 145 deletions
diff --git a/src/main/java/org/onap/dcaegen2/services/sonhms/child/ClusterFormation.java b/src/main/java/org/onap/dcaegen2/services/sonhms/child/ClusterFormation.java
deleted file mode 100644
index e248a59..0000000
--- a/src/main/java/org/onap/dcaegen2/services/sonhms/child/ClusterFormation.java
+++ /dev/null
@@ -1,145 +0,0 @@
-/*******************************************************************************
- *  ============LICENSE_START=======================================================
- *  son-handler
- *  ================================================================================
- *   Copyright (C) 2019 Wipro Limited.
- *   ==============================================================================
- *     Licensed under the Apache License, Version 2.0 (the "License");
- *     you may not use this file except in compliance with the License.
- *     You may obtain a copy of the License at
- *  
- *          http://www.apache.org/licenses/LICENSE-2.0
- *  
- *     Unless required by applicable law or agreed to in writing, software
- *     distributed under the License is distributed on an "AS IS" BASIS,
- *     WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- *     See the License for the specific language governing permissions and
- *     limitations under the License.
- *     ============LICENSE_END=========================================================
- *  
- *******************************************************************************/
-
-package org.onap.dcaegen2.services.sonhms.child;
-
-import java.sql.Timestamp;
-import java.util.ArrayList;
-import java.util.Map;
-import java.util.Properties;
-import java.util.UUID;
-import java.util.concurrent.BlockingQueue;
-
-import org.onap.dcaegen2.services.sonhms.ConfigPolicy;
-import org.onap.dcaegen2.services.sonhms.Configuration;
-import org.onap.dcaegen2.services.sonhms.dao.ClusterDetailsRepository;
-import org.onap.dcaegen2.services.sonhms.entity.ClusterDetails;
-import org.onap.dcaegen2.services.sonhms.model.FapServiceList;
-import org.onap.dcaegen2.services.sonhms.utils.BeanUtil;
-import org.onap.dcaegen2.services.sonhms.utils.ClusterUtils;
-import org.slf4j.Logger;
-
-
-public class ClusterFormation {
-
-    private static final Logger log = org.slf4j.LoggerFactory.getLogger(ClusterFormation.class);
-    private BlockingQueue<FapServiceList> queue;
-    private ClusterUtils clusterUtils;
-    private Detection detect;
-    Properties confProp;
-    ClusterDetails details = new ClusterDetails();
-
-    public ClusterFormation() {
-        this.detect = new Detection();
-    }
-
-    /**
-     * parameterized constructor.
-     *
-     */
-    public ClusterFormation(BlockingQueue<FapServiceList> queue) {
-        super();
-        this.queue = queue;
-        this.detect = new Detection();
-        this.clusterUtils = new ClusterUtils();
-    }
-
-    /**
-     * Determines whether to trigger Oof or wait for notifications.
-     */
-    public Boolean triggerOrWait(Map<String, ArrayList<Integer>> collisionConfusionResult) {
-        // determine collision or confusion
-
-        Configuration configuration = Configuration.getInstance();
-        int collisionSum = 0;
-        int confusionSum = 0;
-
-        for (Map.Entry<String, ArrayList<Integer>> entry : collisionConfusionResult.entrySet()) {
-
-            ArrayList<Integer> arr;
-            arr = entry.getValue();
-            // check for 0 collision and confusion
-            if (!arr.isEmpty()) {
-                collisionSum = collisionSum + arr.get(0);
-                confusionSum = confusionSum + arr.get(1);
-            }
-        }
-        return ((collisionSum >= configuration.getMinCollision()) && (confusionSum >= configuration.getMinConfusion()));
-
-    }
-
-    /**
-     * Waits for notifications.
-     */
-    public Map<String, ArrayList<Integer>> waitForNotification(Map<String, ArrayList<Integer>> collisionConfusionResult,
-            Graph cluster) {
-
-        FapServiceList newNotification;
-        ConfigPolicy config = ConfigPolicy.getInstance();
-        int timer = 60;
-        try {
-            timer = (int) config.getConfig().get("PCI_NEIGHBOR_CHANGE_CLUSTER_TIMEOUT_IN_SECS");
-        } catch (NullPointerException e) {
-            log.debug("Policy config not available. Using default timeout - 60 seconds");
-        }
-
-        Timestamp currentTime = new Timestamp(System.currentTimeMillis());
-        log.debug("Current Time {}", currentTime);
-
-        Timestamp laterTime = new Timestamp(System.currentTimeMillis());
-        log.debug("LaterTime {}", laterTime);
-
-        long difference = laterTime.getTime() - currentTime.getTime();
-
-        int flag = 0;
-
-        while (difference < (timer * 1000)) {
-            try {
-                Thread.sleep(1000);
-            } catch (InterruptedException e) {
-                log.error("Interrupted Exception is {}", e);
-                Thread.currentThread().interrupt();
-            }
-
-            laterTime = new Timestamp(System.currentTimeMillis());
-            difference = laterTime.getTime() - currentTime.getTime();
-
-            if ((difference < (timer * 1000)) && (!queue.isEmpty())) {
-                newNotification = queue.poll();
-                cluster = clusterUtils.modifyCluster(cluster, newNotification);
-
-                // update cluster in DB
-                String cellPciNeighbourString = cluster.getPciNeighbourJson();
-                UUID clusterId = cluster.getGraphId();
-                ClusterDetailsRepository clusterDetailsRepository = BeanUtil.getBean(ClusterDetailsRepository.class);
-                clusterDetailsRepository.updateCluster(cellPciNeighbourString, clusterId.toString());
-                flag++;
-
-            }
-        }
-        if (flag != 0) {
-            return detect.detectCollisionConfusion(cluster);
-
-        }
-        return collisionConfusionResult;
-    }
-
-}