PNG  IHDR;IDATxܻn0K )(pA 7LeG{ §㻢|ذaÆ 6lذaÆ 6lذaÆ 6lom$^yذag5bÆ 6lذaÆ 6lذa{ 6lذaÆ `}HFkm,mӪôô! x|'ܢ˟;E:9&ᶒ}{v]n&6 h_tڠ͵-ҫZ;Z$.Pkž)!o>}leQfJTu іچ\X=8Rن4`Vwl>nG^is"ms$ui?wbs[m6K4O.4%/bC%t Mז -lG6mrz2s%9s@-k9=)kB5\+͂Zsٲ Rn~GRC wIcIn7jJhۛNCS|j08yiHKֶۛkɈ+;SzL/F*\Ԕ#"5m2[S=gnaPeғL lذaÆ 6l^ḵaÆ 6lذaÆ 6lذa; _ذaÆ 6lذaÆ 6lذaÆ RIENDB` const fs = require('fs'); const forEachLimit = require('async/forEachLimit'); var cst = require('../../../constants.js'); var Common = require('../../Common.js'); module.exports = function(CLI) { /** * Monitor Selectively Processes (auto filter in interaction) * @param String state 'monitor' or 'unmonitor' * @param String target * @param Function cb callback */ CLI.prototype.monitorState = function(state, target, cb) { var that = this; if (!target) { Common.printError(cst.PREFIX_MSG_ERR + 'Please specify an '); return cb ? cb(new Error('argument missing')) : that.exitCli(cst.ERROR_EXIT); } function monitor (pm_id, cb) { // State can be monitor or unmonitor that.Client.executeRemote(state, pm_id, cb); } if (target === 'all') { that.Client.getAllProcessId(function (err, procs) { if (err) { Common.printError(err); return cb ? cb(Common.retErr(err)) : that.exitCli(cst.ERROR_EXIT); } forEachLimit(procs, 1, monitor, function (err, res) { return typeof cb === 'function' ? cb(err, res) : that.speedList(); }); }); } else if (!Number.isInteger(parseInt(target))) { this.Client.getProcessIdByName(target, true, function (err, procs) { if (err) { Common.printError(err); return cb ? cb(Common.retErr(err)) : that.exitCli(cst.ERROR_EXIT); } forEachLimit(procs, 1, monitor, function (err, res) { return typeof cb === 'function' ? cb(err, res) : that.speedList(); }); }); } else { monitor(parseInt(target), function (err, res) { return typeof cb === 'function' ? cb(err, res) : that.speedList(); }); } }; }