SWC-DB  v0.5.12 C++ documentations
SWC-DB© (Super Wide Column Database) - High Performance Scalable Database (https://github.com/kashirin-alex/swc-db)
SWC::Comm::Protocol::Rgr::Handler Namespace Reference

Classes

struct  RangeLoad
 
struct  RangeLocate
 
struct  RangeQuerySelect
 
struct  Report
 

Functions

void assign_id (const ConnHandlerPtr &conn, const Event::Ptr &ev, Mngr::Req::RgrMngId::Ptr id_mngr)
 
void column_compact (const ConnHandlerPtr &conn, const Event::Ptr &ev)
 
void column_delete (const ConnHandlerPtr &conn, const Event::Ptr &ev)
 
void columns_unload (const ConnHandlerPtr &conn, const Event::Ptr &ev)
 
void column_update (const ConnHandlerPtr &conn, const Event::Ptr &ev)
 
void range_is_loaded (const ConnHandlerPtr &conn, const Event::Ptr &ev)
 
void range_query_update (const ConnHandlerPtr &conn, const Event::Ptr &ev)
 
void range_unload (const ConnHandlerPtr &conn, const Event::Ptr &ev)
 

Function Documentation

◆ assign_id()

void SWC::Comm::Protocol::Rgr::Handler::assign_id ( const ConnHandlerPtr conn,
const Event::Ptr ev,
Mngr::Req::RgrMngId::Ptr  id_mngr 
)

Definition at line 15 of file AssignId.h.

References SWC::Env::Rgr::is_not_accepting(), and SWC::Error::SERVER_SHUTTING_DOWN.

Referenced by SWC::Ranger::AppContext::handle(), and SWC::Comm::ConnHandler::write().

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

◆ column_compact()

void SWC::Comm::Protocol::Rgr::Handler::column_compact ( const ConnHandlerPtr conn,
const Event::Ptr ev 
)

Definition at line 17 of file ColumnCompact.h.

References SWC::Comm::Protocol::Rgr::Params::ColumnCompactReq::cid, SWC::Error::Exception::code(), SWC::Env::Rgr::columns(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::Rgr::Params::ColumnCompactRsp::err, SWC::Ranger::Columns::get_column(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.

Referenced by SWC::Ranger::AppContext::handle().

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

◆ column_delete()

void SWC::Comm::Protocol::Rgr::Handler::column_delete ( const ConnHandlerPtr conn,
const Event::Ptr ev 
)

Definition at line 17 of file ColumnDelete.h.

References SWC::Comm::Protocol::Rgr::Params::ColumnDelete::cid, SWC::Error::Exception::code(), SWC::Env::Rgr::columns(), SWC::Comm::Serializable::decode(), SWC::Ranger::Columns::get_column(), SWC::LOG_ERROR, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.

Referenced by SWC::Ranger::AppContext::handle().

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

◆ column_update()

void SWC::Comm::Protocol::Rgr::Handler::column_update ( const ConnHandlerPtr conn,
const Event::Ptr ev 
)

Definition at line 17 of file ColumnUpdate.h.

References SWC::DB::SchemaPrimitives::cid, SWC::Error::Exception::code(), SWC::Env::Rgr::columns(), SWC::Comm::Serializable::decode(), SWC::Ranger::Columns::get_column(), SWC::Env::Rgr::is_not_accepting(), SWC::LOG_DEBUG, SWC::LOG_ERROR, SWC::Comm::Protocol::Rgr::Params::ColumnUpdate::schema_primitives, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.

Referenced by SWC::Ranger::AppContext::handle().

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

◆ columns_unload()

void SWC::Comm::Protocol::Rgr::Handler::columns_unload ( const ConnHandlerPtr conn,
const Event::Ptr ev 
)

Definition at line 17 of file ColumnsUnload.h.

References SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadReq::cid_begin, SWC::Comm::Protocol::Rgr::Params::ColumnsUnloadReq::cid_end, SWC::Error::Exception::code(), SWC::Env::Rgr::columns(), SWC::Comm::Serializable::decode(), SWC::LOG_ERROR, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, SWC_LOG_OUT, and SWC::Ranger::Columns::unload().

Referenced by SWC::Ranger::AppContext::handle().

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

◆ range_is_loaded()

void SWC::Comm::Protocol::Rgr::Handler::range_is_loaded ( const ConnHandlerPtr conn,
const Event::Ptr ev 
)

Definition at line 17 of file RangeIsLoaded.h.

References SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedRsp::can_be_merged(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedReq::cid, SWC::Error::Exception::code(), SWC::Env::Rgr::columns(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedRsp::err, SWC::Ranger::Columns::get_range(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC::Error::RGR_NOT_LOADED_RANGE, SWC::Comm::Protocol::Rgr::Params::RangeIsLoadedReq::rid, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.

Referenced by SWC::Ranger::AppContext::handle().

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

◆ range_query_update()

void SWC::Comm::Protocol::Rgr::Handler::range_query_update ( const ConnHandlerPtr conn,
const Event::Ptr ev 
)

Definition at line 18 of file RangeQueryUpdate.h.

References SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateReq::cid, SWC::Error::Exception::code(), SWC::Env::Rgr::columns(), SWC::Comm::Serializable::decode(), SWC::Ranger::Columns::get_range(), SWC::Error::INVALID_ARGUMENT, SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC::Error::RGR_NOT_LOADED_RANGE, SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateReq::rid, SWC_CURRENT_EXCEPTION, SWC_LOG_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.

Referenced by SWC::Ranger::AppContext::handle().

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

◆ range_unload()

void SWC::Comm::Protocol::Rgr::Handler::range_unload ( const ConnHandlerPtr conn,
const Event::Ptr ev 
)

Definition at line 17 of file RangeUnload.h.

References SWC::Comm::Protocol::Rgr::Params::RangeUnload::cid, SWC::Error::Exception::code(), SWC::Env::Rgr::columns(), SWC::Comm::Serializable::decode(), SWC::Comm::Protocol::Rgr::Params::RangeUnloadRsp::err, SWC::Ranger::Columns::get_column(), SWC::LOG_ERROR, SWC::Comm::Buffers::make(), SWC::Error::OK, SWC::Comm::Protocol::Rgr::Params::RangeUnload::rid, SWC_CURRENT_EXCEPTION, SWC_LOG_OSTREAM, and SWC_LOG_OUT.

Referenced by SWC::Ranger::AppContext::handle().

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