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

timeout

Browse Source
This commit is contained in:
William Mantly 2016-02-14 11:02:08 -05:00
parent b7ae900557
commit 39b64a4ecd
1 changed files with 20 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

20
routes/api.js
View File

@ -8,7 +8,26 @@ var client = redis.createClient();
var request = require('request'); var request = require('request');
var lxc = require('../lxc'); var lxc = require('../lxc');
var timeoutEvents = {};
var ip2name = {};
var lxcTimeout = function(ip, time){
var name = ip2name[ip];
console.log(name)
time = time || 100000;
var keys = Object.keys(timeoutEvents)
if(keys.indexOf(name) !== -1){
clearTimeout(timeoutEvents[name])
}
timeoutEvents[name] = setTimeout(function(){
lxc.stop(name);
}, time);
}
var runner = function(req, res, ip){ var runner = function(req, res, ip){
lxcTimeout(ip, 30000);
return request.post({url:'http://'+ip, form: req.body}, function(error, response, body){ return request.post({url:'http://'+ip, form: req.body}, function(error, response, body){
body = JSON.parse(body); body = JSON.parse(body);
body['ip'] = ip.replace('10.0.', ''); body['ip'] = ip.replace('10.0.', '');
@ -113,6 +132,7 @@ router.post('/run/:ip?', function doRun(req, res, next){
}else{ }else{
var name = 'u1-'+(Math.random()*100).toString().replace('.',''); var name = 'u1-'+(Math.random()*100).toString().replace('.','');
return lxc.startEphemeral(name, 'u1', function(data){ return lxc.startEphemeral(name, 'u1', function(data){
ip2name[data.ip] = name;
return runner(req, res, data.ip); return runner(req, res, data.ip);
}); });
} }