From dfabab2315d61669b67f418eaf410980605869d7 Mon Sep 17 00:00:00 2001 From: Syping Date: Tue, 7 Apr 2026 22:08:06 +0200 Subject: [PATCH] {message,submit}_queue: call callback in add function --- src/core/message_queue.cpp | 4 ++++ src/core/submit_queue.cpp | 4 ++++ 2 files changed, 8 insertions(+) diff --git a/src/core/message_queue.cpp b/src/core/message_queue.cpp index 502d89a..e9f38cb 100644 --- a/src/core/message_queue.cpp +++ b/src/core/message_queue.cpp @@ -27,12 +27,16 @@ void message_queue::add(const message &message) { const std::lock_guard guard(m_mutex); m_queue.push(message); + for (const message_queue_size_callback &callback : m_callbacks) + callback(m_queue.size()); } void message_queue::add(message &&message) { const std::lock_guard guard(m_mutex); m_queue.push(message); + for (const message_queue_size_callback &callback : m_callbacks) + callback(m_queue.size()); } void message_queue::process_direct_message_event(dpp::cluster *bot, bot::settings::settings *settings, const dpp::message_context_menu_t &event) diff --git a/src/core/submit_queue.cpp b/src/core/submit_queue.cpp index 74962e9..3fe5057 100644 --- a/src/core/submit_queue.cpp +++ b/src/core/submit_queue.cpp @@ -26,12 +26,16 @@ void submit_queue::add(const translated_message &message) { const std::lock_guard guard(m_mutex); m_queue.push(message); + for (const submit_queue_size_callback &callback : m_callbacks) + callback(m_queue.size()); } void submit_queue::add(translated_message &&message) { const std::lock_guard guard(m_mutex); m_queue.push(message); + for (const submit_queue_size_callback &callback : m_callbacks) + callback(m_queue.size()); } void submit_queue::run(dpp::cluster *bot)