summaryrefslogtreecommitdiff
path: root/src/management/mail.cpp
diff options
context:
space:
mode:
authorclaiff <claiff@mail.ru>2022-10-18 16:52:46 +0300
committerclaiff <claiff@mail.ru>2022-10-18 16:52:46 +0300
commit1ca701a3056725f7560d10929baf3660d52bc4be (patch)
treea1fb1fe43cb4066e7cc86e068898aee40eebb2f7 /src/management/mail.cpp
parent416a20b211539c8db06c26a2297de9109ef69f32 (diff)
downloadobmc-sila-smtp-bugfix/queue_empty_recipients.tar.xz
waiting smtp recipientsbugfix/queue_empty_recipients
Diffstat (limited to 'src/management/mail.cpp')
-rw-r--r--src/management/mail.cpp22
1 files changed, 18 insertions, 4 deletions
diff --git a/src/management/mail.cpp b/src/management/mail.cpp
index eefb666..e3ef9f6 100644
--- a/src/management/mail.cpp
+++ b/src/management/mail.cpp
@@ -11,8 +11,14 @@ namespace smtp::manage
Mail::Mail( file::mail::types::IFileManipulatorPtr const& file_reader )
: mFileReader( file_reader )
, mMails( mFileReader->Read() )
- {
- }
+ {
+ }
+
+ Mail::Mail(const Mail &mails)
+ {
+ mMails = mails.mMails;
+ mFileReader = mails.mFileReader;
+ }
//
@@ -28,7 +34,9 @@ namespace smtp::manage
{
auto merged_mails = GetMergedMails( mails_to_add );
- return RefreshMails( merged_mails );
+ auto result = RefreshMails( merged_mails );
+ mCondition.notify_one();
+ return result;
}
bool Mail::DeleteMailToSend( general::MailsSet const& mail_to_delete )
@@ -38,7 +46,13 @@ namespace smtp::manage
auto result_set_after_delete = GetMailsAfterDelete( mails_to_delete );
return RefreshMails( result_set_after_delete );
- }
+ }
+
+ void Mail::WaitWhileEmptyMails()
+ {
+ std::unique_lock<std::mutex> lock{mMutex};
+ mCondition.wait(lock, [this](){return !mMails.empty();});
+ }
//
//Private methods