Relintai/pandemonium_engine
1
0
Fork 0
mirror of https://github.com/Relintai/pandemonium_engine.git synced 2024-12-31 16:17:12 +01:00
Code Issues Packages Projects Releases Wiki Activity

Also use the queue in SMTPClient when not threading.

Browse Source
This commit is contained in:
Relintai 2024-01-11 00:39:52 +01:00
parent 4a35fb9b44
commit 40e20146f6
2 changed files with 30 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
modules/smtp/smtp_client.cpp
View File

@ -163,6 +163,11 @@ void SMTPClient::send_email(const Ref<EMail> &p_email) {
_worker_semaphore.post();
} else {
if (_current_session_email.is_valid()) {
_mail_queue.push_back(p_email);
return;
}
_send_email(p_email);
}
}
@ -200,7 +205,7 @@ void SMTPClient::_send_email(const Ref<EMail> &p_email) {
emit_signal("result", result);
if (!should_use_threading()) {
set_process(false);
_no_thread_next_email();
}
}
@ -224,7 +229,7 @@ void SMTPClient::_send_email(const Ref<EMail> &p_email) {
emit_signal("result", result);
if (!should_use_threading()) {
set_process(false);
_no_thread_next_email();
}
return;
@ -342,7 +347,7 @@ void SMTPClient::close_connection() {
_current_tls_established = false;
if (!should_use_threading()) {
set_process(false);
_no_thread_next_email();
}
}
@ -548,6 +553,27 @@ void SMTPClient::_process_email() {
}
}
void SMTPClient::_no_thread_next_email() {
if (should_use_threading()) {
return;
}
Ref<EMail> mail;
int size = _mail_queue.size();
if (size > 0) {
mail = _mail_queue[0];
_mail_queue.remove(0);
} else {
set_process(false);
return;
}
if (mail.is_valid()) {
_send_email(mail);
}
}
void SMTPClient::_worker_thread_func(void *user_data) {
SMTPClient *self = (SMTPClient *)user_data;

1
modules/smtp/smtp_client.h
View File

@ -142,6 +142,7 @@ protected:
String encode_password();
void _process_email();
void _no_thread_next_email();
static void _worker_thread_func(void *user_data);