import org.onap.aai.sparky.sync.config.NetworkStatisticsConfig;
import org.onap.aai.sparky.sync.config.SyncControllerConfig;
+import java.util.concurrent.TimeUnit;
+
public class HistoricalEntitySyncController extends SyncControllerImpl
implements SyncControllerRegistrar {
// final String controllerName = "Historical Entity Count Synchronizer";
- long taskFrequencyInMs = syncFrequencyInMinutes * 60 * 1000;
+ long taskFrequencyInMs = getTaskFrequencyInMs(syncFrequencyInMinutes);
setDelayInMs(taskFrequencyInMs);
setSyncFrequencyInMs(taskFrequencyInMs);
}
+ static long getTaskFrequencyInMs(int syncFrequencyInMinutes) {
+ return TimeUnit.MINUTES.toMillis(Integer.toUnsignedLong(syncFrequencyInMinutes));
+ }
+
public SyncControllerRegistry getSyncControllerRegistry() {
return syncControllerRegistry;
}
this.minValue = -1;
this.maxValue = 0;
initializeHistogramBins(numBins);
- this.stepSize = (maxValue / numBins);
+ this.stepSize = ((double) maxValue / (double) numBins);
clear();
}
} else {
- if (min == -1) {
+ if (Double.valueOf(min).equals(-1.0)) {
min = value;
}
protected String getResourceBasePath() {
- String versionStr = null;
+ String versionStr;
if (oxmModelLoader != null) {
versionStr = String.valueOf(oxmModelLoader.getLatestVersionNum());
+ } else {
+ throw new RuntimeException("Unable to resolve aai version.");
}
return "/aai/" + versionStr.toLowerCase();
import static java.util.concurrent.CompletableFuture.supplyAsync;
+import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Collection;
import java.util.Date;
TEST_INDEX_INTEGRITY, GENERATE_FINAL_REPORT
}
+ private final SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss z");
+
/**
* The Enum SyncActions.
*/
/**
* Instantiates a new sync controller.
*
- * @param name the name
* @throws Exception the exception
*/
public SyncControllerImpl(SyncControllerConfig syncControllerConfig) throws Exception {
LOG.info(AaiUiMsgs.INFO_GENERIC,
getControllerName() + " started synchronization at "
- + SynchronizerConstants.SIMPLE_DATE_FORMAT.format(opStartTime).replaceAll(
+ + this.simpleDateFormat.format(opStartTime).replaceAll(
SynchronizerConstants.TIME_STD, SynchronizerConstants.TIME_CONFIG_STD));
runCount.incrementAndGet();
*/
package org.onap.aai.sparky.sync;
-import java.text.SimpleDateFormat;
import java.util.Date;
+import java.util.concurrent.TimeUnit;
/**
* The Class SynchronizerConstants.
// Error values for invalid user input
public static final int DEFAULT_CONFIG_ERROR_INT_VALUE = Integer.MAX_VALUE;
public static final Date DEFAULT_CONFIG_ERROR_DATE_VALUE = new Date(Long.MAX_VALUE);
- public static final SimpleDateFormat SIMPLE_DATE_FORMAT =
- new SimpleDateFormat("yyyy-MM-dd HH:mm:ss z");
public static final String DEPTH_MODIFIER = "?depth=0";
public static final String DEPTH_ALL_MODIFIER = "?depth=all";
public static final int IDX_TIME_IN_TIMESTAMP = 0;
public static final int IDX_TIMEZONE_IN_TIMESTAMP = 1;
public static final long MILLISEC_IN_A_MIN = 60000;
- public static final long MILLISEC_IN_A_DAY = 24 * 60 * 60 * 1000;
+ public static final long MILLISEC_IN_A_DAY = TimeUnit.HOURS.toMillis(24);
public static final String TIME_STD = "GMT";
public static final String TIME_CONFIG_STD = "UTC";
public static final String TIMESTAMP24HOURS_PATTERN =
public double getCurrentTps() {
if (numTransactions.get() > 0) {
- double timeDelta = System.currentTimeMillis() - startTimeInMs;
+ long timeDelta = System.currentTimeMillis() - startTimeInMs;
double numTxns = numTransactions.get();
return (numTxns / timeDelta) * 1000.0;
}
public class SyncControllerConfig {
private static final String UNKNOWN_CONTROLLER_NAME = "UnknownControllerName";
+ private final SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss z");
private String controllerName;
private boolean enabled;
Calendar targetSyncTime = Calendar.getInstance(tz);
targetSyncTime.add(Calendar.SECOND, taskFrequencyInSeconds);
- return SynchronizerConstants.SIMPLE_DATE_FORMAT.format(targetSyncTime.getTimeInMillis())
+ return this.simpleDateFormat.format(targetSyncTime.getTimeInMillis())
.replaceAll(SynchronizerConstants.TIME_STD, SynchronizerConstants.TIME_CONFIG_STD);
} else {
- return SynchronizerConstants.SIMPLE_DATE_FORMAT
+ return this.simpleDateFormat
.format(getNextSyncTime(getTargetSyncTime(), taskFrequencyInSeconds))
.replaceAll(SynchronizerConstants.TIME_STD, SynchronizerConstants.TIME_CONFIG_STD);
throw ex;
} finally {
if (bufferedReader != null) {
- try {
bufferedReader.close();
- } catch (IOException ex) {
- throw ex;
- }
}
}
public OperationResult buildVisualizationUsingGenericQuery(QueryRequest queryRequest) {
OperationResult returnValue = new OperationResult();
- OperationResult dataCollectionResult = null;
+ OperationResult dataCollectionResult = new OperationResult();
QueryParams queryParams = null;
SearchableEntity sourceEntity = null;
--- /dev/null
+package org.onap.aai.sparky.aggregation.sync;
+
+
+import org.junit.Test;
+
+import static org.junit.Assert.assertEquals;
+
+public class HistoricalEntitySyncControllerTest {
+
+ @Test
+ public void shouldConvertMinutesToMs() {
+ assertEquals(60000, HistoricalEntitySyncController.getTaskFrequencyInMs(1));
+ assertEquals(120000, HistoricalEntitySyncController.getTaskFrequencyInMs(2));
+ }
+
+}
\ No newline at end of file