From 3e4a70170b83ffb98baf41cb8a499f622532f3f5 Mon Sep 17 00:00:00 2001 From: Hyoung Joo Ahn Date: Wed, 12 May 2021 20:40:32 +0900 Subject: [PATCH] [MQTTsrc] remove cb_mqtt_on_delivery_complete () this callbeck is useless for the subscriber Signed-off-by: Hyoung Joo Ahn --- gst/mqtt/mqttsrc.c | 14 +------------- 1 file changed, 1 insertion(+), 13 deletions(-) diff --git a/gst/mqtt/mqttsrc.c b/gst/mqtt/mqttsrc.c index b7ec2d4..d8390ca 100644 --- a/gst/mqtt/mqttsrc.c +++ b/gst/mqtt/mqttsrc.c @@ -120,7 +120,6 @@ static void gst_mqtt_src_set_opt_keep_alive_interval (GstMqttSrc * self, const gint num); static void cb_mqtt_on_connection_lost (void *context, char *cause); -static void cb_mqtt_on_delivery_complete (void *context, MQTTAsync_token token); static int cb_mqtt_on_message_arrived (void *context, char *topic_name, int topic_len, MQTTAsync_message * message); static void cb_mqtt_on_connect (void *context, @@ -495,8 +494,7 @@ gst_mqtt_src_start (GstBaseSrc * basesrc) return FALSE; MQTTAsync_setCallbacks (self->mqtt_client_handle, self, - cb_mqtt_on_connection_lost, cb_mqtt_on_message_arrived, - cb_mqtt_on_delivery_complete); + cb_mqtt_on_connection_lost, cb_mqtt_on_message_arrived, NULL); ret = MQTTAsync_connect (self->mqtt_client_handle, &self->mqtt_conn_opts); if (ret != MQTTASYNC_SUCCESS) @@ -979,16 +977,6 @@ cb_mqtt_on_connection_lost (void *context, char *cause) } /** - * @brief A callback to handle the post-processing of the delivered message - * @todo Fill the function body - */ -static void -cb_mqtt_on_delivery_complete (void *context, MQTTAsync_token token) -{ - -} - -/** * @brief A callback to handle the arrived message */ static int -- 2.7.4