#include <swcdb/db/client/Clients.h>
Public Types | |
enum | Flag : uint8_t { DEFAULT = 0x01, BROKER = 0x02, SCHEMA = 0x04 } |
using | Ptr = ClientsPtr |
Static Public Member Functions | |
static Ptr | make (const Config::Settings &settings, const Comm::IoContextPtr &io_ctx, const ContextManager::Ptr &mngr_ctx, const ContextRanger::Ptr &rgr_ctx, const ContextBroker::Ptr &bkr_ctx) |
static Ptr | make (const Config::Settings &settings, const Comm::IoContextPtr &io_ctx, const ContextManager::Ptr &mngr_ctx, const ContextRanger::Ptr &rgr_ctx) |
static Ptr | make (const Config::Settings &settings, const Comm::IoContextPtr &io_ctx, const ContextBroker::Ptr &bkr_ctx) |
Protected Member Functions | |
Clients (const Config::Settings &settings, const Comm::IoContextPtr &io_ctx, const ContextManager::Ptr &mngr_ctx, const ContextRanger::Ptr &rgr_ctx, const ContextBroker::Ptr &bkr_ctx) | |
Clients (const Config::Settings &settings, const Comm::IoContextPtr &io_ctx, const ContextManager::Ptr &mngr_ctx, const ContextRanger::Ptr &rgr_ctx) | |
Clients (const Config::Settings &settings, const Comm::IoContextPtr &io_ctx, const ContextBroker::Ptr &bkr_ctx) | |
using SWC::client::Clients::Ptr = ClientsPtr |
enum SWC::client::Clients::Flag : uint8_t |
|
protected |
Definition at line 42 of file Clients.cc.
Referenced by make().
|
protected |
Definition at line 81 of file Clients.cc.
|
protected |
Definition at line 118 of file Clients.cc.
|
noexcept |
Definition at line 153 of file Clients.cc.
|
inline |
Definition at line 237 of file Clients.h.
References brokers, and SWC::client::Brokers::queues.
|
inline |
Definition at line 242 of file Clients.h.
References brokers, and SWC::client::Brokers::queues.
|
inlinenoexcept |
|
inline |
Definition at line 247 of file Clients.h.
References SWC::client::Managers::groups, and managers.
|
inline |
Definition at line 252 of file Clients.h.
References SWC::client::Managers::groups, and managers.
|
inline |
Definition at line 215 of file Clients.h.
References managers, and SWC::client::Managers::queues.
|
inline |
Definition at line 220 of file Clients.h.
References managers, and SWC::client::Managers::queues.
|
inline |
Definition at line 226 of file Clients.h.
References SWC::client::Rangers::queues, and rangers.
|
inline |
Definition at line 231 of file Clients.h.
References SWC::client::Rangers::queues, and rangers.
|
inline |
Definition at line 130 of file Clients.h.
References SWC::client::Schemas::get(), and schemas.
|
inline |
Definition at line 142 of file Clients.h.
References SWC::client::Schemas::get(), and schemas.
|
inline |
Definition at line 150 of file Clients.h.
References SWC::client::Schemas::get(), and schemas.
|
inline |
Definition at line 136 of file Clients.h.
References SWC::client::Schemas::get(), and schemas.
|
inlinenoexcept |
Definition at line 125 of file Clients.h.
References brokers, and SWC::client::Brokers::queues.
Referenced by init().
|
inline |
Definition at line 87 of file Clients.h.
References brokers, SWC::client::Brokers::cfg_hosts, has_brokers(), SWC::Config::Property::Value_strings_g::set_cb_on_chg(), and shared().
|
static |
Definition at line 32 of file Clients.cc.
References Clients(), and io_ctx.
|
static |
Definition at line 23 of file Clients.cc.
References Clients(), and io_ctx.
|
static |
Definition at line 13 of file Clients.cc.
References Clients(), and io_ctx.
Referenced by SWC::FsBroker::AppContext::AppContext(), SWC::Manager::AppContext::AppContext(), SWC::ThriftBroker::AppContext::AppContext(), main(), SWC::Broker::AppContext::make(), and SWC::Ranger::AppContext::make().
|
inline |
Definition at line 190 of file Clients.h.
References SWC::client::Managers::MasterRangesCache::get_read(), managers, and SWC::client::Managers::master_ranges_cache.
|
inline |
Definition at line 203 of file Clients.h.
References SWC::client::Managers::MasterRangesCache::get_write(), managers, and SWC::client::Managers::master_ranges_cache.
|
inline |
Definition at line 175 of file Clients.h.
References managers, SWC::client::Managers::master_ranges_cache, and SWC::client::Managers::MasterRangesCache::remove().
|
inline |
Definition at line 180 of file Clients.h.
References managers, SWC::client::Managers::master_ranges_cache, and SWC::client::Managers::MasterRangesCache::set().
|
inline |
Definition at line 257 of file Clients.h.
References SWC::client::Managers::groups, and managers.
|
inline |
Definition at line 162 of file Clients.h.
References SWC::client::Rangers::cache, SWC::client::CachedRangers::get(), and rangers.
|
inline |
Definition at line 157 of file Clients.h.
References SWC::client::Rangers::cache, rangers, and SWC::client::CachedRangers::remove().
|
inline |
Definition at line 168 of file Clients.h.
References SWC::client::Rangers::cache, rangers, and SWC::client::CachedRangers::set().
|
inlinenoexcept |
Definition at line 110 of file Clients.h.
References flags, and SWC::Core::AtomicBase< T, OrderT >::store().
Referenced by set_flags__schemas_via_default().
|
inlinenoexcept |
Definition at line 115 of file Clients.h.
References SWC::FS::BROKER, and set_flags().
|
inline |
Definition at line 83 of file Clients.h.
Referenced by SWC::client::Schemas::_request(), and init().
void SWC::client::Clients::stop | ( | ) |
Definition at line 166 of file Clients.cc.
References stop_io(), and stop_services().
|
inline |
void SWC::client::Clients::stop_services | ( | ) |
Definition at line 155 of file Clients.cc.
References brokers, managers, SWC::client::Brokers::queues, SWC::client::Managers::queues, SWC::client::Rangers::queues, rangers, running, and SWC::Core::AtomicBase< T, OrderT >::store().
Referenced by stop().
|
inlinenoexcept |
Brokers SWC::client::Clients::brokers |
Definition at line 278 of file Clients.h.
Referenced by get_bkr_io(), get_bkr_queue(), has_brokers(), init(), and stop_services().
const Config::Property::Value_uint8_g::Ptr SWC::client::Clients::cfg_recv_ahead |
const Config::Property::Value_int32_g::Ptr SWC::client::Clients::cfg_recv_buff_sz |
const Config::Property::Value_int32_g::Ptr SWC::client::Clients::cfg_recv_timeout |
const Config::Property::Value_uint8_g::Ptr SWC::client::Clients::cfg_send_ahead |
const Config::Property::Value_int32_g::Ptr SWC::client::Clients::cfg_send_buff_sz |
const Config::Property::Value_int32_g::Ptr SWC::client::Clients::cfg_send_timeout |
const Config::Property::Value_int32_g::Ptr SWC::client::Clients::cfg_send_timeout_ratio |
Core::Atomic<uint8_t> SWC::client::Clients::flags |
Definition at line 263 of file Clients.h.
Referenced by SWC::client::Schemas::_request(), and set_flags().
Comm::IoContextPtr SWC::client::Clients::io_ctx |
Managers SWC::client::Clients::managers |
Definition at line 276 of file Clients.h.
Referenced by get_mngr(), get_mngr_io(), get_mngr_queue(), mngr_cache_get_read_master(), mngr_cache_get_write_master(), mngr_cache_remove_master(), mngr_cache_set_master(), remove_mngr(), and stop_services().
Rangers SWC::client::Clients::rangers |
Definition at line 277 of file Clients.h.
Referenced by get_rgr_io(), get_rgr_queue(), rgr_cache_get(), rgr_cache_remove(), rgr_cache_set(), and stop_services().
Core::AtomicBool SWC::client::Clients::running |
Definition at line 262 of file Clients.h.
Referenced by stop_services(), and stopping().
Schemas SWC::client::Clients::schemas |
Definition at line 275 of file Clients.h.
Referenced by get_schema().