This commit is contained in:
William Mantly 2016-05-26 19:23:22 -04:00
parent 4651a2f49c
commit b74a71efb4

View File

@ -104,22 +104,22 @@ var getAvailContainer = function(){
} }
}; };
var startWorker = function(clworker, stopPercent){ var startWorker = function(worker, stopPercent){
stopPercent = stopPercent || 30; stopPercent = stopPercent || 30;
getFreeMem(clworker.ip, function(usedMemPercent){ getFreeMem(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', clworker.ip, function(data){ return lxc.startEphemeral(name, 'crunner0', worker.ip, function(data){
if( !data.ip ) return setTimeout(startWorker(clworker),0); if( !data.ip ) return setTimeout(startWorker(worker),0);
worker.availContainers.push({ worker.availContainers.push({
ip: data.ip, ip: data.ip,
name: name, name: name,
worker: clworker, worker: worker,
label: clworker.name+':'+name label: worker.name+':'+name
}); });
return setTimeout(startWorker(clworker, stopPercent), 0); return setTimeout(startWorker(worker, stopPercent), 0);
}); });
}else{ }else{
console.log('using', usedMemPercent, 'percent memory, stopping container creation!', worker.availContainers.length, 'created'); console.log('using', usedMemPercent, 'percent memory, stopping container creation!', worker.availContainers.length, 'created');