Skip to content
Snippets Groups Projects
Commit f08c50f4 authored by wactbprot's avatar wactbprot
Browse files

+ worker: genMeasDoc, runMp: run --> load;run

parent d0d38d49
No related branches found
No related tags found
No related merge requests found
/**
* @module work.wait
* @module work.genMeasDoc
*/
var _ = require("underscore")
, bunyan = require("bunyan")
, broker = require("sc-broker")
, net = require("./net")
, request = require("./request")
, conf = require("./conf")
, utils = require("./utils")
, log = bunyan.createLogger({name: conf.app.name + ".worker.wait",
, log = bunyan.createLogger({name: conf.app.name + ".worker.genMeasDoc",
streams: conf.log.streams
})
, mem = broker.createClient({port: conf.mem.port})
, ro = {ok: true}
, err;
......@@ -21,11 +26,38 @@ var _ = require("underscore")
* @param {Function} cb Callback Funktion
*/
module.exports = function(task, cb){
var path = task.Path
, mdoc = task.Value
var path = task.Path
, mdoc = task.Value
, wrtdata = JSON.stringify(mdoc);
log.info(ro,
"generate measurement doc with id: " + mdoc._id);
net.wrtdoc(mdoc._id, function(err, con){
request.exec(con, task, wrtdata, function (err, data){
if(err){
log.error(err
, "received error in callback");
cb(err);
} else {
var val = { id: path[0]
, cdid: mdoc._id}
log.info(ro,
"generated measurement doc:" + JSON.stringify(data));
mem.publish("get_cd", val, function(err){
if(!err){
log.trace(ro
, "published to get_cd channel");
if(_.isFunction(cb)){
cb(null, ro)
}
}else{
log.error(err
, "error on attempt to publish to get_cd channel");
if(_.isFunction(cb)){
cb(err)
}
}
});
}
});
});
};
......@@ -37,7 +37,7 @@ module.exports = function(task, cb){
, "mp not available");
cb(err);
} else {
mem.set(cpath, conf.ctrlStr.run, function(err){
mem.set(cpath, [conf.ctrlStr.load, conf.ctrlStr.run].join(";"), function(err){
if (!err) {
var inid = setInterval(function(){
mem.get(cpath, function(err, res){
......
......@@ -2,7 +2,7 @@
"author": "wactbprot",
"name": "ssmp",
"description": "server side measurment program",
"version": "1.3.0",
"version": "1.4.0",
"repository": {
"type": "git",
"url": "https://github.com/wactbprot/ssmp"
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment