Mirrors/VILLASnode
1
0
Fork 0
mirror of https://git.rwth-aachen.de/acs/public/villas/node/ synced 2025-03-09 00:00:00 +01:00
Code Issues Releases Wiki Activity

hook: extend print hook for showing prefixes

Browse source
This commit is contained in:
Steffen Vogel 2018-05-24 09:06:53 +02:00
parent 2d23ab52c9
commit 1bd03f22a8
1 changed files with 55 additions and 4 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

59
lib/hooks/print.c
View file

@ -26,6 +26,7 @@
#include <villas/hook.h>
#include <villas/plugin.h>
#include <villas/path.h>
#include <villas/sample.h>
#include <villas/io.h>
@ -33,7 +34,8 @@ struct print {
struct io io;
struct format_type *format;
const char *uri;
char *prefix;
char *uri;
};
static int print_init(struct hook *h)
@ -41,6 +43,7 @@ static int print_init(struct hook *h)
struct print *p = (struct print *) h->_vd;
p->uri = NULL;
p->prefix = NULL;
p->format = format_type_lookup("villas.human");
return 0;
@ -77,17 +80,24 @@ static int print_stop(struct hook *h)
static int print_parse(struct hook *h, json_t *cfg)
{
struct print *p = (struct print *) h->_vd;
const char *format = NULL;
const char *format = NULL, *prefix = NULL, *uri = NULL;
int ret;
json_error_t err;
ret = json_unpack_ex(cfg, &err, 0, "{ s?: s, s?: s }",
"output", &p->uri,
ret = json_unpack_ex(cfg, &err, 0, "{ s?: s, s?: s, s?: s }",
"output", &uri,
"prefix", &prefix,
"format", &format
);
if (ret)
jerror(&err, "Failed to parse configuration of hook '%s'", plugin_name(h->_vt));
if (prefix)
p->prefix = strdup(prefix);
if (uri)
p->uri = strdup(uri);
if (format) {
p->format = format_type_lookup(format);
if (!p->format)
@ -97,10 +107,43 @@ static int print_parse(struct hook *h, json_t *cfg)
return 0;
}
static int print_read(struct hook *h, struct sample *smps[], unsigned *cnt)
{
struct print *p = (struct print *) h->_vd;
if (p->prefix)
printf("%s", p->prefix);
else if (h->node)
printf("Node %s read: ", node_name(h->node));
io_print(&p->io, smps, *cnt);
return 0;
}
static int print_write(struct hook *h, struct sample *smps[], unsigned *cnt)
{
struct print *p = (struct print *) h->_vd;
if (p->prefix)
printf("%s", p->prefix);
else if (h->node)
printf("Node %s write: ", node_name(h->node));
io_print(&p->io, smps, *cnt);
return 0;
}
static int print_process(struct hook *h, struct sample *smps[], unsigned *cnt)
{
struct print *p = (struct print *) h->_vd;
if (p->prefix)
printf("%s", p->prefix);
else if (h->path)
printf("Path %s process: ", path_name(h->path));
io_print(&p->io, smps, *cnt);
return 0;
@ -111,6 +154,12 @@ static int print_destroy(struct hook *h)
int ret;
struct print *p = (struct print *) h->_vd;
if (p->uri)
free(p->uri);
if (p->prefix)
free(p->prefix);
ret = io_destroy(&p->io);
if (ret)
return ret;
@ -130,6 +179,8 @@ static struct plugin p = {
.destroy= print_destroy,
.start = print_start,
.stop = print_stop,
.read = print_read,
.write = print_write,
.process= print_process,
.size = sizeof(struct print)
}