summaryrefslogtreecommitdiff
path: root/src/management/mail.cpp
diff options
context:
space:
mode:
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