#include <swcdb/ranger/AppContext.h>
Public Types | |
typedef std::shared_ptr< AppContext > | Ptr |
Public Types inherited from SWC::Comm::AppContext | |
typedef std::shared_ptr< AppContext > | Ptr |
Public Member Functions | |
AppContext () | |
void | init (const std::string &host, const Comm::EndPoints &endpoints) override |
void | set_srv (Comm::server::SerializedServer::Ptr srv) |
virtual | ~AppContext () noexcept |
void | handle_established (Comm::ConnHandlerPtr conn) override |
void | handle_disconnect (Comm::ConnHandlerPtr conn) noexcept override |
void | handle (Comm::ConnHandlerPtr conn, const Comm::Event::Ptr &ev) override |
void | net_bytes_sent (const Comm::ConnHandlerPtr &conn, size_t b) noexcept override |
void | net_bytes_received (const Comm::ConnHandlerPtr &conn, size_t b) noexcept override |
void | net_accepted (const Comm::EndPoint &endpoint, bool secure) noexcept override |
void | shutting_down (const std::error_code &ec, const int &sig) |
void | stop () override |
Public Member Functions inherited from SWC::Comm::AppContext | |
SWC_CAN_INLINE | AppContext (Config::Property::Value_enum_g::Ptr a_cfg_encoder) noexcept |
AppContext (AppContext &&)=delete | |
AppContext (const AppContext &)=delete | |
AppContext & | operator= (AppContext &&)=delete |
AppContext & | operator= (const AppContext &)=delete |
Static Public Member Functions | |
static SWC_SHOULD_NOT_INLINE Ptr | make () |
Private Attributes | |
Comm::Protocol::Mngr::Req::RgrMngId::Ptr | id_mngr |
Comm::server::SerializedServer::Ptr | m_srv |
Metric::Reporting::Ptr | m_metrics |
std::shared_ptr< Comm::IoContext::ExecutorWorkGuard > | m_guard |
Additional Inherited Members | |
Public Attributes inherited from SWC::Comm::AppContext | |
const Config::Property::Value_enum_g::Ptr | cfg_encoder |
Definition at line 39 of file AppContext.h.
typedef std::shared_ptr<AppContext> SWC::Ranger::AppContext::Ptr |
Definition at line 41 of file AppContext.h.
|
inline |
Definition at line 97 of file AppContext.h.
Referenced by make().
|
inlinevirtualnoexcept |
Reimplemented from SWC::Comm::AppContext.
Definition at line 128 of file AppContext.h.
|
inlineoverridevirtual |
Implements SWC::Comm::AppContext.
Definition at line 142 of file AppContext.h.
References SWC::Comm::Protocol::Rgr::Handler::assign_id(), SWC::Comm::Protocol::Rgr::ASSIGN_ID_NEEDED, SWC::Comm::Protocol::Rgr::COLUMN_COMPACT, SWC::Comm::Protocol::Rgr::Handler::column_compact(), SWC::Comm::Protocol::Rgr::COLUMN_DELETE, SWC::Comm::Protocol::Rgr::Handler::column_delete(), SWC::Comm::Protocol::Rgr::Handler::column_update(), SWC::Comm::Protocol::Rgr::COLUMNS_UNLOAD, SWC::Comm::Protocol::Rgr::Handler::columns_unload(), id_mngr, SWC::Env::Rgr::is_shuttingdown(), m_metrics, SWC::Comm::Protocol::Rgr::MAX_CMD, SWC::Comm::Protocol::Common::Handler::not_implemented(), SWC::Env::Rgr::post(), SWC::Comm::Protocol::Rgr::RANGE_IS_LOADED, SWC::Comm::Protocol::Rgr::Handler::range_is_loaded(), SWC::Comm::Protocol::Rgr::RANGE_LOAD, SWC::Comm::Protocol::Rgr::RANGE_LOCATE, SWC::Comm::Protocol::Rgr::RANGE_QUERY_SELECT, SWC::Comm::Protocol::Rgr::RANGE_QUERY_UPDATE, SWC::Comm::Protocol::Rgr::Handler::range_query_update(), SWC::Comm::Protocol::Rgr::RANGE_UNLOAD, SWC::Comm::Protocol::Rgr::Handler::range_unload(), SWC::Comm::Protocol::Rgr::REPORT, SWC::Env::Rgr::rgr_data(), SWC::Error::RGR_NOT_READY, and SWC::Comm::Protocol::Rgr::SCHEMA_UPDATE.
|
inlineoverridevirtualnoexcept |
Implements SWC::Comm::AppContext.
Definition at line 136 of file AppContext.h.
|
inlineoverridevirtual |
Implements SWC::Comm::AppContext.
Definition at line 130 of file AppContext.h.
|
inlineoverridevirtual |
Reimplemented from SWC::Comm::AppContext.
Definition at line 107 of file AppContext.h.
References SWC::DB::RgrData::endpoints, id_mngr, SWC::Env::Rgr::io(), m_metrics, SWC::Env::Rgr::rgr_data(), shutting_down(), and SWC::Env::Rgr::start().
|
inlinestatic |
Definition at line 44 of file AppContext.h.
References AppContext(), SWC::FS::fs_type(), SWC::Env::Rgr::init(), SWC::Env::Clients::init(), SWC::Env::FsInterface::init(), SWC::Env::Rgr::io(), SWC::client::Clients::make(), SWC::Comm::IoContext::make(), and SWC::Env::Config::settings().
Referenced by SWC::Ranger::make_service().
|
inlineoverridevirtualnoexcept |
Reimplemented from SWC::Comm::AppContext.
Definition at line 255 of file AppContext.h.
References m_metrics.
|
inlineoverridevirtualnoexcept |
Reimplemented from SWC::Comm::AppContext.
Definition at line 249 of file AppContext.h.
References m_metrics.
|
inlineoverridevirtualnoexcept |
Reimplemented from SWC::Comm::AppContext.
Definition at line 243 of file AppContext.h.
References m_metrics.
|
inline |
Definition at line 124 of file AppContext.h.
References m_srv.
|
inline |
Definition at line 261 of file AppContext.h.
References id_mngr, SWC::Env::Rgr::io(), SWC::LOG_INFO, m_guard, m_srv, shutting_down(), SWC::Env::Rgr::shuttingdown(), SWC_CAN_INLINE, SWC_LOG, SWC_LOGF, and SWC_QUICK_EXIT.
Referenced by init(), and shutting_down().
|
inlineoverridevirtual |
Reimplemented from SWC::Comm::AppContext.
Definition at line 298 of file AppContext.h.
References SWC::Env::Clients::get(), id_mngr, SWC::Env::FsInterface::interface(), SWC::Env::Rgr::io(), m_guard, m_metrics, m_srv, SWC::Env::Clients::reset(), SWC::Env::FsInterface::reset(), SWC::Env::Rgr::reset(), and SWC::Env::Rgr::wait_if_in_process().
|
private |
Definition at line 329 of file AppContext.h.
Referenced by handle(), init(), shutting_down(), and stop().
|
private |
Definition at line 332 of file AppContext.h.
Referenced by shutting_down(), and stop().
|
private |
Definition at line 331 of file AppContext.h.
Referenced by handle(), handle_disconnect(), handle_established(), init(), net_accepted(), net_bytes_received(), net_bytes_sent(), and stop().
|
private |
Definition at line 330 of file AppContext.h.
Referenced by handle_disconnect(), handle_established(), set_srv(), shutting_down(), and stop().