SWC-DB  v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
Public Member Functions | Static Public Member Functions | Public Attributes | Private Attributes | Static Private Attributes | List of all members
SWC::Env::Mngr Class Referencefinal

#include <swcdb/manager/MngrEnv.h>

+ Collaboration diagram for SWC::Env::Mngr:

Public Member Functions

 Mngr (const Comm::EndPoints &endpoints)
 
 ~Mngr () noexcept
 

Static Public Member Functions

static void init (const Comm::EndPoints &endpoints)
 
static SWC_CAN_INLINE Comm::IoContextPtr io () noexcept
 
template<typename T_Handler >
static SWC_CAN_INLINE void post (T_Handler &&handler)
 
static SWC_CAN_INLINE Manager::Metric::Reporting::Ptr & metrics_track () noexcept
 
static SWC_CAN_INLINE System::Resources & res () noexcept
 
static SWC_CAN_INLINE Manager::Schemas * schemas () noexcept
 
static SWC_CAN_INLINE Manager::Columns * columns () noexcept
 
static SWC_CAN_INLINE Manager::MngrRole * role () noexcept
 
static SWC_CAN_INLINE Manager::Rangers * rangers () noexcept
 
static SWC_CAN_INLINE Manager::MngdColumns * mngd_columns () noexcept
 
static SWC_CAN_INLINE bool is_shuttingdown () noexcept
 
static void reset () noexcept
 
static void stop ()
 

Public Attributes

Comm::IoContextPtr app_io
 
SWC::Config::Property::Value_int32_g cfg_ram_percent_allowed
 
SWC::Config::Property::Value_int32_g cfg_ram_percent_reserved
 
SWC::Config::Property::Value_int32_g cfg_ram_release_rate
 

Private Attributes

Manager::Metric::Reporting::Ptr _reporting
 
System::Resources _resources
 
Manager::Schemas m_schemas
 
Manager::Columns m_columns
 
Manager::MngrRole m_role
 
Manager::Rangers m_rangers
 
Manager::MngdColumns m_mngd_columns
 
Core::AtomicBool m_shutting_down
 

Static Private Attributes

static std::shared_ptr< Mngr > m_env = nullptr
 

Detailed Description

Definition at line 24 of file MngrEnv.h.

Constructor & Destructor Documentation

◆ Mngr()

SWC::Env::Mngr::Mngr ( const Comm::EndPoints &  endpoints)
inline

Definition at line 90 of file MngrEnv.h.

Referenced by init().

+ Here is the caller graph for this function:

◆ ~Mngr()

SWC::Env::Mngr::~Mngr ( )
inlinenoexcept

Definition at line 122 of file MngrEnv.h.

Member Function Documentation

◆ columns()

static SWC_CAN_INLINE Manager::Columns* SWC::Env::Mngr::columns ( )
inlinestaticnoexcept

Definition at line 59 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::Rangers::assign_ranges_run(), SWC::Manager::MngdColumns::change_active(), SWC::Manager::MngdColumns::columns_ready(), SWC::Manager::MngdColumns::get_column(), SWC::Comm::Protocol::Rgr::Req::ColumnsUnload::handle(), SWC::Manager::Rangers::health_check_columns(), SWC::Manager::Column::init(), SWC::Manager::Rangers::next_rgr(), SWC::Manager::MngdColumns::print(), SWC::Manager::MngdColumns::remove(), SWC::Manager::Rangers::rgr_report(), SWC::Manager::Rangers::rgr_set(), SWC::Manager::Rangers::rgr_shutdown(), SWC::Manager::Range::set_deleted(), SWC::Manager::MngdColumns::set_expect(), SWC::Manager::Range::set_state_none(), SWC::Manager::Range::set_state_queued(), SWC::Manager::MngdColumns::update_status(), and SWC::Manager::Rangers::update_status().

+ Here is the caller graph for this function:

◆ init()

static void SWC::Env::Mngr::init ( const Comm::EndPoints &  endpoints)
inlinestatic

Definition at line 27 of file MngrEnv.h.

References m_env, Mngr(), and SWC_ASSERT.

Referenced by SWC::Manager::AppContext::init().

+ Here is the call graph for this function:
+ Here is the caller graph for this function:

◆ io()

static SWC_CAN_INLINE Comm::IoContextPtr SWC::Env::Mngr::io ( )
inlinestaticnoexcept

Definition at line 33 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::ColumnHealthCheck::finishing(), SWC::Manager::AppContext::init(), SWC::Manager::MngdColumns::remove(), SWC::Manager::AppContext::shutting_down(), and SWC::Manager::AppContext::stop().

+ Here is the caller graph for this function:

◆ is_shuttingdown()

static SWC_CAN_INLINE bool SWC::Env::Mngr::is_shuttingdown ( )
inlinestaticnoexcept

Definition at line 79 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::Range::get_last_rgr(), and SWC::Manager::Rangers::next_rgr().

+ Here is the caller graph for this function:

◆ metrics_track()

static SWC_CAN_INLINE Manager::Metric::Reporting::Ptr& SWC::Env::Mngr::metrics_track ( )
inlinestaticnoexcept

Definition at line 44 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::AppContext::init().

+ Here is the caller graph for this function:

◆ mngd_columns()

static SWC_CAN_INLINE Manager::MngdColumns* SWC::Env::Mngr::mngd_columns ( )
inlinestaticnoexcept

Definition at line 74 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::MngrRole::apply_role_changes(), SWC::Manager::Rangers::assign_ranges(), SWC::Manager::Rangers::changes(), SWC::Comm::Protocol::Mngr::Handler::column_compact(), SWC::Comm::Protocol::Mngr::Handler::column_get(), SWC::Comm::Protocol::Mngr::Handler::column_list(), SWC::Comm::Protocol::Mngr::Handler::column_mng(), SWC::Comm::Protocol::Mngr::Handler::MngrColumnGet::handle(), SWC::Comm::Protocol::Mngr::Handler::MngrColumnGet::handle_no_conn(), SWC::Manager::Rangers::health_check_columns(), SWC::Comm::Protocol::Mngr::Handler::ColumnUpdate::operator()(), SWC::Comm::Protocol::Mngr::Handler::RangeCreate::operator()(), SWC::Comm::Protocol::Mngr::Handler::RangeRemove::operator()(), SWC::Comm::Protocol::Mngr::Handler::Report::operator()(), SWC::Comm::Protocol::Mngr::Handler::range_unloaded(), SWC::Comm::Protocol::Rgr::Req::ColumnDelete::remove(), SWC::Comm::Protocol::Mngr::Handler::rgr_get(), SWC::Manager::Rangers::schedule_run(), SWC::Manager::MngrRole::stop(), SWC::Manager::MngrRole::update_manager_addr(), SWC::Manager::Rangers::update_status(), SWC::Comm::Protocol::Rgr::Req::ColumnUpdate::updated(), and SWC::Comm::Protocol::Mngr::Handler::MngrColumnGet::valid().

+ Here is the caller graph for this function:

◆ post()

template<typename T_Handler >
static SWC_CAN_INLINE void SWC::Env::Mngr::post ( T_Handler &&  handler)
inlinestatic

Definition at line 39 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::MngdColumns::action(), SWC::Manager::Rangers::assign_ranges(), SWC::Manager::AppContext::handle(), SWC::Manager::Rangers::health_check_columns(), and SWC::Manager::MngdColumns::initialize().

+ Here is the caller graph for this function:

◆ rangers()

static SWC_CAN_INLINE Manager::Rangers* SWC::Env::Mngr::rangers ( )
inlinestaticnoexcept

Definition at line 69 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::MngrRole::apply_role_changes(), SWC::Manager::MngdColumns::change_active(), SWC::Comm::Protocol::Mngr::Handler::column_compact(), SWC::Manager::ColumnHealthCheck::ColumnMerger::completion(), SWC::Manager::ColumnHealthCheck::finishing(), SWC::Comm::Protocol::Rgr::Req::ColumnsUnload::handle(), SWC::Comm::Protocol::Rgr::Req::RangeUnoadForMerge::handle(), SWC::Manager::ColumnHealthCheck::ColumnMerger::RangesMerger::handle(), SWC::Manager::ColumnHealthCheck::RangerCheck::handle(), SWC::Comm::Protocol::Rgr::Req::RangeLoad::loaded(), SWC::Comm::Protocol::Mngr::Handler::Report::operator()(), SWC::Comm::Protocol::Mngr::Handler::RgrMngId::operator()(), SWC::Comm::Protocol::Mngr::Handler::RgrUpdate::operator()(), SWC::Comm::Protocol::Mngr::Handler::range_unloaded(), SWC::Manager::MngdColumns::remove(), SWC::Manager::MngdColumns::require_sync(), SWC::Comm::Protocol::Mngr::Handler::rgr_get(), SWC::Manager::ColumnHealthCheck::ColumnMerger::run(), SWC::Manager::ColumnHealthCheck::ColumnMerger::RangesMerger::run(), SWC::Manager::ColumnHealthCheck::run(), SWC::Manager::ColumnHealthCheck::ColumnMerger::run_master(), SWC::Manager::MngrRole::stop(), SWC::Comm::Protocol::Rgr::Req::RangeUnload::unloaded(), SWC::Manager::MngdColumns::update_status(), SWC::Comm::Protocol::Rgr::Req::ColumnUpdate::updated(), SWC::Comm::Protocol::Rgr::Req::RangeIsLoaded::valid(), SWC::Comm::Protocol::Rgr::Req::RangeLoad::valid(), SWC::Comm::Protocol::Rgr::Req::RangeUnload::valid(), and SWC::Comm::Protocol::Rgr::Req::RangeUnoadForMerge::valid().

+ Here is the caller graph for this function:

◆ res()

static SWC_CAN_INLINE System::Resources& SWC::Env::Mngr::res ( )
inlinestaticnoexcept

Definition at line 49 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::MngdColumns::initialize().

+ Here is the caller graph for this function:

◆ reset()

static void SWC::Env::Mngr::reset ( )
inlinestaticnoexcept

Definition at line 83 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::AppContext::stop().

+ Here is the caller graph for this function:

◆ role()

static SWC_CAN_INLINE Manager::MngrRole* SWC::Env::Mngr::role ( )
inlinestaticnoexcept

Definition at line 64 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::Rangers::_changes(), SWC::Manager::MngdColumns::change_active(), SWC::Comm::Protocol::Mngr::Handler::column_get(), SWC::Manager::MngdColumns::columns_load(), SWC::Manager::AppContext::handle(), SWC::Manager::AppContext::handle_disconnect(), SWC::client::Mngr::ContextManager::handle_disconnect(), SWC::Manager::MngdColumns::is_schemas_mngr(), SWC::Comm::Protocol::Mngr::Handler::mngr_active(), SWC::Comm::Protocol::Mngr::Handler::MngrState::operator()(), SWC::Comm::Protocol::Mngr::Handler::Report::operator()(), SWC::Comm::Protocol::Mngr::Handler::RgrMngId::operator()(), SWC::Manager::MngdColumns::remove(), SWC::Manager::Rangers::rgr_report(), SWC::Manager::Rangers::schedule_run(), SWC::Manager::MngdColumns::set_expect(), SWC::Manager::MngdColumns::update(), SWC::Manager::MngdColumns::update_status(), and SWC::Manager::Rangers::update_status().

+ Here is the caller graph for this function:

◆ schemas()

static SWC_CAN_INLINE Manager::Schemas* SWC::Env::Mngr::schemas ( )
inlinestaticnoexcept

Definition at line 54 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::Rangers::assign_ranges_run(), SWC::Manager::MngdColumns::change_active(), SWC::Comm::Protocol::Mngr::Handler::column_list(), SWC::Manager::MngdColumns::columns_load(), SWC::Manager::MngdColumns::create(), SWC::Manager::MngdColumns::create_schemas_store(), SWC::Manager::MngdColumns::get_next_cid(), SWC::Comm::Protocol::Mngr::Handler::get_schema(), SWC::Comm::Protocol::Mngr::Handler::MngrColumnGet::handle(), SWC::Manager::MngdColumns::initialize(), SWC::Manager::MngdColumns::remove(), SWC::Manager::MngdColumns::reset(), SWC::Manager::MngdColumns::run_actions(), SWC::Manager::MngdColumns::update(), SWC::Manager::MngdColumns::update_status(), and SWC::Manager::MngdColumns::update_status_ack().

+ Here is the caller graph for this function:

◆ stop()

void SWC::Env::Mngr::stop ( )
static

Definition at line 157 of file MngrEnv.h.

References m_env.

Referenced by SWC::Manager::AppContext::stop().

+ Here is the caller graph for this function:

Member Data Documentation

◆ _reporting

Manager::Metric::Reporting::Ptr SWC::Env::Mngr::_reporting
private

Definition at line 132 of file MngrEnv.h.

◆ _resources

System::Resources SWC::Env::Mngr::_resources
private

Definition at line 133 of file MngrEnv.h.

◆ app_io

Comm::IoContextPtr SWC::Env::Mngr::app_io

Definition at line 124 of file MngrEnv.h.

◆ cfg_ram_percent_allowed

SWC::Config::Property::Value_int32_g SWC::Env::Mngr::cfg_ram_percent_allowed

Definition at line 126 of file MngrEnv.h.

◆ cfg_ram_percent_reserved

SWC::Config::Property::Value_int32_g SWC::Env::Mngr::cfg_ram_percent_reserved

Definition at line 127 of file MngrEnv.h.

◆ cfg_ram_release_rate

SWC::Config::Property::Value_int32_g SWC::Env::Mngr::cfg_ram_release_rate

Definition at line 128 of file MngrEnv.h.

◆ m_columns

Manager::Columns SWC::Env::Mngr::m_columns
private

Definition at line 135 of file MngrEnv.h.

◆ m_env

std::shared_ptr<Mngr> SWC::Env::Mngr::m_env = nullptr
inlinestaticprivate

Definition at line 131 of file MngrEnv.h.

Referenced by columns(), init(), io(), is_shuttingdown(), metrics_track(), mngd_columns(), post(), rangers(), res(), reset(), role(), schemas(), and stop().

◆ m_mngd_columns

Manager::MngdColumns SWC::Env::Mngr::m_mngd_columns
private

Definition at line 138 of file MngrEnv.h.

◆ m_rangers

Manager::Rangers SWC::Env::Mngr::m_rangers
private

Definition at line 137 of file MngrEnv.h.

◆ m_role

Manager::MngrRole SWC::Env::Mngr::m_role
private

Definition at line 136 of file MngrEnv.h.

◆ m_schemas

Manager::Schemas SWC::Env::Mngr::m_schemas
private

Definition at line 134 of file MngrEnv.h.

◆ m_shutting_down

Core::AtomicBool SWC::Env::Mngr::m_shutting_down
private

Definition at line 139 of file MngrEnv.h.

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