aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorLusheng Ji <lji@research.att.com>2017-09-08 14:41:02 +0000
committerGerrit Code Review <gerrit@onap.org>2017-09-08 14:41:02 +0000
commitc6d71ced8d8ff7d837a95cf38f301b4f53055c70 (patch)
treec712d9f7644214db9ae744320bde3b5808b7c619
parent34d0f73575d6c682a32270a5b1e08b2db2d2ff56 (diff)
parent085dbb6ef076449f019448c479a7db03a45ecd17 (diff)
Merge "Fix for Sonar issue"
-rw-r--r--dcae-controller-core/dcae-controller-platform-server/src/main/java/org/openecomp/dcae/controller/platform/servers/controller/DcaeControllerClusterProvider.java12
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());