MySQL  8.0.20
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)Parallel_readerstatic
Ctx classParallel_readerfriend
Ctxs typedefParallel_readerprivate
dequeue()Parallel_readerprivate
enqueue(std::shared_ptr< Ctx > ctx)Parallel_readerprivate
F typedefParallel_reader
fallback_to_single_threaded_mode()Parallel_readerinline
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_consumedParallel_readerprivate
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_parallel_read_threadsParallel_readerprivate
m_read_ahead_threadsParallel_readerprivate
m_read_aheadqParallel_readerprivate
m_scan_ctx_idParallel_readerprivate
m_scan_ctxsParallel_readerprivate
m_sig_countParallel_readerprivate
m_single_threaded_modeParallel_readerprivate
m_start_callbackParallel_readerprivate
m_submittedParallel_readerprivate
m_syncParallel_readerprivate
MAX_THREADSParallel_readerstatic
max_threads() constParallel_reader
operator=(Parallel_reader &&)=deleteParallel_reader
operator=(const Parallel_reader &)=deleteParallel_reader
parallel_read()Parallel_readerprivate
Parallel_reader(size_t max_threads, bool sync=true)Parallel_readerexplicit
Parallel_reader(const Parallel_reader &)=deleteParallel_reader
Parallel_reader(const Parallel_reader &&)=deleteParallel_reader
read_ahead()Parallel_readerprivate
Read_ahead_queue typedefParallel_readerprivate
read_ahead_queue_empty() constParallel_readerinlineprivate
read_ahead_worker(page_no_t n_pages)Parallel_readerprivate
release_threads(size_t n_threads)Parallel_readerinlinestatic
release_unused_threads(size_t unused_threads)Parallel_readerinlineprivate
reset_error_state()Parallel_readerinlineprivate
run()Parallel_reader
s_active_threadsParallel_readerprivatestatic
Scan_ctx classParallel_readerfriend
Scan_ctxs typedefParallel_readerprivate
set_error_state(dberr_t err)Parallel_readerinline
set_finish_callback(Finish &&f)Parallel_readerinline
set_start_callback(Start &&f)Parallel_readerinline
Start typedefParallel_reader
worker(size_t id)Parallel_readerprivate
~Parallel_reader()Parallel_reader