Class cubthread::entry¶

ClassList > cubthread > entry

#include <thread_entry.hpp>

Public Types¶

Type	Name
enum	status

Public Attributes¶

Type	Name
int	_unload_cnt_parallel_process
int	_unload_parallel_process_idx
bool	check_interrupt
bool	clear_trace
int	client_id
css_conn_entry *	conn_entry
int	count_private_allocators
thread_id_t	emulate_tid
EVENT_STAT	event_stats
fi_test_item *	fi_test_array
int	index
bool	interrupted
bool	is_cdc_daemon
void *	lockwait
int	lockwait_msecs
int	lockwait_state
INT64	lockwait_stime
int	log_data_length
char *	log_data_ptr
struct log_zip *	log_zip_redo
struct log_zip *	log_zip_undo
struct pgbuf_holder_anchor *	m_holder_anchor
bool	m_is_private_lru_enabled
cubload::driver *	m_loaddb_driver
pthread_mutex_t	m_px_lock_mutex
entry *	m_px_orig_thread_entry
UINT64 *	m_px_stats
pthread_mutex_t	m_px_stats_mutex
std::atomic_int	m_qlist_count
status	m_status
bool	m_uses_px_stats
int	net_request_index
entry *	next_wait_thrd
bool	no_logging
bool	no_supplemental_log
bool	on_trace
HL_HEAPID	private_heap_id
int	private_lru_index
void *	query_entry
struct drand48_data	rand_buf
unsigned int	rand_seed
int	read_ovfl_pages_count
int	request_fix_count
int	request_latch_mode
thread_resume_suspend_status	resume_status
unsigned int	rid
std::atomic_bool	shutdown
bool	sort_stats_active
pthread_mutex_t	th_entry_lock
int	trace_format
lf_tran_entry *	tran_entries
int	tran_index
pthread_mutex_t	tran_index_lock
entry *	tran_next_wait
bool	trigger_involved
thread_type	type
struct vacuum_worker *	vacuum_worker
bool	victim_request_fail
bool	wait_for_latch_promote
pthread_cond_t	wakeup_cond
entry *	worker_thrd_list
int	xasl_errcode
int	xasl_recursion_depth
xasl_unpack_info *	xasl_unpack_info_ptr

Public Functions¶

Type	Name
void	assign_lf_tran_index (lockfree::tran::index idx)
void	claim_system_worker ()
void	end_resource_tracks (void)
	entry ()
cubbase::alloc_tracker &	get_alloc_tracker (void)
cubsync::critical_section_tracker &	get_csect_tracker (void)
cuberr::context &	get_error_context (void)
thread_id_t	get_id ()
lockfree::tran::index	get_lf_tran_index ()
cubbase::pgbuf_tracker &	get_pgbuf_tracker (void)
pthread_t	get_posix_id ()
log_system_tdes *	get_system_tdes (void)
bool	is_on_current_thread () const
void	lock (void)
void	pop_resource_tracks (void)
lockfree::tran::index	pull_lf_tran_index ()
void	push_resource_tracks (void)
void	register_id ()
void	release_packet (void * buffer)
void	request_lock_free_transactions (void)
void	reset_system_tdes (void)
void	retire_system_worker ()
void	return_lock_free_transaction_entries (void)
void	set_system_tdes (log_system_tdes * sys_tdes)
void	unlock (void)
void	unregister_id ()
	~entry ()

Public Types Documentation¶

enum status¶

enum cubthread::entry::status {
    TS_DEAD,
    TS_FREE,
    TS_RUN,
    TS_WAIT,
    TS_CHECK
};

Public Attributes Documentation¶

variable _unload_cnt_parallel_process¶

int cubthread::entry::_unload_cnt_parallel_process;

variable _unload_parallel_process_idx¶

int cubthread::entry::_unload_parallel_process_idx;

variable check_interrupt¶

bool cubthread::entry::check_interrupt;

variable clear_trace¶

bool cubthread::entry::clear_trace;

variable client_id¶

int cubthread::entry::client_id;

variable conn_entry¶

css_conn_entry* cubthread::entry::conn_entry;

variable count_private_allocators¶

int cubthread::entry::count_private_allocators;

variable emulate_tid¶

thread_id_t cubthread::entry::emulate_tid;

variable event_stats¶

EVENT_STAT cubthread::entry::event_stats;

variable fi_test_array¶

fi_test_item* cubthread::entry::fi_test_array;

variable index¶

int cubthread::entry::index;

variable interrupted¶

bool cubthread::entry::interrupted;

variable is_cdc_daemon¶

bool cubthread::entry::is_cdc_daemon;

variable lockwait¶

void* cubthread::entry::lockwait;

variable lockwait_msecs¶

int cubthread::entry::lockwait_msecs;

variable lockwait_state¶

int cubthread::entry::lockwait_state;

variable lockwait_stime¶

INT64 cubthread::entry::lockwait_stime;

variable log_data_length¶

int cubthread::entry::log_data_length;

variable log_data_ptr¶

char* cubthread::entry::log_data_ptr;

variable log_zip_redo¶

struct log_zip* cubthread::entry::log_zip_redo;

variable log_zip_undo¶

struct log_zip* cubthread::entry::log_zip_undo;

variable m_holder_anchor¶

struct pgbuf_holder_anchor* cubthread::entry::m_holder_anchor;

variable m_is_private_lru_enabled¶

bool cubthread::entry::m_is_private_lru_enabled;

variable m_loaddb_driver¶

cubload::driver* cubthread::entry::m_loaddb_driver;

variable m_px_lock_mutex¶

pthread_mutex_t cubthread::entry::m_px_lock_mutex;

variable m_px_orig_thread_entry¶

entry* cubthread::entry::m_px_orig_thread_entry;

variable m_px_stats¶

UINT64* cubthread::entry::m_px_stats;

variable m_px_stats_mutex¶

pthread_mutex_t cubthread::entry::m_px_stats_mutex;

variable m_qlist_count¶

std::atomic_int cubthread::entry::m_qlist_count;

variable m_status¶

status cubthread::entry::m_status;

variable m_uses_px_stats¶

bool cubthread::entry::m_uses_px_stats;

variable net_request_index¶

int cubthread::entry::net_request_index;

variable next_wait_thrd¶

entry* cubthread::entry::next_wait_thrd;

variable no_logging¶

bool cubthread::entry::no_logging;

variable no_supplemental_log¶

bool cubthread::entry::no_supplemental_log;

variable on_trace¶

bool cubthread::entry::on_trace;

variable private_heap_id¶

HL_HEAPID cubthread::entry::private_heap_id;

variable private_lru_index¶

int cubthread::entry::private_lru_index;

variable query_entry¶

void* cubthread::entry::query_entry;

variable rand_buf¶

struct drand48_data cubthread::entry::rand_buf;

variable rand_seed¶

unsigned int cubthread::entry::rand_seed;

variable read_ovfl_pages_count¶

int cubthread::entry::read_ovfl_pages_count;

variable request_fix_count¶

int cubthread::entry::request_fix_count;

variable request_latch_mode¶

int cubthread::entry::request_latch_mode;

variable resume_status¶

thread_resume_suspend_status cubthread::entry::resume_status;

variable rid¶

unsigned int cubthread::entry::rid;

variable shutdown¶

std::atomic_bool cubthread::entry::shutdown;

variable sort_stats_active¶

bool cubthread::entry::sort_stats_active;

variable th_entry_lock¶

pthread_mutex_t cubthread::entry::th_entry_lock;

variable trace_format¶

int cubthread::entry::trace_format;

variable tran_entries¶

lf_tran_entry* cubthread::entry::tran_entries[THREAD_TS_LAST];

variable tran_index¶

int cubthread::entry::tran_index;

variable tran_index_lock¶

pthread_mutex_t cubthread::entry::tran_index_lock;

variable tran_next_wait¶

entry* cubthread::entry::tran_next_wait;

variable trigger_involved¶

bool cubthread::entry::trigger_involved;

variable type¶

thread_type cubthread::entry::type;

variable vacuum_worker¶

struct vacuum_worker* cubthread::entry::vacuum_worker;

variable victim_request_fail¶

bool cubthread::entry::victim_request_fail;

variable wait_for_latch_promote¶

bool cubthread::entry::wait_for_latch_promote;

variable wakeup_cond¶

pthread_cond_t cubthread::entry::wakeup_cond;

variable worker_thrd_list¶

entry* cubthread::entry::worker_thrd_list;

variable xasl_errcode¶

int cubthread::entry::xasl_errcode;

variable xasl_recursion_depth¶

int cubthread::entry::xasl_recursion_depth;

variable xasl_unpack_info_ptr¶

xasl_unpack_info* cubthread::entry::xasl_unpack_info_ptr;

Public Functions Documentation¶

function assign_lf_tran_index¶

void cubthread::entry::assign_lf_tran_index (
    lockfree::tran::index idx
)

function claim_system_worker¶

void cubthread::entry::claim_system_worker ()

function end_resource_tracks¶

void cubthread::entry::end_resource_tracks (
    void
)

function entry¶

cubthread::entry::entry ()

function get_alloc_tracker¶

inline cubbase::alloc_tracker & cubthread::entry::get_alloc_tracker (
    void
)

function get_csect_tracker¶

inline cubsync::critical_section_tracker & cubthread::entry::get_csect_tracker (
    void
)

function get_error_context¶

inline cuberr::context & cubthread::entry::get_error_context (
    void
)

function get_id¶

thread_id_t cubthread::entry::get_id ()

function get_lf_tran_index¶

lockfree::tran::index cubthread::entry::get_lf_tran_index ()

function get_pgbuf_tracker¶

inline cubbase::pgbuf_tracker & cubthread::entry::get_pgbuf_tracker (
    void
)

function get_posix_id¶

pthread_t cubthread::entry::get_posix_id ()

function get_system_tdes¶

inline log_system_tdes * cubthread::entry::get_system_tdes (
    void
)

function is_on_current_thread¶

bool cubthread::entry::is_on_current_thread () const

function lock¶

void cubthread::entry::lock (
    void
)

function pop_resource_tracks¶

void cubthread::entry::pop_resource_tracks (
    void
)

function pull_lf_tran_index¶

lockfree::tran::index cubthread::entry::pull_lf_tran_index ()

function push_resource_tracks¶

void cubthread::entry::push_resource_tracks (
    void
)

function register_id¶

void cubthread::entry::register_id ()

function release_packet¶

void cubthread::entry::release_packet (
    void * buffer
)

function request_lock_free_transactions¶

void cubthread::entry::request_lock_free_transactions (
    void
)

function reset_system_tdes¶

inline void cubthread::entry::reset_system_tdes (
    void
)

function retire_system_worker¶

void cubthread::entry::retire_system_worker ()

function return_lock_free_transaction_entries¶

void cubthread::entry::return_lock_free_transaction_entries (
    void
)

function set_system_tdes¶

inline void cubthread::entry::set_system_tdes (
    log_system_tdes * sys_tdes
)

function unlock¶

void cubthread::entry::unlock (
    void
)

function unregister_id¶

void cubthread::entry::unregister_id ()

function ~entry¶

cubthread::entry::~entry ()

The documentation for this class was generated from the following file cubrid/src/thread/thread_entry.hpp