MySQL 9.1.0
Source Code Documentation
Parallel_reader Member List

This is the complete list of members for Parallel_reader, including all inherited members.

add_scan(trx_t *trx, const Config &config, F &&f)Parallel_reader
available_threads(size_t n_required, bool use_reserved)Parallel_readerstatic
Ctxs typedefParallel_readerprivate
dequeue()Parallel_readerprivate
enqueue(std::shared_ptr< Ctx > ctx)Parallel_readerprivate
F typedefParallel_reader
Finish typedefParallel_reader
get_error_state() constParallel_readerinline
is_active() constParallel_readerinlineprivate
is_error_set() constParallel_readerinline
is_queue_empty() constParallel_readerprivate
is_tree_empty() constParallel_readerinline
join()Parallel_readerinline
Links typedefParallel_reader
m_ctx_idParallel_readerprivate
m_ctxsParallel_readerprivate
m_errParallel_readerprivate
m_eventParallel_readerprivate
m_finish_callbackParallel_readerprivate
m_max_threadsParallel_readerprivate
m_mutexParallel_readermutableprivate
m_n_completedParallel_readerprivate
m_n_threadsParallel_readerprivate
m_parallel_read_threadsParallel_readerprivate
m_scan_ctx_idParallel_readerprivate
m_scan_ctxsParallel_readerprivate
m_sig_countParallel_readerprivate
m_start_callbackParallel_readerprivate
m_syncParallel_readerprivate
m_thread_ctxsParallel_readerprivate
MAX_RESERVED_THREADSParallel_readerstatic
max_threads() constParallel_readerinline
MAX_THREADSParallel_readerstatic
MAX_TOTAL_THREADSParallel_readerstatic
operator=(Parallel_reader &&)=deleteParallel_reader
operator=(const Parallel_reader &)=deleteParallel_reader
parallel_read()Parallel_readerprivate
Parallel_reader(size_t max_threads)Parallel_readerexplicit
Parallel_reader(const Parallel_reader &)=deleteParallel_reader
Parallel_reader(const Parallel_reader &&)=deleteParallel_reader
release_threads(size_t n_threads)Parallel_readerinlinestatic
release_unused_threads(size_t unused_threads)Parallel_readerinlineprivate
run(size_t n_threads)Parallel_reader
s_active_threadsParallel_readerprivatestatic
Scan_ctxs typedefParallel_readerprivate
set_error_state(dberr_t err)Parallel_readerinline
set_finish_callback(Finish &&f)Parallel_readerinline
set_n_threads(size_t n_threads)Parallel_readerinline
set_start_callback(Start &&f)Parallel_readerinline
spawn(size_t n_threads) noexceptParallel_reader
Start typedefParallel_reader
State enum nameParallel_reader
worker(Thread_ctx *thread_ctx)Parallel_readerprivate
~Parallel_reader()Parallel_reader