summaryrefslogtreecommitdiffstats
path: root/src/main/java/org/openecomp/sparky/synchronizer/SyncController.java
diff options
context:
space:
mode:
authorARUL NAMBI <arul.nambi@amdocs.com>2017-07-25 14:46:08 -0400
committerARUL NAMBI <arul.nambi@amdocs.com>2017-07-25 14:46:59 -0400
commitd4241a5c945d04e44716851cfd2b7ef427accb48 (patch)
tree805b432231bca7732ea30af365d2b53f534c0ddd /src/main/java/org/openecomp/sparky/synchronizer/SyncController.java
parentf8de1f25e7c71380a61b96d5251f224e3a4c821f (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/SyncController.java')
-rw-r--r--src/main/java/org/openecomp/sparky/synchronizer/SyncController.java35
1 files changed, 18 insertions, 17 deletions
diff --git a/src/main/java/org/openecomp/sparky/synchronizer/SyncController.java b/src/main/java/org/openecomp/sparky/synchronizer/SyncController.java
index 85cbeb5..5d5ef61 100644
--- a/src/main/java/org/openecomp/sparky/synchronizer/SyncController.java
+++ b/src/main/java/org/openecomp/sparky/synchronizer/SyncController.java
@@ -422,30 +422,31 @@ public class SyncController {
boolean allDone = false;
long nextReportTimeStampInMs = System.currentTimeMillis() + 30000L;
+ boolean dumpPeriodicStatReport = false;
while (!allDone) {
- // allDone = false;
-
int totalFinished = 0;
for (IndexSynchronizer synchronizer : registeredSynchronizers) {
- if (System.currentTimeMillis() > nextReportTimeStampInMs) {
-
- nextReportTimeStampInMs = System.currentTimeMillis() + 30000L;
-
- String statReport = synchronizer.getStatReport(false);
-
- if (statReport != null) {
- LOG.info(AaiUiMsgs.INFO_GENERIC, statReport);
- }
- }
-
- if (synchronizer.getState() == SynchronizerState.IDLE) {
- totalFinished++;
- }
+ if (dumpPeriodicStatReport) {
+ if (synchronizer.getState() != SynchronizerState.IDLE) {
+ String statReport = synchronizer.getStatReport(false);
+ if (statReport != null) {
+ LOG.info(AaiUiMsgs.INFO_GENERIC, statReport);
+ }
+ }
+ if (synchronizer.getState() == SynchronizerState.IDLE) {
+ totalFinished++;
+ }
+ }
}
-
+ if ( System.currentTimeMillis() > nextReportTimeStampInMs) {
+ dumpPeriodicStatReport = true;
+ nextReportTimeStampInMs = System.currentTimeMillis() + 30000L;
+ } else {
+ dumpPeriodicStatReport = false;
+ }
allDone = (totalFinished == registeredSynchronizers.size());
try {