mrs::database::MysqlTaskMonitor Class Reference

#include <mysql_task_monitor.h>

Classes
struct	Task

Public Types
using	CachedSession = collector::MysqlFixedPoolManager::CachedObject
using	PoolManager = collector::MysqlFixedPoolManager
using	PoolManagerRef = std::shared_ptr< PoolManager >

Public Member Functions
	~MysqlTaskMonitor ()
void	call_async (CachedSession session, PoolManagerRef session_pool, std::list< std::string > preamble, std::string script, std::list< std::string > postamble, std::function< std::list< std::string >(const std::exception &)> on_error, const std::string &task_id)
void	start ()
void	stop ()
void	reset ()

Private Types
enum	State { k_initializing , k_running , k_check_tasks , k_stopped }

Private Member Functions
void	run ()
bool	update_task (Task &task)

Private Attributes
std::thread	thread_
WaitableVariable< State >	state_ {k_initializing}
std::mutex	tasks_mutex_
std::list< Task >	tasks_

Member Typedef Documentation

CachedSession

using mrs::database::MysqlTaskMonitor::CachedSession = collector::MysqlFixedPoolManager::CachedObject

PoolManager

using mrs::database::MysqlTaskMonitor::PoolManager = collector::MysqlFixedPoolManager

PoolManagerRef

using mrs::database::MysqlTaskMonitor::PoolManagerRef = std::shared_ptr<PoolManager>

Member Enumeration Documentation

State

enum mrs::database::MysqlTaskMonitor::State

private

Enumerator
k_initializing
k_running
k_check_tasks
k_stopped

Constructor & Destructor Documentation

~MysqlTaskMonitor()

mrs::database::MysqlTaskMonitor::~MysqlTaskMonitor

(

)

Member Function Documentation

call_async()

void mrs::database::MysqlTaskMonitor::call_async	(	CachedSession	session,
		PoolManagerRef	session_pool,
		std::list< std::string >	preamble,
		std::string	script,
		std::list< std::string >	postamble,
		std::function< std::list< std::string >(const std::exception &)>	on_error,
		const std::string &	task_id
	)

reset()

void mrs::database::MysqlTaskMonitor::reset

(

)

run()

void mrs::database::MysqlTaskMonitor::run ( )

private

start()

void mrs::database::MysqlTaskMonitor::start

(

)

stop()

void mrs::database::MysqlTaskMonitor::stop

(

)

update_task()

bool mrs::database::MysqlTaskMonitor::update_task ( Task &  task )

private

Member Data Documentation

state_

WaitableVariable<State> mrs::database::MysqlTaskMonitor::state_ {k_initializing}

private

tasks_

std::list<Task> mrs::database::MysqlTaskMonitor::tasks_

private

tasks_mutex_

std::mutex mrs::database::MysqlTaskMonitor::tasks_mutex_

private

thread_

std::thread mrs::database::MysqlTaskMonitor::thread_

private

---

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

• router/src/mysql_rest_service/src/mrs/database/mysql_task_monitor.h
• router/src/mysql_rest_service/src/mrs/database/mysql_task_monitor.cc