Home - News ( United States | United Kingdom | Italy | Germany ) - Football scores

Showing content from http://www.ncbi.nlm.nih.gov/IEB/ToolBox/CPP_DOC/doxyhtml/cass__query__list_8hpp_source.html below:

NCBI C++ ToolKit: include/objtools/pubseq_gateway/impl/cassandra/cass_query_list.hpp Source File

shared_ptr<CCassQueryList>

(shared_ptr<CCassConnection> cass_conn) noexcept;

(

exception* e =

);

(unique_ptr<ICassQueryListConsumer> consumer,

retry_count,

post_async =

);

(

wait);

shared_ptr<CCassQuery>

(

slot_index);

()

;

#define BEGIN_IDBLOB_SCOPE

BEGIN_IDBLOB_SCOPE USING_NCBI_SCOPE

function< void()> TCassQueryListTickCB

CCassOneExecConsumer(CCassOneExecConsumer &&)=delete

bool Start(shared_ptr< CCassQuery > query, CCassQueryList &list, size_t) override

CCassOneExecConsumer & operator=(const CCassOneExecConsumer &)=delete

void Reset(shared_ptr< CCassQuery >, CCassQueryList &, size_t) override

bool ProcessRow(shared_ptr< CCassQuery >, CCassQueryList &, size_t) override

CCassOneExecConsumer(function< bool(CCassQuery &query, CCassQueryList &list)> cb, function< void(CCassQuery &query, CCassQueryList &list, bool succeeded)> finish_cb=nullptr)

function< bool(CCassQuery &query, CCassQueryList &list)> m_cb

function< void(CCassQuery &query, CCassQueryList &list, bool succeeded)> m_finish_cb

void Failed(shared_ptr< CCassQuery >, CCassQueryList &, size_t, const exception *) override

CCassOneExecConsumer & operator=(CCassOneExecConsumer &&)=delete

bool Finish(shared_ptr< CCassQuery > query, CCassQueryList &list, size_t) override

CCassOneExecConsumer(const CCassOneExecConsumer &)=delete

weak_ptr< CCassQueryList > m_query_list

virtual void OnData() override

CQryNotification(shared_ptr< CCassQueryList > query_list, size_t index)

CCassQueryList::CQryNotification.

vector< shared_ptr< CQryNotification > > m_notification_arr

void DetachSlot(SQrySlot *slot)

CCassQueryList & SetKeyspace(const string &keyspace)

atomic< thread::id > m_owning_thread

SQrySlot * CheckSlot(size_t index, bool discard)

void AttachSlot(SQrySlot *slot, SPendingSlot &&pending_slot)

void Release(SQrySlot *slot)

atomic_bool m_yield_in_progress

vector< SPendingSlot > m_pending_arr

virtual ~CCassQueryList()

atomic_size_t m_attached_slots

static constexpr uint64_t kReadyPopWaitTimeout

static constexpr unsigned int kDfltMaxQuery

weak_ptr< CCassQueryList > m_self_weak

void Execute(unique_ptr< ICassQueryListConsumer > consumer, int retry_count, bool post_async=false)

static shared_ptr< CCassQueryList > Create(shared_ptr< CCassConnection > cass_conn) noexcept

CCassQueryList.

size_t NumberOfActiveQueries() const

static constexpr size_t kNotifyQueueLen

shared_ptr< CCassConnection > m_cass_conn

shared_ptr< CCassQuery > Extract(size_t slot_index)

static constexpr unsigned int kResetRelaxTime

size_t NumberOfBusySlots() const

vector< SQrySlot > m_query_arr

void CheckPending(SQrySlot *slot)

string GetKeyspace() const

size_t GetMaxQueries() const

void ReadRows(SQrySlot *slot)

TCassQueryListTickCB m_tick_cb

SQrySlot * CheckSlots(bool discard, bool wait=true)

size_t NumberOfPendingSlots() const

CCassQueryList & SetTickCB(TCassQueryListTickCB cb)

CCassQueryList & SetMaxQueries(size_t max_queries)

static constexpr uint64_t kReadyPushWaitTimeout

void Cancel(const exception *e=nullptr)

mpmc_bounded_queue_w< size_t, kNotifyQueueLen > m_ready

ICassQueryListConsumer & operator=(ICassQueryListConsumer &&)=delete

virtual bool Finish(shared_ptr< CCassQuery >, CCassQueryList &, size_t)

ICassQueryListConsumer & operator=(const ICassQueryListConsumer &)=delete

virtual bool Start(shared_ptr< CCassQuery > query, CCassQueryList &list, size_t query_idx)=0

virtual bool ProcessRow(shared_ptr< CCassQuery > query, CCassQueryList &list, size_t query_idx)=0

ICassQueryListConsumer(const ICassQueryListConsumer &)=delete

virtual ~ICassQueryListConsumer()=default

ICassQueryListConsumer(ICassQueryListConsumer &&)=delete

ICassQueryListConsumer()=default

virtual void Failed(shared_ptr< CCassQuery > query, CCassQueryList &list, size_t query_idx, const exception *e)=0

virtual void Reset(shared_ptr< CCassQuery >, CCassQueryList &, size_t)

unique_ptr< ICassQueryListConsumer > m_consumer

shared_ptr< CCassQuery > m_qry

unique_ptr< ICassQueryListConsumer > m_consumer

RetroSearch is an open source project built by @garambo | Open a GitHub Issue

Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo

HTML: 3.2 | Encoding: UTF-8 | Version: 0.7.4