wmantly/lxc_manager_node
1
1
Fork 0
Code Issues Pull Requests Releases Wiki Activity

patches for zombie check

Browse Source
This commit is contained in:
Thomas Harvey 2017-10-11 00:29:50 -04:00
parent 482fe08c07
commit 099bce3846
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
routes/worker_collection.js
View File

@ -66,7 +66,7 @@ var Worker = (function(){
worker.ip = worker.publicIP; worker.ip = worker.publicIP;
worker.usedrunners = 0; worker.usedrunners = 0;
worker.age = +(new Date()); worker.age = +(new Date());
console.log("AGE:",worker.age); worker.isBuildingRunners = false;
return worker; return worker;
}; };
@ -94,12 +94,12 @@ var Worker = (function(){
proto.destroy = function(){ proto.destroy = function(){
var worker = this; var worker = this;
return doapi.dropletDestroy(this.id, function(body) { return doapi.dropletDestroy(this.id, function(body) {
console.log('Deleted worker', this.name); console.log('Deleted worker', worker.name);
}); });
}; };
proto.isZombie = function(){ proto.isZombie = function(){
return this.availrunners.length === 0 && this.usedrunners === 0; return this.availrunners.length === 0 && this.usedrunners === 0 && !this.isBuildingRunners;
}; };
proto.startRunners = function(args){ proto.startRunners = function(args){
@ -111,16 +111,16 @@ var Worker = (function(){
console.log(`Blocked outdated worker(${worker.image.id}), current image ${args.settings.image}.`) console.log(`Blocked outdated worker(${worker.image.id}), current image ${args.settings.image}.`)
return ; return ;
} }
args = args || {}; args = args || {};
// percent of used RAM to stop runner creation // percent of used RAM to stop runner creation
args.stopPercent = args.stopPercent || 80; args.stopPercent = args.stopPercent || 80;
args.onStart = args.onStart || __empty; args.onStart = args.onStart || __empty;
args.onDone = args.onDone || __empty; args.onDone = args.onDone || __empty;
worker.isBuildingRunners = true;
worker.ramPercentUsed(function(usedMemPercent){ worker.ramPercentUsed(function(usedMemPercent){
if(usedMemPercent > args.stopPercent ){ if(usedMemPercent > args.stopPercent ){
worker.isBuildingRunners = false;
console.log('using', String(usedMemPercent).trim(), console.log('using', String(usedMemPercent).trim(),
'percent memory, stopping runner creation!', worker.availrunners.length, 'percent memory, stopping runner creation!', worker.availrunners.length,
'created on ', worker.name 'created on ', worker.name