From 21a5491d537b80190634262ccb7c8bb3159564a1 Mon Sep 17 00:00:00 2001 From: Euripedes Rocha Date: Mon, 27 Mar 2023 09:11:48 +0200 Subject: [PATCH] Removes unused outbox functions. --- lib/include/mqtt_outbox.h | 2 -- lib/mqtt_outbox.c | 25 ------------------------- 2 files changed, 27 deletions(-) diff --git a/lib/include/mqtt_outbox.h b/lib/include/mqtt_outbox.h index fbeb5a5..e180fca 100644 --- a/lib/include/mqtt_outbox.h +++ b/lib/include/mqtt_outbox.h @@ -42,8 +42,6 @@ outbox_item_handle_t outbox_dequeue(outbox_handle_t outbox, pending_state_t pend outbox_item_handle_t outbox_get(outbox_handle_t outbox, int msg_id); uint8_t *outbox_item_get_data(outbox_item_handle_t item, size_t *len, uint16_t *msg_id, int *msg_type, int *qos); esp_err_t outbox_delete(outbox_handle_t outbox, int msg_id, int msg_type); -esp_err_t outbox_delete_msgid(outbox_handle_t outbox, int msg_id); -esp_err_t outbox_delete_msgtype(outbox_handle_t outbox, int msg_type); esp_err_t outbox_delete_item(outbox_handle_t outbox, outbox_item_handle_t item); int outbox_delete_expired(outbox_handle_t outbox, outbox_tick_t current_tick, outbox_tick_t timeout); /** diff --git a/lib/mqtt_outbox.c b/lib/mqtt_outbox.c index f60a471..1915e59 100644 --- a/lib/mqtt_outbox.c +++ b/lib/mqtt_outbox.c @@ -121,19 +121,7 @@ esp_err_t outbox_delete(outbox_handle_t outbox, int msg_id, int msg_type) } return ESP_FAIL; } -esp_err_t outbox_delete_msgid(outbox_handle_t outbox, int msg_id) -{ - outbox_item_handle_t item, tmp; - STAILQ_FOREACH_SAFE(item, outbox, next, tmp) { - if (item->msg_id == msg_id) { - STAILQ_REMOVE(outbox, item, outbox_item, next); - free(item->buffer); - free(item); - } - } - return ESP_OK; -} esp_err_t outbox_set_pending(outbox_handle_t outbox, int msg_id, pending_state_t pending) { outbox_item_handle_t item = outbox_get(outbox, msg_id); @@ -162,19 +150,6 @@ esp_err_t outbox_set_tick(outbox_handle_t outbox, int msg_id, outbox_tick_t tick return ESP_FAIL; } -esp_err_t outbox_delete_msgtype(outbox_handle_t outbox, int msg_type) -{ - outbox_item_handle_t item, tmp; - STAILQ_FOREACH_SAFE(item, outbox, next, tmp) { - if (item->msg_type == msg_type) { - STAILQ_REMOVE(outbox, item, outbox_item, next); - free(item->buffer); - free(item); - } - - } - return ESP_OK; -} int outbox_delete_single_expired(outbox_handle_t outbox, outbox_tick_t current_tick, outbox_tick_t timeout) { int msg_id = -1;