fez5587/Superalgos
1
0 Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Inter Process Memory Implemented

Browse Source
This commit is contained in:
Luis Fernando Molina committed 2019-03-18 21:41:27 +01:00
1 parent d0a7f15c07
commit aa6ea90bad
2 files changed
+33 -3
Download Patch File Download Diff File Expand all files Collapse all files

No files matched your search

MultiPeriodDaily.js
+26 -2
View File
@@ -98,6 +98,8 @@
let previousDay; // Holds the date of the previous day relative to the processing date.
let currentDay; // Holds the processing date.
let interExecutionMemoryArray;
getContextVariables();
function getContextVariables() {
@@ -233,7 +235,7 @@
contextVariables.lastFile = new Date(thisReport.lastFile);
if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> getContextVariables -> thisReport.lastFile !== undefined"); }
interExecutionMemoryArray = thisReport.interExecutionMemoryArray;
processTimePeriods();
return;
@@ -251,6 +253,19 @@
if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> getContextVariables -> thisReport.lastFile === undefined"); }
if (FULL_LOG === true) { logger.write(MODULE_NAME, "[INFO] start -> getContextVariables -> contextVariables.lastFile = " + contextVariables.lastFile); }
/*
The first time the process is running is the right time to create the data structure that is going to be shared across different executions.
This data structure has one object per each timePeriod.
*/
interExecutionMemoryArray = [];
for (let i = 0; i < global.dailyFilePeriods.length; i++)
{
let emptyObject = {};
interExecutionMemoryArray.push(emptyObject);
}
processTimePeriods();
return;
}
@@ -511,7 +526,15 @@
const timePeriod = global.dailyFilePeriods[n][0];
const outputPeriodLabel = global.dailyFilePeriods[n][1];
usertBot.start(dataFiles, timePeriod, outputPeriodLabel, currentDay, contextVariables.dateBeginOfMarket, contextVariables.dateEndOfMarket, onBotFinished);
usertBot.start(
dataFiles,
timePeriod,
outputPeriodLabel,
currentDay,
contextVariables.dateBeginOfMarket,
contextVariables.dateEndOfMarket,
interExecutionMemoryArray[n],
onBotFinished);
function onBotFinished(err) {
@@ -688,6 +711,7 @@
thisReport.file.lastExecution = bot.currentDaytime;
thisReport.file.lastFile = lastFileDate;
thisReport.file.interExecutionMemoryArray = interExecutionMemoryArray;
thisReport.save(callBack);
}
MultiPeriodMarket.js
+7 -1
View File
@@ -244,7 +244,13 @@
const timePeriod = global.marketFilesPeriods[n][0];
const outputPeriodLabel = global.marketFilesPeriods[n][1];
usertBot.start(dataFiles, timePeriod, outputPeriodLabel, contextVariables.dateBeginOfMarket, contextVariables.dateEndOfMarket, onBotFinished);
usertBot.start(
dataFiles,
timePeriod,
outputPeriodLabel,
contextVariables.dateBeginOfMarket,
contextVariables.dateEndOfMarket,
onBotFinished);
function onBotFinished(err) {