From 8e052eaa5e4dfbd9c6c21f7b5aeb21312e9fb172 Mon Sep 17 00:00:00 2001
From: Steffen Vogel <post@steffenvogel.de>
Date: Sat, 20 Oct 2018 16:23:26 +0200
Subject: [PATCH] do not send offsets of network node-types

---
 lib/nodes/amqp.c      | 2 +-
 lib/nodes/mqtt.c      | 2 +-
 lib/nodes/nanomsg.c   | 2 +-
 lib/nodes/socket.c    | 2 +-
 lib/nodes/websocket.c | 2 +-
 lib/nodes/zeromq.c    | 2 +-
 6 files changed, 6 insertions(+), 6 deletions(-)

diff --git a/lib/nodes/amqp.c b/lib/nodes/amqp.c
index b1f29d220..448e721ea 100644
--- a/lib/nodes/amqp.c
+++ b/lib/nodes/amqp.c
@@ -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;
 
diff --git a/lib/nodes/mqtt.c b/lib/nodes/mqtt.c
index bbe94b07a..c49a1a95d 100644
--- a/lib/nodes/mqtt.c
+++ b/lib/nodes/mqtt.c
@@ -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;
 
diff --git a/lib/nodes/nanomsg.c b/lib/nodes/nanomsg.c
index 575c584b0..f3acb72d6 100644
--- a/lib/nodes/nanomsg.c
+++ b/lib/nodes/nanomsg.c
@@ -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;
 
diff --git a/lib/nodes/socket.c b/lib/nodes/socket.c
index e2766d050..cde1225ef 100644
--- a/lib/nodes/socket.c
+++ b/lib/nodes/socket.c
@@ -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;
 
diff --git a/lib/nodes/websocket.c b/lib/nodes/websocket.c
index ac88fe1f1..788218c6d 100644
--- a/lib/nodes/websocket.c
+++ b/lib/nodes/websocket.c
@@ -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;
 
diff --git a/lib/nodes/zeromq.c b/lib/nodes/zeromq.c
index bc27efdd8..b9078b276 100644
--- a/lib/nodes/zeromq.c
+++ b/lib/nodes/zeromq.c
@@ -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;