RetroSearch Browse

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

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

NCBI C++ ToolKit: src/objtools/pubseq_gateway/cassandra/fullscan/worker.cpp Source File

34 #include <condition_variable> 128

(*m_ActiveQueries)++;

132 catch

(

const

exception & e) {

141 bool

do_next{

true

}, restart_request{

false

result

{

true

};

157 m_Queries

[index]->row_consumer->Finalize();

158 m_Queries

[index]->row_consumer =

nullptr

;

160

}

catch

(

const

exception & e) {

164

(*m_ActiveQueries)--;

174

restart_request =

true

;

179

}

catch

(exception

const

& e) {

184 if

(restart_request) {

189

}

catch

(exception

const

& e) {

221 bool

need_exit{

false

}, more_tasks{

true

}, contunue_processing{

true

};

238

chrono::milliseconds(10),

247

&& contunue_processing;

252 string

error_msg =

"m_Queries[index].data_ready == true while m_Queries[index].query == nullptr"

;

261

contunue_processing = contunue_processing &&

m_RowConsumer

->Tick();

266

contunue_processing = contunue_processing &&

query

->row_consumer->Tick();

271

need_exit = (!more_tasks && *

m_ActiveQueries

== 0) || !contunue_processing;

279

}

catch

(

const

exception & e) {

#define BEGIN_IDBLOB_SCOPE

@ eQueryFailedRestartable

shared_ptr< CCassQuery > TQueryPtr

TCassConsistency m_Consistency

unsigned int m_QueryMaxRetryCount

string GetFirstError() const

CCassandraFullscanWorker & SetMaxRetryCount(unsigned int max_retry_count)

function< CCassandraFullscanPlan::TQueryPtr()> TTaskProvider

bool x_StartQuery(size_t index)

ECassandraFullscanConsumerPolicy m_ConsumerCreationPolicy

unsigned int m_MaxActiveStatements

TCassandraFullscanConsumerFactory m_ConsumerFactory

shared_ptr< SProgressStatus > m_ProgressStatus

void x_ProcessError(string const &msg)

bool x_ProcessQueryResult(size_t index)

CCassandraFullscanWorker & SetPageSize(unsigned int value)

TTaskProvider m_TaskProvider

unique_ptr< ICassandraFullscanConsumer > m_RowConsumer

CCassandraFullscanWorker & SetMaxActiveStatements(unsigned int value)

CCassandraFullscanWorker & SetConsumerCreationPolicy(ECassandraFullscanConsumerPolicy policy)

CCassandraFullscanPlan::TQueryPtr x_GetNextTask()

CCassandraFullscanWorker & SetTaskProvider(TTaskProvider provider)

unique_ptr< atomic_long > m_ActiveQueries

CCassandraFullscanWorker()

CCassandraFullscanWorker & SetConsumerFactory(TCassandraFullscanConsumerFactory consumer_factory)

vector< shared_ptr< SQueryContext > > m_Queries

CCassandraFullscanWorker & SetConsistency(CassConsistency value)

virtual void OnQueryRestart()

virtual bool ReadRow(CCassQuery const &query)=0

function< unique_ptr< ICassandraFullscanConsumer >()> TCassandraFullscanConsumerFactory

ECassandraFullscanConsumerPolicy

The NCBI C++ standard methods for dealing with std::string.

#define ERR_POST(message)

Error posting with file, line number information but without error codes.

void Error(CExceptionArgs_Base &args)

TErrCode GetErrCode(void) const

Get error code.

void Warning(CExceptionArgs_Base &args)

const GenericPointer< typename T::ValueType > T2 value

static SLJIT_INLINE sljit_ins msg(sljit_gpr r, sljit_s32 d, sljit_gpr x, sljit_gpr b)

BEGIN_IDBLOB_SCOPE USING_NCBI_SCOPE

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