This commit is contained in:
William Mantly 2016-05-30 16:28:07 -04:00
parent 4c2a4b7657
commit d22a79c81e

View File

@ -89,7 +89,7 @@ var workers = (function(){
console.log('found old droplet, killing it'); console.log('found old droplet, killing it');
doapi.dropletDestroy(worker.id, function(){}); doapi.dropletDestroy(worker.id, function(){});
}); });
workers.checkBalance(); // workers.checkBalance();
}); });
}; };
@ -122,20 +122,22 @@ var workers = (function(){
if(isCheckingWorkers) return false; if(isCheckingWorkers) return false;
isCheckingWorkers = true; isCheckingWorkers = true;
var changed = false; var changed = false;
var minWorkers = 3;
console.log('checking balance'); console.log('checking balance');
if(workers.length < 3){ if(workers.length < minWorkers){
console.log('less then 3 workers, starting a droplet'); console.log('less then 3 workers, starting a droplet');
for(var i=2; i--;) workers.create(); for(var i=minWorkers; i--;) workers.create();
return ; return ;
} }
if(workers[workers.length-1].usedrunner !== 0){ if(workers[workers.length-1].usedrunner !== 0){
console.log('last droplet has no free runners, starting droplet'); console.log('last droplet has no free runners, starting droplet');
return workers.create(); return workers.create();
} }
if(workers.length > 3 && workers[workers.length-1].usedrunner === 0 && workers[workers.length-2].usedrunner === 0){ if(workers.length > minWorkers && workers[workers.length-1].usedrunner === 0 && workers[workers.length-2].usedrunner === 0){
console.log('Last 2 runners not used, killing last runner'); console.log('Last 2 runners not used, killing last runner');
workers.destroy(); workers.destroy();
changed = true;
} }
for(let worker of workers){ for(let worker of workers){
@ -150,7 +152,7 @@ var workers = (function(){
isCheckingWorkers = false; isCheckingWorkers = false;
if(changed) setTimeout(function(){ if(changed) setTimeout(function(){
workers.checkBalance(); workers.checkBalance();
}, 3000); }, 5000);
}; };
return workers; return workers;