Class parallel_scan::input_handler_index¶

ClassList > parallel_scan > input_handler_index

#include <px_scan_input_handler_index.hpp>

Public Functions¶

Type	Name
SCAN_CODE	claim_next_overflow_page (THREAD_ENTRY * thread_p, int slot_idx, PAGE_PTR & out_page, int & out_range_idx)
void	cleanup_keys (THREAD_ENTRY * thread_p)
void	enter_worker ()
void	exit_overflow_help (THREAD_ENTRY * thread_p, int slot_idx)
int	finalize (THREAD_ENTRY * thread_p)
BTID_INT *	get_btid_int ()
INDX_INFO *	get_indx_info ()
key_val_range *	get_key_val_ranges ()
SCAN_CODE	get_next_page_with_fix (THREAD_ENTRY * thread_p, SCAN_ID * worker_scan_id, PAGE_PTR & out_page, INT16 * out_slot_hint=nullptr, int * out_range_idx=nullptr)
int	get_num_key_ranges () const
int	init_on_main (THREAD_ENTRY * thread_p, INDX_INFO * indx_info, SCAN_ID * scan_id, val_descr * vd, int parallelism)
int	initialize (THREAD_ENTRY * thread_p, HFID * hfid, SCAN_ID * scan_id)
	input_handler_index (interrupt * interrupt_p, err_messages_with_lock * err_messages_p)
bool	is_desc_index () const
void	leave_worker ()
void	release_overflow_page (THREAD_ENTRY * thread_p, PAGE_PTR page)
void	signal_chain_ended (int last_local_idx)
void	signal_no_more_leaves ()
int	try_publish_overflow (THREAD_ENTRY * thread_p, VPID first_ovf_vpid, VPID leaf_vpid, PGSLOTID leaf_slot_id, int range_idx)
SCAN_CODE	wait_or_help_overflow (THREAD_ENTRY * thread_p, PAGE_PTR & out_page, DB_VALUE * out_local_key, bool * out_local_clear_key, int & out_range_idx, int & out_slot_idx)

Public Functions Documentation¶

function claim_next_overflow_page¶

inline SCAN_CODE parallel_scan::input_handler_index::claim_next_overflow_page (
    THREAD_ENTRY * thread_p,
    int slot_idx,
    PAGE_PTR & out_page,
    int & out_range_idx
)

function cleanup_keys¶

void parallel_scan::input_handler_index::cleanup_keys (
    THREAD_ENTRY * thread_p
)

function enter_worker¶

inline void parallel_scan::input_handler_index::enter_worker ()

function exit_overflow_help¶

inline void parallel_scan::input_handler_index::exit_overflow_help (
    THREAD_ENTRY * thread_p,
    int slot_idx
)

function finalize¶

int parallel_scan::input_handler_index::finalize (
    THREAD_ENTRY * thread_p
)

function get_btid_int¶

inline BTID_INT * parallel_scan::input_handler_index::get_btid_int ()

function get_indx_info¶

inline INDX_INFO * parallel_scan::input_handler_index::get_indx_info ()

function get_key_val_ranges¶

inline key_val_range * parallel_scan::input_handler_index::get_key_val_ranges ()

function get_next_page_with_fix¶

inline SCAN_CODE parallel_scan::input_handler_index::get_next_page_with_fix (
    THREAD_ENTRY * thread_p,
    SCAN_ID * worker_scan_id,
    PAGE_PTR & out_page,
    INT16 * out_slot_hint=nullptr,
    int * out_range_idx=nullptr
)

function get_num_key_ranges¶

inline int parallel_scan::input_handler_index::get_num_key_ranges () const

function init_on_main¶

int parallel_scan::input_handler_index::init_on_main (
    THREAD_ENTRY * thread_p,
    INDX_INFO * indx_info,
    SCAN_ID * scan_id,
    val_descr * vd,
    int parallelism
)

function initialize¶

int parallel_scan::input_handler_index::initialize (
    THREAD_ENTRY * thread_p,
    HFID * hfid,
    SCAN_ID * scan_id
)

function input_handler_index¶

inline parallel_scan::input_handler_index::input_handler_index (
    interrupt * interrupt_p,
    err_messages_with_lock * err_messages_p
)

function is_desc_index¶

inline bool parallel_scan::input_handler_index::is_desc_index () const

function leave_worker¶

inline void parallel_scan::input_handler_index::leave_worker ()

function release_overflow_page¶

inline void parallel_scan::input_handler_index::release_overflow_page (
    THREAD_ENTRY * thread_p,
    PAGE_PTR page
)

function signal_chain_ended¶

inline void parallel_scan::input_handler_index::signal_chain_ended (
    int last_local_idx
)

function signal_no_more_leaves¶

inline void parallel_scan::input_handler_index::signal_no_more_leaves ()

function try_publish_overflow¶

inline int parallel_scan::input_handler_index::try_publish_overflow (
    THREAD_ENTRY * thread_p,
    VPID first_ovf_vpid,
    VPID leaf_vpid,
    PGSLOTID leaf_slot_id,
    int range_idx
)

function wait_or_help_overflow¶

inline SCAN_CODE parallel_scan::input_handler_index::wait_or_help_overflow (
    THREAD_ENTRY * thread_p,
    PAGE_PTR & out_page,
    DB_VALUE * out_local_key,
    bool * out_local_clear_key,
    int & out_range_idx,
    int & out_slot_idx
)

The documentation for this class was generated from the following file cubrid/src/query/parallel/px_scan/px_scan_input_handler_index.hpp