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

stuff

Browse Source
This commit is contained in:
William Mantly 2016-05-27 19:47:34 -04:00
parent 71bd4ffc4a
commit d5bd5d2c39
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
routes/api.js
View File

@ -19,12 +19,14 @@ var checkDroplet = function(id, time){
doapi.dropletInfo(id, function(data){ doapi.dropletInfo(id, function(data){
newWorker = JSON.parse(data)['droplet']; newWorker = JSON.parse(data)['droplet'];
if(newWorker.status == 'active'){ if(newWorker.status == 'active'){
console.log('Runner is now active, starting runners in 10 seconds')
setTimeout(function(){ setTimeout(function(){
startRunners(workers[workers.push(makeWorkerObj(newWorker))-1]) startRunners(workers[workers.push(makeWorkerObj(newWorker))-1])
}, 10000); }, 10000);
isCheckingWorkers = false; isCheckingWorkers = false;
return true; return true;
}else{ }else{
console.log('Worker not ready, check again in ', time, 'MS');
setTimeout(function(){ setTimeout(function(){
checkDroplet(id) checkDroplet(id)
}, time); }, time);
@ -56,7 +58,7 @@ var checkWorkersBalance = function(){
isCheckingWorkers = true; isCheckingWorkers = true;
if(workers.length < 2){ if(workers.length < 2){
console.log('No workers, starting droplet'); console.log('less then 2 workers, starting a droplet');
return workerCreate(); return workerCreate();
} }
if(workers[workers.length-1].usedrunner !== 0){ if(workers[workers.length-1].usedrunner !== 0){
@ -67,6 +69,7 @@ var checkWorkersBalance = function(){
console.log('Last 2 runners not used, killing last runner'); console.log('Last 2 runners not used, killing last runner');
workerDestroy(); workerDestroy();
} }
console.log('stopping workers balancing check');
isCheckingWorkers = false; isCheckingWorkers = false;
}; };
@ -158,7 +161,8 @@ var initWorkers = function(){
var getAvailrunner = function(runner){ var getAvailrunner = function(runner){
for(let worker of workers){ for(let worker of workers){
if(worker.availrunners.length !== 0) continue; console.log('checking ', worker.name, ' with ', worker.availrunners.length, ' free workers');
if(worker.availrunners.length === 0) continue;
// if(runner) runnerFree(runner); // if(runner) runnerFree(runner);
return worker.getRunner(); return worker.getRunner();
} }