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

do not send offsets of network node-types

Browse source
This commit is contained in:
Steffen Vogel 2018-10-20 16:23:26 +02:00
parent 64fa076d11
commit 8e052eaa5e
6 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
lib/nodes/amqp.c
View file

@ -239,7 +239,7 @@ int amqp_start(struct node *n)
amqp_rpc_reply_t rep;
amqp_queue_declare_ok_t *r;
ret = io_init(&a->io, a->format, &n->signals, SAMPLE_HAS_ALL);
ret = io_init(&a->io, a->format, &n->signals, SAMPLE_HAS_ALL & ~SAMPLE_HAS_OFFSET);
if (ret)
return ret;

2
lib/nodes/mqtt.c
View file

@ -299,7 +299,7 @@ int mqtt_start(struct node *n)
mosquitto_message_callback_set(m->client, mqtt_message_cb);
mosquitto_subscribe_callback_set(m->client, mqtt_subscribe_cb);
ret = io_init(&m->io, m->format, &n->signals, SAMPLE_HAS_ALL);
ret = io_init(&m->io, m->format, &n->signals, SAMPLE_HAS_ALL & ~SAMPLE_HAS_OFFSET);
if (ret)
return ret;

2
lib/nodes/nanomsg.c
View file

@ -153,7 +153,7 @@ int nanomsg_start(struct node *n)
int ret;
struct nanomsg *m = (struct nanomsg *) n->_vd;
ret = io_init(&m->io, m->format, &n->signals, SAMPLE_HAS_ALL);
ret = io_init(&m->io, m->format, &n->signals, SAMPLE_HAS_ALL & ~SAMPLE_HAS_OFFSET);
if (ret)
return ret;

2
lib/nodes/socket.c
View file

@ -218,7 +218,7 @@ int socket_start(struct node *n)
int ret;
/* Initialize IO */
ret = io_init(&s->io, s->format, &n->signals, SAMPLE_HAS_ALL);
ret = io_init(&s->io, s->format, &n->signals, SAMPLE_HAS_ALL & ~SAMPLE_HAS_OFFSET);
if (ret)
return ret;

2
lib/nodes/websocket.c
View file

@ -87,7 +87,7 @@ static int websocket_connection_init(struct websocket_connection *c)
if (ret)
return ret;
ret = io_init(&c->io, c->format, &c->node->signals, SAMPLE_HAS_ALL);
ret = io_init(&c->io, c->format, &c->node->signals, SAMPLE_HAS_ALL & ~SAMPLE_HAS_OFFSET);
if (ret)
return ret;

2
lib/nodes/zeromq.c
View file

@ -257,7 +257,7 @@ int zeromq_start(struct node *n)
int ret;
struct zeromq *z = (struct zeromq *) n->_vd;
ret = io_init(&z->io, z->format, &n->signals, SAMPLE_HAS_ALL);
ret = io_init(&z->io, z->format, &n->signals, SAMPLE_HAS_ALL & ~SAMPLE_HAS_OFFSET);
if (ret)
return ret;