summaryrefslogtreecommitdiff
path: root/src/management/mail.hpp
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.hpp
parent416a20b211539c8db06c26a2297de9109ef69f32 (diff)
downloadobmc-sila-smtp-bugfix/queue_empty_recipients.tar.xz
waiting smtp recipientsbugfix/queue_empty_recipients
Diffstat (limited to 'src/management/mail.hpp')
-rw-r--r--src/management/mail.hpp6
1 files changed, 6 insertions, 0 deletions
diff --git a/src/management/mail.hpp b/src/management/mail.hpp
index 39d4048..0a5c890 100644
--- a/src/management/mail.hpp
+++ b/src/management/mail.hpp
@@ -1,6 +1,8 @@
#pragma once
#include <string>
+#include <mutex>
+#include <condition_variable>
#include "file/mail/types/ifile_manipulator.hpp"
#include "checker/registrator_mails.hpp"
@@ -11,11 +13,13 @@ namespace smtp::manage
{
public:
explicit Mail( file::mail::types::IFileManipulatorPtr const& file_reader );
+ Mail(Mail const& mails);
~Mail() = default;
general::MailsSet GetMailToSend() const;
bool AddMailsToSend( general::MailsSet const& mails );
bool DeleteMailToSend( general::MailsSet const& mail_to_delete );
+ void WaitWhileEmptyMails();
private:
general::MailsSet GetMergedMails( general::MailsSet const& mails_to_add );
general::MailsSet GetItersectionMails( general::MailsSet const& mail_to_delete ) const;
@@ -24,6 +28,8 @@ namespace smtp::manage
file::mail::types::IFileManipulatorPtr mFileReader;
general::MailsSet mMails;
+ mutable std::mutex mMutex;
+ std::condition_variable mCondition;
};
}