Parallel_reader::Thread_ctx Struct Reference

Thread related context information. More...

#include <row0pread.h>

Public Member Functions
	Thread_ctx (size_t id) noexcept
	Constructor. More...
	~Thread_ctx () noexcept
	Destructor. More...
template<typename T >
void	set_callback_ctx (T *ctx) noexcept
	Set thread related callback information. More...
template<typename T >
T *	get_callback_ctx () noexcept
	Get the thread related callback information/. More...
void	create_blob_heap () noexcept
	Create BLOB heap. More...
State	get_state () const noexcept
void	save_current_user_record_as_last_processed () noexcept
void	restore_to_last_processed_user_record () noexcept
void	save_previous_user_record_as_last_processed () noexcept
void	restore_to_first_unprocessed () noexcept
	Thread_ctx (Thread_ctx &&)=delete
	Thread_ctx (const Thread_ctx &)=delete
Thread_ctx &	operator= (Thread_ctx &&)=delete
Thread_ctx &	operator= (const Thread_ctx &)=delete

Public Attributes
size_t	m_thread_id {std::numeric_limits<size_t>::max()}
	Thread ID. More...
void *	m_callback_ctx {}
	Callback information related to the thread. More...
mem_heap_t *	m_blob_heap {}
	BLOB heap per thread. More...
State	m_state {State::UNKNOWN}
	Worker thread state. More...
PCursor *	m_pcursor {}
	Current persistent cursor. More...

Detailed Description

Thread related context information.

Constructor & Destructor Documentation

Thread_ctx() [1/3]

Parallel_reader::Thread_ctx::Thread_ctx ( size_t  id )

inlineexplicitnoexcept

Constructor.

Parameters

[in]

id

Thread ID

~Thread_ctx()

Parallel_reader::Thread_ctx::~Thread_ctx ( )

inlinenoexcept

Destructor.

Thread_ctx() [2/3]

Parallel_reader::Thread_ctx::Thread_ctx ( Thread_ctx &&  )

delete

Thread_ctx() [3/3]

Parallel_reader::Thread_ctx::Thread_ctx ( const Thread_ctx &  )

delete

Member Function Documentation

create_blob_heap()

void Parallel_reader::Thread_ctx::create_blob_heap ( )

inlinenoexcept

Create BLOB heap.

get_callback_ctx()

template<typename T >

T * Parallel_reader::Thread_ctx::get_callback_ctx ( )

inlinenoexcept

Get the thread related callback information/.

Returns

return context.

get_state()

State Parallel_reader::Thread_ctx::get_state ( ) const

inlinenoexcept

Returns

the worker thread state.

operator=() [1/2]

Thread_ctx & Parallel_reader::Thread_ctx::operator= ( const Thread_ctx &  )

delete

operator=() [2/2]

Thread_ctx & Parallel_reader::Thread_ctx::operator= ( Thread_ctx &&  )

delete

restore_to_first_unprocessed()

void Parallel_reader::Thread_ctx::restore_to_first_unprocessed ( )

noexcept

See also

PCursor::restore_to_first_unprocessed

restore_to_last_processed_user_record()

void Parallel_reader::Thread_ctx::restore_to_last_processed_user_record ( )

noexcept

See also

PCursor::restore_to_last_processed_user_record

save_current_user_record_as_last_processed()

void Parallel_reader::Thread_ctx::save_current_user_record_as_last_processed ( )

noexcept

See also

PCursor::save_current_user_record_as_last_processed

save_previous_user_record_as_last_processed()

void Parallel_reader::Thread_ctx::save_previous_user_record_as_last_processed ( )

noexcept

See also

PCursor::save_previous_user_record_as_last_processed

set_callback_ctx()

template<typename T >

void Parallel_reader::Thread_ctx::set_callback_ctx ( T *  ctx )

inlinenoexcept

Set thread related callback information.

Parameters

[in]

ctx

callback context

Member Data Documentation

m_blob_heap

mem_heap_t* Parallel_reader::Thread_ctx::m_blob_heap {}

BLOB heap per thread.

m_callback_ctx

void* Parallel_reader::Thread_ctx::m_callback_ctx {}

Callback information related to the thread.

Note

Needs to be created and destroyed by the callback itself.

m_pcursor

PCursor* Parallel_reader::Thread_ctx::m_pcursor {}

Current persistent cursor.

m_state

State Parallel_reader::Thread_ctx::m_state {State::UNKNOWN}

Worker thread state.

m_thread_id

size_t Parallel_reader::Thread_ctx::m_thread_id {std::numeric_limits<size_t>::max()}

Thread ID.

---

The documentation for this struct was generated from the following files:

• storage/innobase/include/row0pread.h
• storage/innobase/row/row0pread.cc