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 Types | Public Member Functions | Static Public Member Functions | Public Attributes | List of all members
SWC::Ranger::Range::MetaRegOnAddReq Class Reference
+ Inheritance diagram for SWC::Ranger::Range::MetaRegOnAddReq:
+ Collaboration diagram for SWC::Ranger::Range::MetaRegOnAddReq:

Public Types

typedef std::shared_ptr< MetaRegOnAddReq > Ptr
 
- Public Types inherited from SWC::Ranger::Query::Update::BaseMeta
typedef std::shared_ptr< BaseMeta > Ptr
 
- Public Types inherited from SWC::client::Query::Update::Handlers::BaseSingleColumn
typedef std::shared_ptr< BaseSingleColumn > Ptr
 
- Public Types inherited from SWC::client::Query::Update::Handlers::Base
typedef std::shared_ptr< Base > Ptr
 
typedef Core::Vector< Column * > Colms
 

Public Member Functions

SWC_CAN_INLINE MetaRegOnAddReq (const RangePtr &a_range, Callback::RangeQueryUpdate *a_req)
 
 MetaRegOnAddReq (MetaRegOnAddReq &&)=delete
 
 MetaRegOnAddReq (const MetaRegOnAddReq &)=delete
 
MetaRegOnAddReq & operator= (const MetaRegOnAddReq &)=delete
 
MetaRegOnAddReq & operator= (MetaRegOnAddReq &&)=delete
 
virtual ~MetaRegOnAddReq () noexcept
 
virtual void response (int err=Error::OK) override
 
virtual void callback () override
 
- Public Member Functions inherited from SWC::Ranger::Query::Update::BaseMeta
 BaseMeta (const RangePtr &range)
 
virtual bool valid () noexcept override
 
bool is_last_rsp (int err)
 
- Public Member Functions inherited from SWC::client::Query::Update::Handlers::BaseSingleColumn
SWC_CAN_INLINE BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t cid, DB::Types::KeySeq seq, uint32_t versions, uint32_t ttl_secs, DB::Types::Column type, Clients::Flag a_executor=Clients::DEFAULT)
 
SWC_CAN_INLINE BaseSingleColumn (const Clients::Ptr &a_clients, const cid_t cid, DB::Types::KeySeq seq, uint32_t versions, uint32_t ttl_secs, DB::Types::Column type, const StaticBuffer &buffer)
 
virtual ~BaseSingleColumn () noexcept
 
virtual bool requires_commit () noexcept override
 
virtual bool empty () noexcept override
 
virtual size_t size_bytes () noexcept override
 
virtual void next (Base::Colms &cols) noexcept override
 
virtual Base::Column * next (cid_t cid) noexcept override
 
virtual void error (cid_t cid, int err) noexcept override
 
SWC_CAN_INLINE size_t size () noexcept
 
- Public Member Functions inherited from SWC::client::Query::Update::Handlers::Base
SWC_CAN_INLINE Base (const Clients::Ptr &a_clients, Clients::Flag a_executor=Clients::Flag::DEFAULT) noexcept
 
 Base (Base &&)=delete
 
 Base (const Base &)=delete
 
Base & operator= (const Base &)=delete
 
Base & operator= (Base &&)=delete
 
virtual int error () noexcept
 
virtual void error (int err) noexcept
 
SWC_CAN_INLINE void add_resend_count (size_t count) noexcept
 
SWC_CAN_INLINE size_t get_resend_count (bool reset=true) noexcept
 
void commit ()
 
SWC_CAN_INLINE void commit (const cid_t cid)
 
void commit (Column *colp)
 

Static Public Member Functions

static SWC_CAN_INLINE Ptr make (const RangePtr &range, Callback::RangeQueryUpdate *req)
 

Public Attributes

Callback::RangeQueryUpdate * req
 
- Public Attributes inherited from SWC::Ranger::Query::Update::BaseMeta
RangePtr range
 
- Public Attributes inherited from SWC::client::Query::Update::Handlers::BaseSingleColumn
ColumnMutable column
 
- Public Attributes inherited from SWC::client::Query::Update::Handlers::Base
Clients::Ptr clients
 
Profiling profile
 
Core::Atomic< int > state_error
 
Core::CompletionCounter< uint64_t > completion
 
Core::Atomic< uint32_t > timeout
 
Core::Atomic< uint32_t > timeout_ratio
 
Core::Atomic< uint32_t > buff_sz
 
Core::Atomic< uint8_t > buff_ahead
 
const Clients::Flag executor
 

Additional Inherited Members

- Protected Member Functions inherited from SWC::Ranger::Query::Update::BaseMeta
virtual ~BaseMeta () noexcept
 
- Protected Member Functions inherited from SWC::client::Query::Update::Handlers::Base
virtual void _execute (Column *colp)
 
virtual ~Base () noexcept
 

Detailed Description

Definition at line 1109 of file Range.cc.

Member Typedef Documentation

◆ Ptr

typedef std::shared_ptr<MetaRegOnAddReq> SWC::Ranger::Range::MetaRegOnAddReq::Ptr

Definition at line 1111 of file Range.cc.

Constructor & Destructor Documentation

◆ MetaRegOnAddReq() [1/3]

SWC_CAN_INLINE SWC::Ranger::Range::MetaRegOnAddReq::MetaRegOnAddReq ( const RangePtr &  a_range,
Callback::RangeQueryUpdate *  a_req 
)
inline

Definition at line 1121 of file Range.cc.

Referenced by make().

+ Here is the caller graph for this function:

◆ MetaRegOnAddReq() [2/3]

SWC::Ranger::Range::MetaRegOnAddReq::MetaRegOnAddReq ( MetaRegOnAddReq &&  )
delete

◆ MetaRegOnAddReq() [3/3]

SWC::Ranger::Range::MetaRegOnAddReq::MetaRegOnAddReq ( const MetaRegOnAddReq &  )
delete

◆ ~MetaRegOnAddReq()

virtual SWC::Ranger::Range::MetaRegOnAddReq::~MetaRegOnAddReq ( )
inlinevirtualnoexcept

Definition at line 1130 of file Range.cc.

Member Function Documentation

◆ callback()

virtual void SWC::Ranger::Range::MetaRegOnAddReq::callback ( )
inlineoverridevirtual

Implements SWC::Ranger::Query::Update::BaseMeta.

Definition at line 1137 of file Range.cc.

References SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::cells_added, SWC::Comm::Protocol::Rgr::Params::RangeQueryUpdateRsp::err, SWC::client::Query::Update::Handlers::Base::error(), SWC::Env::Rgr::post(), SWC::Ranger::Query::Update::BaseMeta::range, req, SWC::Ranger::Callback::RangeQueryUpdate::response(), SWC::Ranger::Callback::RangeQueryUpdate::rsp, and SWC::Error::SERVER_SHUTTING_DOWN.

Referenced by response().

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

◆ make()

static SWC_CAN_INLINE Ptr SWC::Ranger::Range::MetaRegOnAddReq::make ( const RangePtr &  range,
Callback::RangeQueryUpdate *  req 
)
inlinestatic

Definition at line 1114 of file Range.cc.

References MetaRegOnAddReq(), SWC::Ranger::Query::Update::BaseMeta::range, and req.

Referenced by SWC::Ranger::Range::_run_add_queue().

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

◆ operator=() [1/2]

MetaRegOnAddReq& SWC::Ranger::Range::MetaRegOnAddReq::operator= ( const MetaRegOnAddReq &  )
delete

◆ operator=() [2/2]

MetaRegOnAddReq& SWC::Ranger::Range::MetaRegOnAddReq::operator= ( MetaRegOnAddReq &&  )
delete

◆ response()

virtual void SWC::Ranger::Range::MetaRegOnAddReq::response ( int  err = Error::OK)
inlineoverridevirtual

Implements SWC::client::Query::Update::Handlers::Base.

Definition at line 1132 of file Range.cc.

References callback(), and SWC::Ranger::Query::Update::BaseMeta::is_last_rsp().

+ Here is the call graph for this function:

Member Data Documentation

◆ req

Callback::RangeQueryUpdate* SWC::Ranger::Range::MetaRegOnAddReq::req

Definition at line 1118 of file Range.cc.

Referenced by callback(), and make().

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