From 085dbb6ef076449f019448c479a7db03a45ecd17 Mon Sep 17 00:00:00 2001 From: rama-huawei Date: Thu, 7 Sep 2017 20:37:12 +0530 Subject: Fix for Sonar issue DCAEGEN2-93 Change-Id: I27ae1d06903c9acbe86e349f60daab0048360ae8 Signed-off-by: rama-huawei --- .../servers/controller/DcaeControllerClusterProvider.java | 12 ------------ 1 file changed, 12 deletions(-) diff --git a/dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerClusterProvider.java b/dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerClusterProvider.java index b751d96..1cd583f 100644 --- a/dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerClusterProvider.java +++ b/dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerClusterProvider.java @@ -117,7 +117,6 @@ public class DcaeControllerClusterProvider extends BasicAdaptorProvider implemen b = b.replaceFirst("localhost", s.getServer().getNetworks().get(0).getDnsName()); client.setBaseAddress(b); logger.info("using baseAdress: " + client.getBaseAddress()); -// System.out.println("CLUSTER: " + client.getBaseAddress()); return new DcaeControllerClusterConsole(client); } @@ -148,7 +147,6 @@ public class DcaeControllerClusterProvider extends BasicAdaptorProvider implemen @Override public void start() { -// System.out.println("CLUSTER: start"); try { String hostname = SecurityUtils.getHostName(); if (hostname.indexOf(".") > 0) @@ -172,44 +170,34 @@ public class DcaeControllerClusterProvider extends BasicAdaptorProvider implemen } catch (Exception e) { e.printStackTrace(); } -// System.out.println("CLUSTER: start"); Thread t = new Thread("cluster replication") { @Override public void run() { -// System.out.println("CLUSTER 2: run"); while (true) { try { -// System.out.println("CLUSTER 3: run"); for (ControllerClusterServer s : o.getServers()) { if (s.getName().equals(o.getMyServerName())) o.setRole(s.getRole()); } controller.getServer().isSlave = o.getRole() == ServerRole.SLAVE; if (o.getRole() == ServerRole.MASTER) { -// System.out.println("CLUSTER 3: run"); ecomplogger.setOperation(DcaeControllerOperationEnum.CLUSTER_DATA_REPLICATION); ecomplogger.newRequestId(); ecomplogger.setInstanceId(controller, o); ecomplogger.recordAuditEventStart(); for (ControllerClusterServer s : o.getServers()) { -// System.out.println("CLUSTER 4: run: " + s.getName() + " " + s.getRole()); if (s.getRole() != ServerRole.SLAVE) continue; if (s.getName().equals(o.getMyServerName())) continue; -// System.out.println("CLUSTER 5: run"); for (ControllerClusterServerData d : s.getData()) { try { -// System.out.println("CLUSTER 6: run: " + d.getName()); Date last = d.getLastPush() == null ? null : d.getLastPush().last; long i = DateUtils.stringToDuration(d.getPushInterval()); -// System.out.println("CLUSTER 7: run"); long now = new Date().getTime(); if (last != null && last.getTime() + i > now) continue; -// System.out.println("CLUSTER 8: run"); o.pushData(s.getName(), d.getName()); -// System.out.println("CLUSTER 9: run"); } catch (Exception e) { ecomplogger.warn(DcaeControllerMessageEnum.CLUSTER_DATA_REPLICATION_FAILED, s.getName()); -- cgit 1.2.3-korg