Syping/dtranslatebot
1
0
Fork 0
mirror of https://github.com/Syping/dtranslatebot.git synced 2026-04-21 14:40:41 +02:00
Code Issues Projects Releases Packages Wiki Activity

{message,submit}_queue: call callback in add function

Browse source
This commit is contained in:
Syping 2026-04-07 22:08:06 +02:00
parent 8acf512c65
commit dfabab2315
2 changed files with 8 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

4
src/core/message_queue.cpp
View file

@ -27,12 +27,16 @@ void message_queue::add(const message &message)
{ {
const std::lock_guard<std::mutex> guard(m_mutex); const std::lock_guard<std::mutex> guard(m_mutex);
m_queue.push(message); m_queue.push(message);
for (const message_queue_size_callback &callback : m_callbacks)
callback(m_queue.size());
} }
void message_queue::add(message &&message) void message_queue::add(message &&message)
{ {
const std::lock_guard<std::mutex> guard(m_mutex); const std::lock_guard<std::mutex> guard(m_mutex);
m_queue.push(message); 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) void message_queue::process_direct_message_event(dpp::cluster *bot, bot::settings::settings *settings, const dpp::message_context_menu_t &event)

4
src/core/submit_queue.cpp
View file

@ -26,12 +26,16 @@ void submit_queue::add(const translated_message &message)
{ {
const std::lock_guard<std::mutex> guard(m_mutex); const std::lock_guard<std::mutex> guard(m_mutex);
m_queue.push(message); m_queue.push(message);
for (const submit_queue_size_callback &callback : m_callbacks)
callback(m_queue.size());
} }
void submit_queue::add(translated_message &&message) void submit_queue::add(translated_message &&message)
{ {
const std::lock_guard<std::mutex> guard(m_mutex); const std::lock_guard<std::mutex> guard(m_mutex);
m_queue.push(message); m_queue.push(message);
for (const submit_queue_size_callback &callback : m_callbacks)
callback(m_queue.size());
} }
void submit_queue::run(dpp::cluster *bot) void submit_queue::run(dpp::cluster *bot)