diff options
author | claiff <claiff@mail.ru> | 2022-10-18 16:52:46 +0300 |
---|---|---|
committer | claiff <claiff@mail.ru> | 2022-10-18 16:52:46 +0300 |
commit | 1ca701a3056725f7560d10929baf3660d52bc4be (patch) | |
tree | a1fb1fe43cb4066e7cc86e068898aee40eebb2f7 /src/management/mail.hpp | |
parent | 416a20b211539c8db06c26a2297de9109ef69f32 (diff) | |
download | obmc-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.hpp | 6 |
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; }; } |