From 7573c628f22bd251129ec2b9b2b656dff752267d Mon Sep 17 00:00:00 2001 From: Jaeyun Jung Date: Mon, 21 Aug 2023 17:09:41 +0900 Subject: [PATCH] [MQTT] update handle name Code clean, update param name - broker handle. Signed-off-by: Jaeyun Jung --- src/libnnstreamer-edge/nnstreamer-edge-mqtt-mosquitto.c | 4 ++-- src/libnnstreamer-edge/nnstreamer-edge-mqtt-paho.c | 4 ++-- src/libnnstreamer-edge/nnstreamer-edge-mqtt.h | 2 +- 3 files changed, 5 insertions(+), 5 deletions(-) diff --git a/src/libnnstreamer-edge/nnstreamer-edge-mqtt-mosquitto.c b/src/libnnstreamer-edge/nnstreamer-edge-mqtt-mosquitto.c index b859a1c..99c850d 100644 --- a/src/libnnstreamer-edge/nnstreamer-edge-mqtt-mosquitto.c +++ b/src/libnnstreamer-edge/nnstreamer-edge-mqtt-mosquitto.c @@ -258,7 +258,7 @@ nns_edge_mqtt_close (nns_edge_broker_h broker_h) * @brief Internal util function to send edge-data via MQTT connection. */ int -nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h) +nns_edge_mqtt_publish_data (nns_edge_broker_h broker_h, nns_edge_data_h data_h) { int ret; void *data = NULL; @@ -270,7 +270,7 @@ nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h) return ret; } - ret = nns_edge_mqtt_publish (handle, data, size); + ret = nns_edge_mqtt_publish (broker_h, data, size); if (NNS_EDGE_ERROR_NONE != ret) nns_edge_loge ("Failed to send data to destination."); diff --git a/src/libnnstreamer-edge/nnstreamer-edge-mqtt-paho.c b/src/libnnstreamer-edge/nnstreamer-edge-mqtt-paho.c index 658397d..651b097 100644 --- a/src/libnnstreamer-edge/nnstreamer-edge-mqtt-paho.c +++ b/src/libnnstreamer-edge/nnstreamer-edge-mqtt-paho.c @@ -268,7 +268,7 @@ nns_edge_mqtt_close (nns_edge_broker_h broker_h) * @brief Internal util function to send edge-data via MQTT connection. */ int -nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h) +nns_edge_mqtt_publish_data (nns_edge_broker_h broker_h, nns_edge_data_h data_h) { int ret; void *data = NULL; @@ -280,7 +280,7 @@ nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h) return ret; } - ret = nns_edge_mqtt_publish (handle, data, size); + ret = nns_edge_mqtt_publish (broker_h, data, size); if (NNS_EDGE_ERROR_NONE != ret) nns_edge_loge ("Failed to send data to destination."); diff --git a/src/libnnstreamer-edge/nnstreamer-edge-mqtt.h b/src/libnnstreamer-edge/nnstreamer-edge-mqtt.h index 7ef2532..d1de9d6 100644 --- a/src/libnnstreamer-edge/nnstreamer-edge-mqtt.h +++ b/src/libnnstreamer-edge/nnstreamer-edge-mqtt.h @@ -60,7 +60,7 @@ int nns_edge_mqtt_get_message (nns_edge_broker_h broker_h, void **msg, nns_size_ /** * @brief Internal util function to send edge-data via MQTT connection. */ -int nns_edge_mqtt_publish_data (nns_edge_broker_h handle, nns_edge_data_h data_h); +int nns_edge_mqtt_publish_data (nns_edge_broker_h broker_h, nns_edge_data_h data_h); /** * @brief Set event callback for new message. -- 2.34.1