Comparing version 0.4.25 to 0.4.26
@@ -188,2 +188,19 @@ /* | ||
function stopWorker(signal){ | ||
if(!exports.safeKill(pid, signal, logger)){ | ||
//worker still there, should emit 'exit' eventually | ||
logger.debug('[deathQueue] worker:%d did not report death by:%d, kill by '+signal, pid, wait); | ||
if (signal === 'SIGTERM') { | ||
deathGuard = setTimeout(stopWorker.bind(null, 'SIGKILL'), wait); | ||
} | ||
} | ||
else{//suicide or accident already happended, process has run away | ||
//we emit this from master on behalf of the run away process. | ||
logger.debug('[deathQueue] worker:%d probably ran away, emit:%s on behalf', death); | ||
//immediately report death to the master | ||
emitter.emit('died', pid); | ||
} | ||
} | ||
var onDeath = function onDeath(dismiss){ | ||
@@ -213,17 +230,4 @@ | ||
}, | ||
deathGuard = setTimeout(function(){ | ||
deathGuard = setTimeout(stopWorker.bind(null, 'SIGTERM'), wait); | ||
if(!exports.safeKill(pid, 'SIGTERM', logger)){ | ||
//worker still there, should emit 'exit' eventually | ||
logger.debug('[deathQueue] worker:%d did not report death by:%d, kill by SIGTERM', pid, wait); | ||
} | ||
else{//suicide or accident already happended, process has run away | ||
//we emit this from master on behalf of the run away process. | ||
logger.debug('[deathQueue] worker:%d probably ran away, emit:%s on behalf', death); | ||
//immediately report death to the master | ||
emitter.emit('died', pid); | ||
} | ||
}, wait); | ||
worker.kill('SIGINT'); | ||
@@ -251,3 +255,3 @@ | ||
exports.deathQueue = exports.deathQueueGenerator({ | ||
'timeout': 60000 | ||
'timeout': process.env.DEATH_TIMEOUT || 60000 | ||
}); |
{ | ||
"author": "ql.io", | ||
"contributors": [{ | ||
"name": "Subbu Allamaraju", | ||
"email": "subbu@ebaysf.com" | ||
}, | ||
"author": "ql.io", | ||
"contributors": [ | ||
{ | ||
"name": "Roy Zhou", | ||
"email": "huzhou@ebay.com" | ||
}], | ||
"name": "cluster2", | ||
"version": "0.4.25", | ||
"repository": { | ||
"type": "git", | ||
"url": "https://github.com/cubejs/cluster2" | ||
"name": "Subbu Allamaraju", | ||
"email": "subbu@ebaysf.com" | ||
}, | ||
"engines": { | ||
"node": ">= 0.8.0" | ||
}, | ||
"main": "lib/index.js", | ||
"dependencies": { | ||
"underscore": "~1.4.4", | ||
"express": "~2.5.11", | ||
"ejs": "~0.8.4", | ||
"npm": "~1.3.0", | ||
"when": "~2.4.0", | ||
"usage": "~0.3.8", | ||
"bignumber.js": "~1.1.1", | ||
"gc-stats": "~0.0.1" | ||
}, | ||
"devDependencies": { | ||
"websocket": "~1.0.8", | ||
"nodeunit": "~0.8.0", | ||
"request": "~2.21.0", | ||
"mocha": "~1.11.0", | ||
"should": "~1.2.2", | ||
"harbor": "~0.2.0" | ||
}, | ||
"scripts": { | ||
"test": "nodeunit test" | ||
}, | ||
"optionalDependencies": {}, | ||
"publishConfig": { | ||
"registry": "https://registry.npmjs.org/" | ||
{ | ||
"name": "Roy Zhou", | ||
"email": "huzhou@ebay.com" | ||
} | ||
} | ||
], | ||
"name": "cluster2", | ||
"version": "0.4.26", | ||
"repository": { | ||
"type": "git", | ||
"url": "https://github.com/cubejs/cluster2" | ||
}, | ||
"engines": { | ||
"node": ">= 0.8.0" | ||
}, | ||
"main": "lib/index.js", | ||
"dependencies": { | ||
"underscore": "~1.4.4", | ||
"express": "~2.5.11", | ||
"ejs": "~0.8.4", | ||
"npm": "~1.3.0", | ||
"when": "~2.4.0", | ||
"usage": "~0.3.8", | ||
"bignumber.js": "~1.1.1", | ||
"gc-stats": "~0.0.1" | ||
}, | ||
"devDependencies": { | ||
"websocket": "~1.0.8", | ||
"nodeunit": "~0.8.0", | ||
"request": "~2.21.0", | ||
"mocha": "~1.11.0", | ||
"should": "~1.2.2", | ||
"harbor": "~0.2.0" | ||
}, | ||
"scripts": { | ||
"test": "nodeunit test" | ||
}, | ||
"optionalDependencies": {}, | ||
"publishConfig": { | ||
"registry": "https://registry.npmjs.org/" | ||
}, | ||
"ebay": {} | ||
} |
Environment variable access
Supply chain riskPackage accesses environment variables, which may be a sign of credential stuffing or data theft.
Found 1 instance in 1 package
120852
2036
26
6