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 15:28:28 -04:00
parent 7fcbcecb6a
commit 9991e7eb36
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files

15
routes/api.js
View File

@ -19,7 +19,9 @@ 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'){
setTimeout(function(){startRunners(workers[workers.push(makeWokerObj(newWorker))-1])}, 5000); setTimeout(function(){
startRunners(workers[workers.push(makeWorkerObj(newWorker))-1])
}, 5000);
isCheckingWorkers = false; isCheckingWorkers = false;
return true; return true;
}else{ }else{
@ -46,6 +48,7 @@ var workerCreate = function(){
var workerDestroy = function(worker){ var workerDestroy = function(worker){
worker = worker || workers.pop(); worker = worker || workers.pop();
doapi.dropletDestroy(worker.id, function(){}); doapi.dropletDestroy(worker.id, function(){});
checkWorkersBalance();
}; };
var checkWorkersBalance = function(){ var checkWorkersBalance = function(){
@ -60,7 +63,7 @@ var checkWorkersBalance = function(){
console.log('last droplet has no free runners, starting droplet'); console.log('last droplet has no free runners, starting droplet');
return workerCreate(); return workerCreate();
} }
if(workers.length>1 && workers[workers.length-1].usedrunner === 0 && workers[workers.length-2].usedrunner === 0){ if(workers.length > 2 && 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');
workerDestroy(); workerDestroy();
} }
@ -97,7 +100,7 @@ var lxcTimeout = function(runner, time){
} }
return runner.timeout = setTimeout(function(){ return runner.timeout = setTimeout(function(){
runnerFree(runner) runnerFree(runner);
}, time); }, time);
}; };
@ -124,7 +127,7 @@ var runner = function(req, res, runner){
}); });
}; };
var makeWokerObj = function(worker){ var makeWorkerObj = function(worker){
worker.networks.v4.forEach(function(value){ worker.networks.v4.forEach(function(value){
worker[value.type+'IP'] = value.ip_address; worker[value.type+'IP'] = value.ip_address;
}); });
@ -147,14 +150,14 @@ var initWorkers = function(){
doapi.dropletsByTag('clworker', function(data){ doapi.dropletsByTag('clworker', function(data){
data = JSON.parse(data); data = JSON.parse(data);
data['droplets'].forEach(function(value){ data['droplets'].forEach(function(value){
startRunners(workers[workers.push(makeWokerObj(value))-1]); startRunners(workers[workers.push(makeWorkerObj(value))-1]);
}); });
}); });
}; };
var getAvailrunner = function(runner){ var getAvailrunner = function(runner){
var i = -1; var i = -1;
while(workers[++i].availrunners.length && ( runner && workers[i].index < runner.worker.index )){ while(workers[++i].availrunners.length !== 0 /*&& ( runner && workers[i].index < runner.worker.index )*/){
if(runner) runnerFree(runner); if(runner) runnerFree(runner);
return workers[i].getRunner(); return workers[i].getRunner();
} }