jjkiers/cloudron-box
1
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

make the globals const

Browse Source
This commit is contained in:
Girish Ramakrishnan
2022-05-20 09:38:17 -07:00
parent d366f3107d
commit d9a02faf7a
1 changed files with 3 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/scheduler.js
View File

@@ -16,9 +16,8 @@ const apps = require('./apps.js'),
safe = require('safetydance'), safe = require('safetydance'),
_ = require('underscore'); _ = require('underscore');
// appId -> { containerId, schedulerConfig (manifest), cronjobs } const gState = {}; // appId -> { containerId, schedulerConfig (manifest), cronjobs }
let gState = { }; const gSuspendedAppIds = new Set(); // suspended because some apptask is running
let gSuspendedAppIds = new Set(); // suspended because some apptask is running
// TODO: this should probably also stop existing jobs to completely prevent race but the code is not re-entrant // TODO: this should probably also stop existing jobs to completely prevent race but the code is not re-entrant
function suspendJobs(appId) { function suspendJobs(appId) {
@@ -120,10 +119,9 @@ async function sync() {
debug(`sync: removing jobs of ${appId}`); debug(`sync: removing jobs of ${appId}`);
const [error] = await safe(stopJobs(appId, gState[appId])); const [error] = await safe(stopJobs(appId, gState[appId]));
if (error) debug(`sync: error stopping jobs of removed app ${appId}: ${error.message}`); if (error) debug(`sync: error stopping jobs of removed app ${appId}: ${error.message}`);
delete gState[appId];
} }
gState = _.omit(gState, removedAppIds);
for (const app of allApps) { for (const app of allApps) {
const appState = gState[app.id] || null; const appState = gState[app.id] || null;
const schedulerConfig = apps.getSchedulerConfig(app); const schedulerConfig = apps.getSchedulerConfig(app);