wmantly/lxc_manager_node
1
1
Fork 0
Code Issues Pull Requests Releases Wiki Activity

simpler

Browse Source
This commit is contained in:
William Mantly 2017-10-09 00:26:58 -04:00
parent b45f45153f
commit 14a628a8ff
2 changed files with 23 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
routes/api.js
View File

@ -215,9 +215,10 @@ var workers = (function(){
workers.checkForZombies(); workers.checkForZombies();
// if there are workers being created, stop scale up and down check // if there are workers being created, stop scale up and down check
if(workers.currentCreating) return ; if(workers.currentCreating+workers.length < workers.min) 'do nothing';
else if(workers.currentCreating)
return ;
// scale up and down check
// hold amount of workers with no used runners // hold amount of workers with no used runners
var lastMinAval = 0; var lastMinAval = 0;
@ -234,13 +235,23 @@ var workers = (function(){
if(lastMinAval > workers.settings.minAvail){ if(lastMinAval > workers.settings.minAvail){
// Remove workers if there are more then the settings states // Remove workers if there are more then the settings states
console.log('Last 3 runners not used, killing last runner', workers.length); console.log(
'Last 3 runners not used, killing last runner',
'lastMinAval:', lastMinAval,
'minAvail:', workers.settings.minAvail,
'workers:', workers.length
);
return workers.destroy(); return workers.destroy();
} else if(lastMinAval < workers.settings.minAvail){ } else if(lastMinAval < workers.settings.minAvail){
// creates workers if the settings file demands it // creates workers if the settings file demands it
console.log('last 3 workers have no free runners, starting droplet'); console.log(
'last 3 workers have no free runners, starting droplet',
'lastMinAval:', lastMinAval,
'minAvail:', workers.settings.minAvail,
'workers:', workers.length
);
return workers.create(); return workers.create();
} }

14
testAPI.js
View File

@ -1,16 +1,18 @@
const request = require('request'); const request = require('request');
var till = 15; var till = 5;
var completed = 0; var completed = 0;
var errors = 0; var errors = 0;
for(let i=0; i<till; i++){ for(let i=0; i<till; i++){
console.log('calling', i); console.log('calling', i);
let httpOptions = { let httpOptions = {
url: 'http://codeland.bytedev.co:2000/api/run', url: 'http://codeland.bytedev.co:2000/api/run?once=true',
form: { form: {
code: `python3 -c "print(1)"`, code: `python3 -c "
once: true, from time import sleep
sleep(10)
"`,
} }
}; };
request.post(httpOptions, function(error, response, body){ request.post(httpOptions, function(error, response, body){
@ -20,8 +22,8 @@ for(let i=0; i<till; i++){
} }
body = JSON.parse(body); body = JSON.parse(body);
let res = (Buffer.from(body.res, 'base64').toString('ascii'));
console.log(i, body); console.log(i, res);
if(completed===till){ if(completed===till){
console.log(errors); console.log(errors);
} }