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 01:05:15 -04:00
parent d7b32996b3
commit ac524a1c76
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
routes/api.js
View File

@ -14,13 +14,13 @@ var isCheckingWorkers = false;
var dopletNewID = 0; var dopletNewID = 0;
var checkDroplet = function(id, time){ var checkDroplet = function(id, time){
time = time || 30000; time = time || 5000;
doapi.dropletInfo(id, function(data){ doapi.dropletInfo(id, function(data){
var worker = JSON.parse(data)['droplet']; var worker = JSON.parse(data)['droplet'];
if(worker.status == 'active'){ if(worker.status == 'active'){
workers.push(makeWokerObj(worker)); workers.push(makeWokerObj(worker));
isCheckingWorkers = false; isCheckingWorkers = false;
return ch; return true;
}else{ }else{
setTimeout(function(){ setTimeout(function(){
checkDroplet(id) checkDroplet(id)
@ -56,6 +56,7 @@ var checkWorkersBalance = function(){
return workerCreate(); return workerCreate();
} }
if(!workers[workers.length-1].availrunners.length){ if(!workers[workers.length-1].availrunners.length){
console.log('starting new droplet!');
return workerCreate(); return workerCreate();
} }
if(!workers[workers.length-1].availrunners.length && !workers[workers.length-2].availrunners.length){ if(!workers[workers.length-1].availrunners.length && !workers[workers.length-2].availrunners.length){
@ -179,7 +180,7 @@ var startRunners = function(worker, stopPercent){
return setTimeout(startRunners(worker, stopPercent), 0); return setTimeout(startRunners(worker, stopPercent), 0);
}); });
}else{ }else{
setTimeout(checkWorkersBalance, 30000); setTimeout(checkWorkersBalance, 10000);
console.log('using', usedMemPercent, 'percent memory, stopping runner creation!', worker.availrunners.length, 'created on ', worker.name); console.log('using', usedMemPercent, 'percent memory, stopping runner creation!', worker.availrunners.length, 'created on ', worker.name);
} }
}); });