Class cubpl::execution_stack¶

ClassList > cubpl > execution_stack

#include <pl_execution_stack_context.hpp>

Public Attributes¶

Type	Name
cubmethod::header	m_client_header
std::queue< cubmem::block >	m_data_queue
std::string	m_error_msg
cubmethod::header	m_java_header
bool	m_transaction_control

Public Functions¶

Type	Name
int	add_cursor (int handler_id, QUERY_ID query_id, bool oid_included)
void	add_query_handler (int handler_id)
void	destory_all_cursors (session * sess)
	execution_stack () = delete
	execution_stack (cubthread::entry * thread_p, session * sess)
	execution_stack (execution_stack && other) = delete
	execution_stack (const execution_stack & copy) = delete
connection_view &	get_connection ()
query_cursor *	get_cursor (QUERY_ID query_id)
std::queue< cubmem::block > &	get_data_queue ()
std::string	get_error_message ()
PL_STACK_ID	get_id () const
const std::unordered_set< std::uint64_t > *	get_stack_cursor () const
const std::unordered_set< int > *	get_stack_query_handler () const
cubthread::entry *	get_thread_entry () const
TRANID	get_tran_id ()
execution_stack &	operator= (execution_stack && other) = delete
execution_stack &	operator= (const execution_stack & copy) = delete
void	promote_to_session_cursor (QUERY_ID query_id)
int	read_data_from_java (cubmem::block & b)
void	read_payload_block (cubpacking::unpacker & unpacker)
void	remove_cursor (QUERY_ID query_id)
void	remove_query_handler (int handler_id)
void	reset_query_handlers ()
int	send_data_to_client (Args &&... args)
int	send_data_to_client_recv (const xs_callback_func & func, Args &&... args)
int	send_data_to_java (Args &&... args)
void	set_cs_command (int command)
void	set_error_message (std::string error_msg)
void	set_java_command (int command)
	~execution_stack ()

Protected Attributes¶

Type	Name
connection_view	m_connection
std::string	m_error_message
PL_STACK_ID	m_id
bool	m_is_running
session *	m_session
std::unordered_set< std::uint64_t >	m_stack_cursor_id
std::map< std::uint64_t, int >	m_stack_cursor_map
std::unordered_set< int >	m_stack_handler_id
cubthread::entry *	m_thread_p
TRANID	m_tid

Protected Functions¶

Type	Name
int	interrupt_handler ()

Public Attributes Documentation¶

variable m_client_header¶

cubmethod::header cubpl::execution_stack::m_client_header;

variable m_data_queue¶

std::queue<cubmem::block> cubpl::execution_stack::m_data_queue;

variable m_error_msg¶

std::string cubpl::execution_stack::m_error_msg;

variable m_java_header¶

cubmethod::header cubpl::execution_stack::m_java_header;

variable m_transaction_control¶

bool cubpl::execution_stack::m_transaction_control;

Public Functions Documentation¶

function add_cursor¶

int cubpl::execution_stack::add_cursor (
    int handler_id,
    QUERY_ID query_id,
    bool oid_included
)

function add_query_handler¶

void cubpl::execution_stack::add_query_handler (
    int handler_id
)

function destory_all_cursors¶

void cubpl::execution_stack::destory_all_cursors (
    session * sess
)

function execution_stack [1/4]¶

cubpl::execution_stack::execution_stack () = delete

function execution_stack [2/4]¶

cubpl::execution_stack::execution_stack (
    cubthread::entry * thread_p,
    session * sess
)

function execution_stack [3/4]¶

cubpl::execution_stack::execution_stack (
    execution_stack && other
) = delete

function execution_stack [4/4]¶

cubpl::execution_stack::execution_stack (
    const  execution_stack & copy
) = delete

function get_connection¶

connection_view & cubpl::execution_stack::get_connection ()

function get_cursor¶

query_cursor * cubpl::execution_stack::get_cursor (
    QUERY_ID query_id
)

function get_data_queue¶

std::queue< cubmem::block > & cubpl::execution_stack::get_data_queue ()

function get_error_message¶

inline std::string cubpl::execution_stack::get_error_message ()

function get_id¶

PL_STACK_ID cubpl::execution_stack::get_id () const

function get_stack_cursor¶

const std::unordered_set< std::uint64_t > * cubpl::execution_stack::get_stack_cursor () const

function get_stack_query_handler¶

const std::unordered_set< int > * cubpl::execution_stack::get_stack_query_handler () const

function get_thread_entry¶

cubthread::entry * cubpl::execution_stack::get_thread_entry () const

function get_tran_id¶

TRANID cubpl::execution_stack::get_tran_id ()

function operator=¶

execution_stack & cubpl::execution_stack::operator= (
    execution_stack && other
) = delete

function operator=¶

execution_stack & cubpl::execution_stack::operator= (
    const  execution_stack & copy
) = delete

function promote_to_session_cursor¶

void cubpl::execution_stack::promote_to_session_cursor (
    QUERY_ID query_id
)

function read_data_from_java¶

inline int cubpl::execution_stack::read_data_from_java (
    cubmem::block & b
)

function read_payload_block¶

void cubpl::execution_stack::read_payload_block (
    cubpacking::unpacker & unpacker
)

function remove_cursor¶

void cubpl::execution_stack::remove_cursor (
    QUERY_ID query_id
)

function remove_query_handler¶

void cubpl::execution_stack::remove_query_handler (
    int handler_id
)

function reset_query_handlers¶

void cubpl::execution_stack::reset_query_handlers ()

function send_data_to_client¶

template<typename ... Args>
inline int cubpl::execution_stack::send_data_to_client (
    Args &&... args
)

function send_data_to_client_recv¶

template<typename ... Args>
inline int cubpl::execution_stack::send_data_to_client_recv (
    const  xs_callback_func & func,
    Args &&... args
)

function send_data_to_java¶

template<typename ... Args>
inline int cubpl::execution_stack::send_data_to_java (
    Args &&... args
)

function set_cs_command¶

inline void cubpl::execution_stack::set_cs_command (
    int command
)

function set_error_message¶

inline void cubpl::execution_stack::set_error_message (
    std::string error_msg
)

function set_java_command¶

inline void cubpl::execution_stack::set_java_command (
    int command
)

function ~execution_stack¶

cubpl::execution_stack::~execution_stack ()

Protected Attributes Documentation¶

variable m_connection¶

connection_view cubpl::execution_stack::m_connection;

variable m_error_message¶

std::string cubpl::execution_stack::m_error_message;

variable m_id¶

PL_STACK_ID cubpl::execution_stack::m_id;

variable m_is_running¶

bool cubpl::execution_stack::m_is_running;

variable m_session¶

session* cubpl::execution_stack::m_session;

variable m_stack_cursor_id¶

std::unordered_set<std::uint64_t> cubpl::execution_stack::m_stack_cursor_id;

variable m_stack_cursor_map¶

std::map<std::uint64_t, int> cubpl::execution_stack::m_stack_cursor_map;

variable m_stack_handler_id¶

std::unordered_set<int> cubpl::execution_stack::m_stack_handler_id;

variable m_thread_p¶

cubthread::entry* cubpl::execution_stack::m_thread_p;

variable m_tid¶

TRANID cubpl::execution_stack::m_tid;

Protected Functions Documentation¶

function interrupt_handler¶

int cubpl::execution_stack::interrupt_handler ()

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