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

loopback: adapt to new signal code and separate node-type configuration into in/out sections

Browse source
This commit is contained in:
Steffen Vogel 2018-08-20 18:29:00 +02:00
parent e4fedaf4c5
commit a59509294c
1 changed files with 6 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

11
lib/nodes/loopback.c
View file

@ -45,19 +45,19 @@ int loopback_parse(struct node *n, json_t *cfg)
return 0;
}
int loopback_open(struct node *n)
int loopback_start(struct node *n)
{
int ret;
struct loopback *l = (struct loopback *) n->_vd;
ret = pool_init(&l->pool, l->queuelen, SAMPLE_LENGTH(n->samplelen), &memory_hugepage);
ret = pool_init(&l->pool, l->queuelen, SAMPLE_LENGTH(list_length(&n->signals)), &memory_hugepage);
if (ret)
return ret;
return queue_signalled_init(&l->queue, l->queuelen, &memory_hugepage, QUEUE_SIGNALLED_EVENTFD);
}
int loopback_close(struct node *n)
int loopback_stop(struct node *n)
{
int ret;
struct loopback *l= (struct loopback *) n->_vd;
@ -125,11 +125,12 @@ static struct plugin p = {
.type = PLUGIN_TYPE_NODE,
.node = {
.vectorize = 0,
.flags = NODE_TYPE_PROVIDES_SIGNALS,
.size = sizeof(struct loopback),
.parse = loopback_parse,
.print = loopback_print,
.start = loopback_open,
.stop = loopback_close,
.start = loopback_start,
.stop = loopback_stop,
.read = loopback_read,
.write = loopback_write,
.fd = loopback_fd