diff options
author | 2017-07-25 14:46:08 -0400 | |
---|---|---|
committer | 2017-07-25 14:46:59 -0400 | |
commit | d4241a5c945d04e44716851cfd2b7ef427accb48 (patch) | |
tree | 805b432231bca7732ea30af365d2b53f534c0ddd /src/main/java/org/openecomp/sparky/synchronizer/AggregationSuggestionSynchronizer.java | |
parent | f8de1f25e7c71380a61b96d5251f224e3a4c821f (diff) |
Fixing the sync issues with AAI
Issue-ID: AAI-73
Change-Id: I5c7df7c24c59c347b112cdb003eea726e239a1ca
Signed-off-by: ARUL NAMBI <arul.nambi@amdocs.com>
Diffstat (limited to 'src/main/java/org/openecomp/sparky/synchronizer/AggregationSuggestionSynchronizer.java')
-rw-r--r-- | src/main/java/org/openecomp/sparky/synchronizer/AggregationSuggestionSynchronizer.java | 12 |
1 files changed, 5 insertions, 7 deletions
diff --git a/src/main/java/org/openecomp/sparky/synchronizer/AggregationSuggestionSynchronizer.java b/src/main/java/org/openecomp/sparky/synchronizer/AggregationSuggestionSynchronizer.java index 0337f6a..75200be 100644 --- a/src/main/java/org/openecomp/sparky/synchronizer/AggregationSuggestionSynchronizer.java +++ b/src/main/java/org/openecomp/sparky/synchronizer/AggregationSuggestionSynchronizer.java @@ -27,15 +27,12 @@ package org.openecomp.sparky.synchronizer; import static java.util.concurrent.CompletableFuture.supplyAsync; -import org.openecomp.cl.mdc.MdcContext; - -import java.net.InetAddress; -import java.net.UnknownHostException; import java.util.Map; import java.util.concurrent.ExecutorService; import org.openecomp.cl.api.Logger; import org.openecomp.cl.eelf.LoggerFactory; +import org.openecomp.cl.mdc.MdcContext; import org.openecomp.sparky.dal.NetworkTransaction; import org.openecomp.sparky.dal.rest.HttpMethod; import org.openecomp.sparky.dal.rest.OperationResult; @@ -87,7 +84,8 @@ public class AggregationSuggestionSynchronizer extends AbstractEntitySynchronize @Override public OperationState doSync() { isSyncInProgress = true; - + this.syncDurationInMs = -1; + syncStartedTimeStampInMs = System.currentTimeMillis(); syncEntity(); while (!isSyncDone()) { @@ -176,8 +174,8 @@ public class AggregationSuggestionSynchronizer extends AbstractEntitySynchronize @Override public String getStatReport(boolean shouldDisplayFinalReport) { - return getStatReport(System.currentTimeMillis() - this.syncStartedTimeStampInMs, - shouldDisplayFinalReport); + syncDurationInMs = System.currentTimeMillis() - syncStartedTimeStampInMs; + return getStatReport(syncDurationInMs, shouldDisplayFinalReport); } @Override |