Blame: lib/Worker.js - Unitech/pm2 - Morph

SIGN IN SIGN UP

Unitech / pm2 UNCLAIMED

Node.js Production Process Manager with a built-in Load Balancer.

43013 0 18 JavaScript

Normal View History Raw

add Copyright header to each file 2016-03-22 23:33:43 +01:00			`/**`
Update copywrite year (2021 -> 2022) 2022-01-19 11:41:33 +01:00			`* Copyright 2013-2022 the PM2 project authors. All rights reserved.`
add Copyright header to each file 2016-03-22 23:33:43 +01:00			`* Use of this source code is governed by a license that`
			`* can be found in the LICENSE file.`
			`*/`
use croner instead of node-schedule 2022-02-09 10:19:31 +01:00			`const eachLimit = require('async/eachLimit');`
			`const debug = require('debug')('pm2:worker');`
			`const domain = require('domain');`
			`const Cron = require('croner');`
			`const pkg = require('../package.json');`

			`var cst = require('../constants.js');`
chore: version check 2019-12-10 16:42:31 +01:00			`var vCheck = require('./VersionCheck.js')`
Worker implemented but not finished yet 2014-11-07 17:38:37 +01:00
Worker is working :P 2014-11-10 14:45:41 +01:00			`module.exports = function(God) {`
			`var timer = null;`
Worker implemented but not finished yet 2014-11-07 17:38:37 +01:00
Use a Map instead of an object to keep cron jobs in memory 2018-10-09 11:04:30 +02:00			`God.CronJobs = new Map();`
Worker is working :P 2014-11-10 14:45:41 +01:00			`God.Worker = {};`
re-refactor worker 2014-11-18 18:14:34 +01:00			`God.Worker.is_running = false;`
Worker implemented but not finished yet 2014-11-07 17:38:37 +01:00
fix: right cron prefix + re activate cron on restart 2019-11-18 15:36:26 +01:00			`God.getCronID = function(pm_id) {`
			return `cron-${pm_id}`
			`}`

fix: cron refactor 2019-11-14 23:37:35 +01:00			`God.registerCron = function(pm2_env) {`
			`if (!pm2_env \|\|`
			`pm2_env.pm_id === undefined \|\|`
			`!pm2_env.cron_restart \|\|`
cron restarts improvements 2021-09-24 12:40:46 +02:00			`pm2_env.cron_restart == '0' \|\|`
fix: right cron prefix + re activate cron on restart 2019-11-18 15:36:26 +01:00			`God.CronJobs.has(God.getCronID(pm2_env.pm_id)))`
fix #2487 put cron in the worker 2018-10-06 10:52:18 +02:00			`return;`

fix: cron-restart in cluster mode + alias --cron to --cron-restart fix #4834 #4733 #4307 #4834 2020-12-09 11:55:41 +01:00			`var pm_id = pm2_env.pm_id`
			`console.log('[PM2][WORKER] Registering a cron job on:', pm_id);`
fix #2487 put cron in the worker 2018-10-06 10:52:18 +02:00
use croner instead of node-schedule 2022-02-09 10:19:31 +01:00			`var job = Cron(pm2_env.cron_restart, function() {`
Replaced cron with node-schedule 2021-09-24 22:57:02 +02:00			`God.restartProcessId({id: pm_id}, function(err, data) {`
			`if (err)`
			`console.error(err.stack \|\| err);`
			`return;`
			`});`
fix #2487 put cron in the worker 2018-10-06 10:52:18 +02:00			`});`

fix: cron-restart in cluster mode + alias --cron to --cron-restart fix #4834 #4733 #4307 #4834 2020-12-09 11:55:41 +01:00			`God.CronJobs.set(God.getCronID(pm_id), job);`
fix: cron refactor 2019-11-14 23:37:35 +01:00			`}`


			`/**`
			`* Deletes the cron job on deletion of process`
			`*/`
			`God.deleteCron = function(id) {`
fix: right cron prefix + re activate cron on restart 2019-11-18 15:36:26 +01:00			`if (typeof(id) !== 'undefined' && God.CronJobs.has(God.getCronID(id)) === false)`
fix: cron refactor 2019-11-14 23:37:35 +01:00			`return;`
			`console.log('[PM2] Deregistering a cron job on:', id);`
fix: right cron prefix + re activate cron on restart 2019-11-18 15:36:26 +01:00			`var job = God.CronJobs.get(God.getCronID(id));`
fix cron check 2022-02-08 10:14:16 +01:00
			`if (job)`
use croner instead of node-schedule 2022-02-09 10:19:31 +01:00			`job.stop();`
fix cron check 2022-02-08 10:14:16 +01:00
fix: right cron prefix + re activate cron on restart 2019-11-18 15:36:26 +01:00			`God.CronJobs.delete(God.getCronID(id));`
fix: cron refactor 2019-11-14 23:37:35 +01:00			`};`

			`var _getProcessById = function(pm_id) {`
			`var proc = God.clusters_db[pm_id];`
			`return proc ? proc : null;`
fix #2487 put cron in the worker 2018-10-06 10:52:18 +02:00			`};`


re-refactor worker 2014-11-18 18:14:34 +01:00			`var maxMemoryRestart = function(proc_key, cb) {`
			`var proc = _getProcessById(proc_key.pm2_env.pm_id);`
worker refactored 2014-11-18 15:41:20 +01:00
re-refactor worker 2014-11-18 18:14:34 +01:00			`if (!(proc &&`
			`proc.pm2_env &&`
Worker: restart process if using 0 memory and status equals ONLINE 2014-11-21 16:53:14 +01:00			`proc_key.monit))`
re-refactor worker 2014-11-18 18:14:34 +01:00			`return cb();`

Worker: restart process if using 0 memory and status equals ONLINE 2014-11-21 16:53:14 +01:00			`if (proc_key.monit.memory !== undefined &&`
			`proc.pm2_env.max_memory_restart !== undefined &&`
(fix) module pid/mem monitoring 2016-11-28 16:14:20 +01:00			`proc.pm2_env.max_memory_restart < proc_key.monit.memory &&`
restart if module only 2016-11-30 10:53:30 +01:00			`proc.pm2_env.axm_options &&`
(fix) module pid/mem monitoring 2016-11-28 16:14:20 +01:00			`proc.pm2_env.axm_options.pid === undefined) {`
(pm2)(worker) display current memory usage when restarting on memory limit 2016-08-06 21:13:40 -07:00			`console.log('[PM2][WORKER] Process %s restarted because it exceeds --max-memory-restart value (current_memory=%s max_memory_limit=%s [octets])', proc.pm2_env.pm_id, proc_key.monit.memory, proc.pm2_env.max_memory_restart);`
fix: cron-restart in cluster mode + alias --cron to --cron-restart fix #4834 #4733 #4307 #4834 2020-12-09 11:55:41 +01:00			`God.reloadProcessId({`
#2012 #1650 #1743 #1613: allow reconfiguration attrs/env on reload 2016-03-11 16:23:11 +01:00			`id : proc.pm2_env.pm_id`
			`}, function(err, data) {`
re-refactor worker 2014-11-18 18:14:34 +01:00			`if (err)`
			`console.error(err.stack \|\| err);`
worker refactored 2014-11-18 15:41:20 +01:00			`return cb();`
re-refactor worker 2014-11-18 18:14:34 +01:00			`});`
			`}`
Worker: restart process if using 0 memory and status equals ONLINE 2014-11-21 16:53:14 +01:00			`else {`
re-refactor worker 2014-11-18 18:14:34 +01:00			`return cb();`
Worker: restart process if using 0 memory and status equals ONLINE 2014-11-21 16:53:14 +01:00			`}`
--max-memory-restart implemented 2014-11-17 17:47:52 +01:00			`};`

Worker is working :P 2014-11-10 14:45:41 +01:00			`var tasks = function() {`
re-refactor worker 2014-11-18 18:14:34 +01:00			`if (God.Worker.is_running === true) {`
			`debug('[PM2][WORKER] Worker is already running, skipping this round');`
			`return false;`
			`}`
			`God.Worker.is_running = true;`
refactor worker 2014-11-16 13:20:14 +01:00
worker refactored 2014-11-18 15:41:20 +01:00			`God.getMonitorData(null, function(err, data) {`
re-refactor worker 2014-11-18 18:14:34 +01:00			`if (err \|\| !data \|\| typeof(data) !== 'object') {`
			`God.Worker.is_running = false;`
			`return console.error(err);`
			`}`
--max-memory-restart implemented 2014-11-17 17:47:52 +01:00
#3928 reset restart delay once application is in stable mode 2018-10-03 11:17:53 +02:00			`eachLimit(data, 1, function(proc, next) {`
			`if (!proc \|\| !proc.pm2_env \|\| proc.pm2_env.pm_id === undefined)`
re-refactor worker 2014-11-18 18:14:34 +01:00			`return next();`
worker refactored 2014-11-18 15:41:20 +01:00
#3928 reset restart delay once application is in stable mode 2018-10-03 11:17:53 +02:00			`debug('[PM2][WORKER] Processing proc id:', proc.pm2_env.pm_id);`

			`// Reset restart delay if application has an uptime of more > 30secs`
			`if (proc.pm2_env.exp_backoff_restart_delay !== undefined &&`
			`proc.pm2_env.prev_restart_delay && proc.pm2_env.prev_restart_delay > 0) {`
			`var app_uptime = Date.now() - proc.pm2_env.pm_uptime`
			`if (app_uptime > cst.EXP_BACKOFF_RESET_TIMER) {`
			`var ref_proc = _getProcessById(proc.pm2_env.pm_id);`
			`ref_proc.pm2_env.prev_restart_delay = 0`
Small grammar fix and addition of units to output. 2020-08-11 20:59:11 +10:00			console.log(`[PM2][WORKER] Reset the restart delay, as app ${proc.name} has been up for more than ${cst.EXP_BACKOFF_RESET_TIMER}ms`)
#3928 reset restart delay once application is in stable mode 2018-10-03 11:17:53 +02:00			`}`
			`}`

			`// Check if application has reached memory threshold`
			`maxMemoryRestart(proc, function() {`
#3932 address CPU spikes - now using bellow to 0.5% in average 2018-09-28 20:47:57 +02:00			`return next();`
worker refactored 2014-11-18 15:41:20 +01:00			`});`
re-refactor worker 2014-11-18 18:14:34 +01:00			`}, function(err) {`
			`God.Worker.is_running = false;`
Fixed: multiple calls to vizion.parse() for the same process 2015-01-09 16:01:14 +01:00			`debug('[PM2][WORKER] My job here is done, next job in %d seconds', parseInt(cst.WORKER_INTERVAL / 1000));`
worker refactored 2014-11-18 15:41:20 +01:00			`});`
			`});`
Worker is working :P 2014-11-10 14:45:41 +01:00			`};`

fixed ENOMEM crashing PM2 2015-06-05 17:50:30 +02:00			`var wrappedTasks = function() {`
			`var d = domain.create();`

			`d.once('error', function(err) {`
			`console.error('[PM2][WORKER] Error caught by domain:\n' + (err.stack \|\| err));`
			`God.Worker.is_running = false;`
			`});`

			`d.run(function() {`
			`tasks();`
			`});`
			`};`


Worker is working :P 2014-11-10 14:45:41 +01:00			`God.Worker.start = function() {`
fixed ENOMEM crashing PM2 2015-06-05 17:50:30 +02:00			`timer = setInterval(wrappedTasks, cst.WORKER_INTERVAL);`
chore: version check 2019-12-10 16:42:31 +01:00
feat: add support for disabling version checks This adds support for a `PM2_DISABLE_VERSION_CHECKS` env variable, which will disabling running version checks for PM2. 2024-07-07 14:36:36 -04:00			`if (!process.env.PM2_DISABLE_VERSION_CHECK) {`
			`setInterval(() => {`
			`vCheck({`
			`state: 'check',`
			`version: pkg.version,`
			`});`
			`}, 1000 * 60 * 60 * 24);`
			`}`
Worker is working :P 2014-11-10 14:45:41 +01:00			`};`

			`God.Worker.stop = function() {`
			`if (timer !== null)`
			`clearInterval(timer);`
			`};`
			`};`