diff options
author | rama-huawei <rama.subba.reddy.s@huawei.com> | 2017-09-07 20:37:12 +0530 |
---|---|---|
committer | rama-huawei <rama.subba.reddy.s@huawei.com> | 2017-09-07 20:38:02 +0530 |
commit | 085dbb6ef076449f019448c479a7db03a45ecd17 (patch) | |
tree | 98044cd46cd96d6bdfe802d26dcecb79a2497f16 | |
parent | e8476215b2cf4ac6225f0a939139377f88acbecb (diff) |
Fix for Sonar issue
DCAEGEN2-93
Change-Id: I27ae1d06903c9acbe86e349f60daab0048360ae8
Signed-off-by: rama-huawei <rama.subba.reddy.s@huawei.com>
-rw-r--r-- | dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerClusterProvider.java | 12 |
1 files changed, 0 insertions, 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()); |