#include <swcdb/core/CompletionCounter.h>
Public Member Functions | |
constexpr SWC_CAN_INLINE | CompletionCounter (CountT start=0) noexcept |
CompletionCounter (const CompletionCounter &)=delete | |
CompletionCounter (const CompletionCounter &&)=delete | |
CompletionCounter & | operator= (const CompletionCounter &)=delete |
~CompletionCounter () noexcept | |
constexpr SWC_CAN_INLINE void | increment (CountT v=1) noexcept |
constexpr SWC_CAN_INLINE bool | is_last () noexcept |
constexpr SWC_CAN_INLINE CountT | count () const noexcept |
constexpr SWC_CAN_INLINE CountT | increment_and_count () noexcept |
constexpr SWC_CAN_INLINE CountT | decrement_and_count () noexcept |
Additional Inherited Members | |
Private Member Functions inherited from SWC::Core::Atomic< uint32_t > | |
constexpr SWC_CAN_INLINE | Atomic () noexcept |
constexpr SWC_CAN_INLINE | Atomic (ValueT initial) noexcept |
Atomic (const Atomic< uint32_t > &)=delete | |
Atomic (const Atomic< uint32_t > &&)=delete | |
Atomic< uint32_t > & | operator= (ValueT v)=delete |
~Atomic () noexcept | |
constexpr SWC_CAN_INLINE uint32_t | fetch_sub (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | fetch_add (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | fetch_xor (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | fetch_and (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | fetch_or (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | sub_rslt (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | add_rslt (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | xor_rslt (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | and_rslt (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | or_rslt (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | operator++ (int) noexcept |
constexpr SWC_CAN_INLINE uint32_t | operator-- (int) noexcept |
Private Member Functions inherited from SWC::Core::AtomicBase< uint32_t > | |
constexpr SWC_CAN_INLINE | AtomicBase () noexcept |
constexpr SWC_CAN_INLINE | AtomicBase (ValueT initial) noexcept |
AtomicBase (const AtomicBase< uint32_t > &)=delete | |
AtomicBase (const AtomicBase< uint32_t > &&)=delete | |
AtomicBase< uint32_t > & | operator= (ValueT v)=delete |
~AtomicBase () noexcept | |
constexpr SWC_CAN_INLINE void | store (uint32_t v) noexcept |
constexpr SWC_CAN_INLINE uint32_t | load () const noexcept |
constexpr SWC_CAN_INLINE uint32_t | exchange (uint32_t value) noexcept |
constexpr SWC_CAN_INLINE bool | compare_exchange_weak (uint32_t &at, uint32_t value) noexcept |
constexpr SWC_CAN_INLINE | operator uint32_t () const noexcept |
Definition at line 16 of file CompletionCounter.h.
|
inlineexplicitconstexprnoexcept |
Definition at line 19 of file CompletionCounter.h.
|
delete |
|
delete |
|
inlinenoexcept |
Definition at line 29 of file CompletionCounter.h.
|
inlineconstexprnoexcept |
Definition at line 42 of file CompletionCounter.h.
Referenced by SWC::client::Query::Update::Handlers::Common::commit_if_need(), SWC::Manager::ColumnHealthCheck::finishing(), SWC::client::Query::Select::Scanner::print(), SWC::System::Resources::stop(), SWC::client::Query::Select::Handlers::Common::wait(), SWC::client::Query::Update::Handlers::Common::wait(), SWC::client::Query::Update::Handlers::Metric::Reporting::wait(), and SWC::client::Query::Update::Handlers::Common::wait_ahead_buffers().
|
inlineconstexprnoexcept |
Definition at line 52 of file CompletionCounter.h.
Referenced by SWC::ThriftBroker::AppContext::releaseHandler().
|
inlineconstexprnoexcept |
Definition at line 32 of file CompletionCounter.h.
Referenced by SWC::System::Resources::checker(), SWC::client::Query::Update::BrokerCommitter::commit(), SWC::client::Query::Update::Handlers::Base::commit(), SWC::client::Query::Update::Committer::commit_data(), SWC::client::Query::Select::Handlers::Base::default_executor(), SWC::client::Query::Select::Scanner::mngr_locate_master(), SWC::client::Query::Select::Scanner::mngr_resolve_rgr_meta(), SWC::client::Query::Select::Scanner::mngr_resolve_rgr_select(), SWC::client::Query::Select::Scanner::rgr_locate_master(), SWC::client::Query::Select::Scanner::rgr_locate_meta(), and SWC::client::Query::Select::Scanner::rgr_select().
|
inlineconstexprnoexcept |
Definition at line 47 of file CompletionCounter.h.
Referenced by SWC::ThriftBroker::AppContext::getHandler().
|
inlineconstexprnoexcept |
Definition at line 37 of file CompletionCounter.h.
Referenced by SWC::client::Query::Update::BrokerCommitter::commit(), SWC::client::Query::Update::Committer::commit_data(), SWC::client::Query::Update::BrokerCommitter::committed(), SWC::client::Query::Update::Committer::committed_data(), SWC::Manager::ColumnHealthCheck::finishing(), SWC::Ranger::Query::Update::BaseMeta::is_last_rsp(), SWC::Comm::Protocol::Bkr::Handler::Updater::response(), SWC::client::Query::Update::Handlers::Common::response(), SWC::client::Query::Update::Handlers::Metric::Reporting::response(), SWC::DB::RgrData::BaseUpdater::response(), SWC::client::Query::Select::Scanner::response_if_last(), and SWC::System::Resources::schedule().
|
delete |