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

rebase to master

Browse source
This commit is contained in:
Manuel Pitz 2021-02-15 15:24:49 +01:00
commit af09e1bc69
1 changed files with 20 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

20
lib/nodes/mqtt.cpp
View file

@ -351,6 +351,26 @@ int mqtt_check(struct vnode *n)
return 0;
}
int mqtt_prepare(struct vnode *n)
{
int ret;
struct mqtt *m = (struct mqtt *) n->_vd;
ret = io_init(&m->io, m->format, &n->in.signals, (int) SampleFlags::HAS_ALL & ~(int) SampleFlags::HAS_OFFSET);
if (ret)
return ret;
ret = pool_init(&m->pool, 1024, SAMPLE_LENGTH(vlist_length(&n->in.signals)));
if (ret)
return ret;
ret = queue_signalled_init(&m->queue, 1024);
if (ret)
return ret;
return 0;
}
char * mqtt_print(struct vnode *n)
{
struct mqtt *m = (struct mqtt *) n->_vd;