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-26 20:41:25 -04:00
parent 19293fdaff
commit caf32c3809
1 changed files with 7 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
routes/api.js
View File

@ -2,7 +2,7 @@
var express = require('express'); var express = require('express');
var router = express.Router(); var router = express.Router();
var extend = require('node.extend'); var util = require('util');
var request = require('request'); var request = require('request');
var lxc = require('../lxc'); var lxc = require('../lxc');
var doapi = require('../doapi')(); var doapi = require('../doapi')();
@ -43,7 +43,6 @@ var lxcTimeout = function(container, time){
}; };
var runner = function(req, res, container){ var runner = function(req, res, container){
console.log('calling runner:', container);
var httpOptions = { var httpOptions = {
url: 'http://' + container.worker.ip, url: 'http://' + container.worker.ip,
@ -56,7 +55,7 @@ var runner = function(req, res, container){
}; };
return request.post(httpOptions, function(error, response, body){ return request.post(httpOptions, function(error, response, body){
console.log('runner response:', arguments) // console.log('runner response:', arguments)
body = JSON.parse(body); body = JSON.parse(body);
var i = -1; var i = -1;
while(workers[++i].availContainers.length && workers[i].index < container.worker.index){ while(workers[++i].availContainers.length && workers[i].index < container.worker.index){
@ -97,11 +96,11 @@ var getWorkers = function(){
var getAvailContainer = function(){ var getAvailContainer = function(){
var i = -1; var i = -1;
while(workers[++i].availContainers.length){ while(workers[++i].availContainers.length){
console.log('found avail on worker:', i);
var container = workers[i].availContainers.pop(); var container = workers[i].availContainers.pop();
label2container[container.label] = container; label2container[container.label] = container;
container.worker.usedContainer++; container.worker.usedContainer++;
console.log('return container:', container);
return container; return container;
} }
}; };
@ -198,7 +197,9 @@ router.get('/stop/:name', function(req, res, next){
}); });
router.get('/liststuff', function(req, res, next){ router.get('/liststuff', function(req, res, next){
res.json({'workers': workers}) var obj = util.inspect(workers);
console.log('worker inspected:', obj)
res.send(obj);
}); });
router.post('/run/:ip?', function doRun(req, res, next){ router.post('/run/:ip?', function doRun(req, res, next){