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/runner_8cpp_source.html below:

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

46

constexpr

char const

const

kParamThreadCount =

"runner_thread_count"

;

47

constexpr

char const

const

kParamConsistency =

"runner_consistency"

;

48

constexpr

char const

const

kParamPageSize =

"runner_page_size"

;

49

constexpr

char const

const

kParamMaxActiveStatements =

"runner_max_active_statements"

;

50

constexpr

char const

const

kParamMaxRetryCount =

"runner_max_retry_count"

;

97

unique_ptr<ICassandraFullscanPlan> plan

102 "Invalid sequence of operations, execution plan should not be overriden" 110 unsigned int

max_retry_count

157 return Execute

(

nullptr

""

);

164 "Invalid sequence of operations, execution plan should be provided" 175

thread_count =

max

(thread_count, 1UL);

178 "Invalid sequence of operations. Thread count is greater than max_active_statements total." 181

vector<thread> worker_threads;

182

vector<CCassandraFullscanWorker> workers;

184

worker_threads.reserve(thread_count - 1);

185

workers.reserve(thread_count);

188 if

(thread_count > 1) {

203 auto

consumer_factory_fn =

204

[

this

]() -> unique_ptr<ICassandraFullscanConsumer> {

209 for

(

size_t i

= 0;

< thread_count; ++

) {

219

workers.emplace_back(std::move(worker));

223 for

(

size_t i

= 0;

< workers.size() - 1; ++

) {

224

worker_threads.emplace_back(

232

workers[workers.size() - 1]();

235 for

(thread&

: worker_threads) {

238

worker_threads.clear();

240 bool

all_finished =

true

;

241 for

(

const auto

& worker : workers) {

242 if

(worker.HadError()) {

244 "Fullscan failed: one of workers got exception with message - "

+ worker.GetFirstError()

247 if

(!worker.IsFinished()) {

248

all_finished =

false

;

#define BEGIN_IDBLOB_SCOPE

CassConsistency TCassConsistency

static TCassConsistency FromString(string_view value)

shared_ptr< CCassQuery > TQueryPtr

CCassandraFullscanRunner & SetConsumerFactory(TCassandraFullscanConsumerFactory consumer_factory)

unsigned int m_MaxActiveStatements

unsigned int GetPageSize() const

TCassandraFullscanConsumerFactory m_ConsumerFactory

unsigned int m_MaxRetryCount

CCassandraFullscanRunner()

CCassandraFullscanRunner & SetConsumerCreationPolicy(ECassandraFullscanConsumerPolicy policy)

static constexpr unsigned int kMaxRetryCountDefault

CCassandraFullscanRunner & SetConsistency(CassConsistency value)

unsigned int GetMaxActiveStatements() const

void ApplyConfiguration(IRegistry const *registry, string const &section)

CCassandraFullscanRunner & SetMaxActiveStatements(unsigned int value)

CCassandraFullscanRunner & SetThreadCount(size_t value)

size_t GetThreadCount() const

static constexpr size_t kThreadCountDefault

static constexpr string_view kConsistencyDefault

mutex m_ConsumerFactoryMutex

unsigned int GetMaxRetryCount() const

CCassandraFullscanRunner & SetMaxRetryCount(unsigned int max_retry_count)

TCassConsistency GetConsistency() const

CCassandraFullscanRunner & SetExecutionPlan(unique_ptr< ICassandraFullscanPlan > plan)

static constexpr unsigned int kMaxActiveStatementsDefault

ECassandraFullscanConsumerPolicy m_ConsumerCreationPolicy

TCassConsistency m_Consistency

static constexpr unsigned int kPageSizeDefault

unique_ptr< ICassandraFullscanPlan > m_ExecutionPlan

CCassandraFullscanRunner & SetPageSize(unsigned int value)

CCassandraFullscanWorker & SetMaxRetryCount(unsigned int max_retry_count)

function< CCassandraFullscanPlan::TQueryPtr()> TTaskProvider

CCassandraFullscanWorker & SetPageSize(unsigned int value)

CCassandraFullscanWorker & SetMaxActiveStatements(unsigned int value)

CCassandraFullscanWorker & SetConsumerCreationPolicy(ECassandraFullscanConsumerPolicy policy)

CCassandraFullscanWorker & SetTaskProvider(TTaskProvider provider)

CCassandraFullscanWorker & SetConsumerFactory(TCassandraFullscanConsumerFactory consumer_factory)

CCassandraFullscanWorker & SetConsistency(CassConsistency value)

virtual size_t GetQueryCount() const =0

virtual TQueryPtr GetNextQuery()=0

function< unique_ptr< ICassandraFullscanConsumer >()> TCassandraFullscanConsumerFactory

ECassandraFullscanConsumerPolicy

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

#define NCBI_THROW(exception_class, err_code, message)

Generic macro to throw an exception, given the exception class, error code and message string.

virtual int GetInt(const string &section, const string &name, int default_value, TFlags flags=0, EErrAction err_action=eThrow) const

Get integer value of specified parameter name.

virtual string GetString(const string &section, const string &name, const string &default_value, TFlags flags=0) const

Get the parameter string value.

const GenericPointer< typename T::ValueType > T2 value

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