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-29 14:03:58 -04:00
parent 05b6a477f4
commit f63b6c3acd
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
routes/api.js
View File

@ -28,7 +28,7 @@ var workers = (function(){
console.log('Droplet is now active, starting runners in 20 seconds') console.log('Droplet is now active, starting runners in 20 seconds')
setTimeout(function(worker){ setTimeout(function(worker){
console.log('Ready to start runners!') console.log('Ready to start runners!')
workers.startRunners(workers[workers.push(workers.makeWorkerObj(worker))-1]) workers.workers.startRunners(workers[workers.push(workers.makeWorkerObj(worker))-1])
isCheckingWorkers = false; isCheckingWorkers = false;
}, 20000, worker); }, 20000, worker);
return true; return true;
@ -99,7 +99,7 @@ var workers = (function(){
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(startRunners(worker),0); if( !data.ip ) return setTimeout(workers.startRunners(worker),0);
console.log('started runner') console.log('started runner')
worker.availrunners.push({ worker.availrunners.push({
@ -108,7 +108,7 @@ var workers = (function(){
worker: worker, worker: worker,
label: worker.name + ':' + name label: worker.name + ':' + name
}); });
return setTimeout(startRunners(worker, stopPercent), 0); return setTimeout(workers.startRunners(worker, stopPercent), 0);
}); });
}else{ }else{
setTimeout(workers.checkBalance, 10000); setTimeout(workers.checkBalance, 10000);