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-30 18:35:00 -04:00
parent 4b4ab75aaa
commit 3e0d34a2f5
1 changed files with 5 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
routes/api.js
View File

@ -56,7 +56,7 @@ var workers = (function(){
}; };
workers.destroy = function(worker){ workers.destroy = function(worker){
worker = worker || workers.pop(); var worker = worker || workers.pop();
doapi.dropletDestroy(worker.id, function(){ doapi.dropletDestroy(worker.id, function(){
isCheckingWorkers = false; isCheckingWorkers = false;
}); });
@ -93,14 +93,14 @@ var workers = (function(){
}; };
workers.startRunners = function(worker, newWorker, stopPercent){ workers.startRunners = function(worker, newWorker, stopPercent){
console.log('starting runners on', worker.name, worker.ip) // console.log('starting runners on', worker.name, worker.ip)
stopPercent = stopPercent || 80; stopPercent = stopPercent || 80;
ramPercentUsed(worker.ip, function(usedMemPercent){ ramPercentUsed(worker.ip, function(usedMemPercent){
if(usedMemPercent < stopPercent ){ if(usedMemPercent < stopPercent ){
var name = 'crunner-'+(Math.random()*100).toString().replace('.',''); var name = 'crunner-'+(Math.random()*100).toString().replace('.','');
return lxc.startEphemeral(name, 'crunner0', worker.ip, function(data){ return lxc.startEphemeral(name, 'crunner0', worker.ip, function(data){
if(!data.ip) return setTimeout(workers.startRunners(worker, newWorker),0); if(!data.ip) return setTimeout(workers.startRunners(worker, newWorker),0);
console.log('started runner') console.log('started runner on', worker.name)
if(newWorker) worker = workers[workers.push(worker)-1] if(newWorker) worker = workers[workers.push(worker)-1]
worker.availrunners.push({ worker.availrunners.push({
@ -112,7 +112,7 @@ var workers = (function(){
return setTimeout(workers.startRunners(worker, stopPercent), 0); return setTimeout(workers.startRunners(worker, stopPercent), 0);
}); });
}else{ }else{
console.log('using', usedMemPercent, 'percent memory, stopping runner creation!', worker.availrunners.length, 'created on ', worker.name); console.log('using', String(usedMemPercent), 'percent memory, stopping runner creation!', worker.availrunners.length, 'created on ', worker.name);
} }
}); });
}; };
@ -222,6 +222,7 @@ var getAvailrunner = function(runner){
return false; return false;
}; };
setTimeout(function(){ setTimeout(function(){
console.log('Starting balance checking in 30 seconds')
setInterval(workers.checkBalance, 30000); setInterval(workers.checkBalance, 30000);
}, 180000); }, 180000);
workers.destroyOld(); workers.destroyOld();