SWC::Core::StateSynchronization Class Reference

#include <swcdb/core/StateSynchronization.h>

Inheritance diagram for SWC::Core::StateSynchronization:

Collaboration diagram for SWC::Core::StateSynchronization:

Public Member Functions
SWC_CAN_INLINE	StateSynchronization () noexcept
	~StateSynchronization () noexcept
SWC_CAN_INLINE void	wait ()
SWC_CAN_INLINE void	acknowledge () noexcept
SWC_CAN_INLINE void	reset () noexcept

Private Attributes
std::mutex	m_mutex
std::condition_variable	m_cv
bool	m_ack

Detailed Description

Definition at line 16 of file StateSynchronization.h.

Constructor & Destructor Documentation

StateSynchronization()

SWC_CAN_INLINE SWC::Core::StateSynchronization::StateSynchronization ( )

inlinenoexcept

Definition at line 20 of file StateSynchronization.h.

~StateSynchronization()

SWC::Core::StateSynchronization::~StateSynchronization ( )

inlinenoexcept

Definition at line 22 of file StateSynchronization.h.

Member Function Documentation

acknowledge()

SWC_CAN_INLINE void SWC::Core::StateSynchronization::acknowledge ( )

inlinenoexcept

Definition at line 31 of file StateSynchronization.h.

References m_ack, m_cv, and m_mutex.

Referenced by SWC::DB::RgrData::SyncUpdater::callback(), SWC::DB::RgrData::SyncSelector::callback(), SWC::Comm::Protocol::Bkr::Req::ColumnCompact_Sync::callback(), SWC::Comm::Protocol::Mngr::Req::ColumnCompact_Sync::callback(), SWC::Comm::Protocol::Bkr::Req::ColumnMng_Sync::callback(), SWC::Comm::Protocol::Mngr::Req::ColumnMng_Sync::callback(), SWC::Comm::Protocol::Bkr::Req::ColumnGet_Sync::callback(), SWC::Comm::Protocol::Bkr::Req::ColumnList_Sync::callback(), SWC::Comm::Protocol::Mngr::Req::ColumnGet_Sync::callback(), SWC::Comm::Protocol::Mngr::Req::ColumnList_Sync::callback(), SWC::client::Schemas::ColumnGetData::callback(), SWC::Ranger::Callback::ColumnsUnloadAll::complete(), SWC::Comm::Protocol::FsBroker::Req::AppendSync::handle(), SWC::Comm::Protocol::FsBroker::Req::CloseSync::handle(), SWC::Comm::Protocol::FsBroker::Req::CombiPreadSync::handle(), SWC::Comm::Protocol::FsBroker::Req::CreateSync::handle(), SWC::Comm::Protocol::FsBroker::Req::ExistsSync::handle(), SWC::Comm::Protocol::FsBroker::Req::FlushSync::handle(), SWC::Comm::Protocol::FsBroker::Req::LengthSync::handle(), SWC::Comm::Protocol::FsBroker::Req::MkdirsSync::handle(), SWC::Comm::Protocol::FsBroker::Req::OpenSync::handle(), SWC::Comm::Protocol::FsBroker::Req::PreadSync::handle(), SWC::Comm::Protocol::FsBroker::Req::ReadAllSync::handle(), SWC::Comm::Protocol::FsBroker::Req::ReaddirSync::handle(), SWC::Comm::Protocol::FsBroker::Req::ReadSync::handle(), SWC::Comm::Protocol::FsBroker::Req::RemoveSync::handle(), SWC::Comm::Protocol::FsBroker::Req::RenameSync::handle(), SWC::Comm::Protocol::FsBroker::Req::RmdirSync::handle(), SWC::Comm::Protocol::FsBroker::Req::SeekSync::handle(), SWC::Comm::Protocol::FsBroker::Req::SyncSync::handle(), SWC::Comm::Protocol::FsBroker::Req::WriteSync::handle(), SWC::Ranger::RangeSplit::mngr_create_range(), SWC::Ranger::mngr_remove_range(), and SWC::Utils::shell::Rgr::report().

Here is the caller graph for this function:

reset()

SWC_CAN_INLINE void SWC::Core::StateSynchronization::reset ( )

inlinenoexcept

Definition at line 38 of file StateSynchronization.h.

References m_ack.

Referenced by SWC::Utils::shell::Mngr::cluster_status(), SWC::Utils::shell::Mngr::managers_status(), and SWC::Ranger::Callback::ColumnsUnloadAll::wait().

Here is the caller graph for this function:

wait()

SWC_CAN_INLINE void SWC::Core::StateSynchronization::wait ( )

inline

Definition at line 25 of file StateSynchronization.h.

References m_ack, m_cv, and m_mutex.

Referenced by SWC::Utils::shell::Mngr::cluster_status(), SWC::Utils::shell::Mngr::column_status(), SWC::Utils::shell::Mngr::managers_status(), SWC::Ranger::RangeSplit::mngr_create_range(), SWC::Ranger::mngr_remove_range(), SWC::Utils::shell::Mngr::rangers_status(), SWC::Utils::shell::Rgr::report(), SWC::Utils::shell::Rgr::report_resources(), SWC::Ranger::RangeSplit::run(), SWC::Ranger::Callback::ColumnsUnloadAll::wait(), and SWC::client::Schemas::ColumnGetData::wait().

Here is the caller graph for this function:

Member Data Documentation

m_ack

bool SWC::Core::StateSynchronization::m_ack

private

Definition at line 45 of file StateSynchronization.h.

Referenced by acknowledge(), reset(), and wait().

m_cv

std::condition_variable SWC::Core::StateSynchronization::m_cv

private

Definition at line 44 of file StateSynchronization.h.

Referenced by acknowledge(), and wait().

m_mutex

std::mutex SWC::Core::StateSynchronization::m_mutex

private

Definition at line 43 of file StateSynchronization.h.

Referenced by acknowledge(), and wait().

---

The documentation for this class was generated from the following file:

• include/swcdb/core/StateSynchronization.h