#include <load_session.hpp>

Collaboration diagram for cubload::session:

Public Member Functions
	session (load_args &args)

	~session ()

	session (session &&other)=delete

	session (const session &copy)=delete

session &	operator= (session &&other)=delete

session &	operator= (const session &copy)=delete

int	install_class (cubthread::entry &thread_ref, const batch &batch, bool &is_ignored, std::string &cls_name)

int	load_batch (cubthread::entry &thread_ref, const batch *batch, bool use_temp_batch, bool &is_batch_accepted, load_status &status)

void	wait_for_completion ()

void	wait_for_previous_batch (batch_id id)

void	notify_batch_done (batch_id id)

void	notify_batch_done_and_register_tran_end (batch_id id, int tran_index)

void	register_tran_start (int tran_index)

void	on_error (std::string &err_msg)

void	fail (bool has_lock=false)

bool	is_failed ()

void	interrupt ()

void	fetch_status (load_status &status, bool has_lock=false)

void	stats_update_rows_committed (int64_t rows_committed)

int64_t	stats_get_rows_committed ()

void	stats_update_last_committed_line (int64_t last_committed_line)

void	stats_update_current_line (int64_t current_line)

void	update_class_statistics (cubthread::entry &thread_ref)

const load_args &	get_args ()

class_registry &	get_class_registry ()

template<typename... Args>
void	append_log_msg (MSGCAT_LOADDB_MSG msg_id, Args &&...args)

Private Member Functions
void	notify_waiting_threads ()

bool	is_completed ()

void	collect_stats ()

template<typename T >
void	update_atomic_value_with_max (std::atomic< T > &atomic_val, T new_max)

Private Attributes
std::mutex	m_mutex

std::condition_variable	m_cond_var

std::set< int >	m_tran_indexes

load_args	m_args

batch_id	m_last_batch_id

std::atomic< batch_id >	m_max_batch_id

std::atomic< size_t >	m_active_task_count

class_registry	m_class_registry

stats	m_stats

bool	m_is_failed

std::vector< stats >	m_collected_stats

driver *	m_driver

cubthread::entry_task *	m_temp_task

Detailed Description

Definition at line 71 of file load_session.hpp.

Constructor & Destructor Documentation

cubload::session::session ( load_args & args )

explicit

cubload::session::~session ( )

Definition at line 271 of file load_session.cpp.

References m_driver, and cubload::worker_manager_unregister_session().

cubload::session::session ( session && other )

delete

cubload::session::session ( const session & copy )

delete

Member Function Documentation

template<typename... Args>

void cubload::session::append_log_msg	(	MSGCAT_LOADDB_MSG	msg_id,
		Args &&...	args
	)

Definition at line 168 of file load_session.hpp.

References collect_stats(), cubload::error_handler::format_log_msg(), get_args(), cubload::stats::log_message, m_mutex, m_stats, and notify_waiting_threads().

Referenced by cubload::server_class_installer::check_class(), cubload::load_task::execute(), cubload::server_class_installer::register_class_with_attributes(), and update_class_statistics().

Here is the caller graph for this function:

void cubload::session::collect_stats ( )

private

Definition at line 634 of file load_session.cpp.

References cubload::stats::error_message, cubload::stats::log_message, m_args, m_collected_stats, m_stats, and cubload::load_args::syntax_check.

Referenced by append_log_msg(), notify_batch_done_and_register_tran_end(), and on_error().

Here is the caller graph for this function:

void cubload::session::fail ( bool has_lock = false )

Definition at line 379 of file load_session.cpp.

References m_is_failed, m_mutex, and notify_waiting_threads().

Referenced by cubload::load_task::execute(), cubload::init_driver(), install_class(), and interrupt().

Here is the caller graph for this function:

void cubload::session::fetch_status	(	load_status &	status,
		bool	has_lock = `false`
	)

Definition at line 648 of file load_session.cpp.

References assert, is_completed(), is_failed(), m_collected_stats, and m_mutex.

Referenced by load_batch(), and sloaddb_fetch_status().

Here is the caller graph for this function:

const load_args & cubload::session::get_args ( )

Definition at line 513 of file load_session.cpp.

References m_args.

Referenced by append_log_msg(), cubload::load_task::execute(), cubload::server_object_loader::finish_line(), cubload::server_object_loader::flush_records(), cubload::server_class_installer::is_class_ignored(), cubload::server_object_loader::process_line(), and cubload::server_class_installer::register_class_with_attributes().

Here is the caller graph for this function:

class_registry & cubload::session::get_class_registry ( )

Definition at line 507 of file load_session.cpp.

References m_class_registry.

Referenced by cubload::load_task::execute(), cubload::server_object_loader::init(), install_class(), and cubload::server_class_installer::register_class_with_attributes().

Here is the caller graph for this function:

int cubload::session::install_class	(	cubthread::entry &	thread_ref,
		const batch &	batch,
		bool &	is_ignored,
		std::string &	cls_name
	)

Definition at line 525 of file load_session.cpp.

References er_errid_if_has_error(), ER_FAILED, er_has_error(), fail(), cubload::class_registry::get_class_entry(), cubload::batch::get_class_id(), cubload::class_entry::get_class_name(), get_class_registry(), cubload::invoke_parser(), is_failed(), cubload::class_entry::is_ignored(), m_driver, cubthread::entry::m_loaddb_driver, NO_ERROR, and NULL.

Referenced by sloaddb_install_class().

Here is the caller graph for this function:

void cubload::session::interrupt ( )

Definition at line 413 of file load_session.cpp.

References fail(), cubthread::get_entry(), logtb_set_tran_index_interrupt(), m_mutex, m_tran_indexes, and notify_waiting_threads().

Referenced by session_stop_attached_threads(), and sloaddb_interrupt().

Here is the caller graph for this function:

bool cubload::session::is_completed ( )

private

Definition at line 279 of file load_session.cpp.

References m_last_batch_id, and m_max_batch_id.

Referenced by fetch_status(), and wait_for_completion().

Here is the caller graph for this function:

bool cubload::session::is_failed ( )

Definition at line 407 of file load_session.cpp.

References m_is_failed.

Referenced by cubload::load_task::execute(), fetch_status(), cubload::server_object_loader::finish_line(), cubload::server_object_loader::flush_records(), install_class(), load_batch(), notify_batch_done(), notify_batch_done_and_register_tran_end(), cubload::server_object_loader::process_line(), cubload::server_class_installer::register_class_with_attributes(), wait_for_completion(), and wait_for_previous_batch().

Here is the caller graph for this function:

int cubload::session::load_batch	(	cubthread::entry &	thread_ref,
		const batch *	batch,
		bool	use_temp_batch,
		bool &	is_batch_accepted,
		load_status &	status
	)