From 4cb64d39cf5b2681e12c02d7004f66d8bc551d10 Mon Sep 17 00:00:00 2001 From: Gichan Jang Date: Thu, 13 Mar 2025 09:55:25 +0900 Subject: [PATCH] Skip connection request For TCP or MQTT, let pub node skip the connection request. Signed-off-by: Gichan Jang --- src/libnnstreamer-edge/nnstreamer-edge-internal.c | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/src/libnnstreamer-edge/nnstreamer-edge-internal.c b/src/libnnstreamer-edge/nnstreamer-edge-internal.c index 097fbaa..9f9532c 100644 --- a/src/libnnstreamer-edge/nnstreamer-edge-internal.c +++ b/src/libnnstreamer-edge/nnstreamer-edge-internal.c @@ -1750,7 +1750,7 @@ int nns_edge_connect (nns_edge_h edge_h, const char *dest_host, int dest_port) { nns_edge_handle_s *eh; - int ret; + int ret = NNS_EDGE_ERROR_NONE; eh = (nns_edge_handle_s *) edge_h; if (!eh) { @@ -1798,6 +1798,8 @@ nns_edge_connect (nns_edge_h edge_h, const char *dest_host, int dest_port) if (NNS_EDGE_CONNECT_TYPE_HYBRID == eh->connect_type || NNS_EDGE_CONNECT_TYPE_MQTT == eh->connect_type) { + if (NNS_EDGE_NODE_TYPE_PUB == eh->node_type) + goto done; ret = _nns_edge_start_mqtt_sub (eh); if (NNS_EDGE_ERROR_NONE != ret) goto done; @@ -1818,6 +1820,8 @@ nns_edge_connect (nns_edge_h edge_h, const char *dest_host, int dest_port) goto done; } } else { + if (NNS_EDGE_NODE_TYPE_PUB == eh->node_type) + goto done; ret = _nns_edge_connect_to (eh, eh->client_id, dest_host, dest_port); if (ret != NNS_EDGE_ERROR_NONE) { nns_edge_loge ("Failed to connect to %s:%d", dest_host, dest_port); -- 2.34.1