26#ifndef ROUTER_SRC_MYSQL_REST_SERVICE_SRC_MRS_DATABASE_MYSQL_TASK_MONITOR_H_
27#define ROUTER_SRC_MYSQL_REST_SERVICE_SRC_MRS_DATABASE_MYSQL_TASK_MONITOR_H_
51 std::list<std::string> preamble, std::string script,
52 std::list<std::string> postamble,
53 std::function<std::list<std::string>(
const std::exception &)> on_error,
54 const std::string &task_id);
71 std::function<std::list<std::string>(
const std::exception &)>
on_error;
Definition: wait_variable.h:34
Definition: cache_manager.h:41
Definition: mysql_fixed_pool_manager.h:40
MySqlFixedCacheManagerImpl::CachedObject CachedObject
Definition: mysql_fixed_pool_manager.h:45
Definition: mysql_task_monitor.h:41
void reset()
Definition: mysql_task_monitor.cc:56
std::list< Task > tasks_
Definition: mysql_task_monitor.h:83
void start()
Definition: mysql_task_monitor.cc:40
void run()
Definition: mysql_task_monitor.cc:61
~MysqlTaskMonitor()
Definition: mysql_task_monitor.cc:38
std::mutex tasks_mutex_
Definition: mysql_task_monitor.h:82
State
Definition: mysql_task_monitor.h:77
@ k_check_tasks
Definition: mysql_task_monitor.h:77
@ k_initializing
Definition: mysql_task_monitor.h:77
@ k_running
Definition: mysql_task_monitor.h:77
@ k_stopped
Definition: mysql_task_monitor.h:77
std::shared_ptr< PoolManager > PoolManagerRef
Definition: mysql_task_monitor.h:45
WaitableVariable< State > state_
Definition: mysql_task_monitor.h:80
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)
Definition: mysql_task_monitor.cc:99
void stop()
Definition: mysql_task_monitor.cc:47
bool update_task(Task &task)
Definition: mysql_task_monitor.cc:113
std::thread thread_
Definition: mysql_task_monitor.h:79
Definition: authorize_manager.h:48
Definition: mysql_task_monitor.h:62
std::function< std::list< std::string >(const std::exception &)> on_error
Definition: mysql_task_monitor.h:71
std::string task_id
Definition: mysql_task_monitor.h:73
bool failed
Definition: mysql_task_monitor.h:74
std::string script
Definition: mysql_task_monitor.h:68
CachedSession session
Definition: mysql_task_monitor.h:66
PoolManagerRef session_pool_ref
Definition: mysql_task_monitor.h:65
std::list< std::string > preamble
Definition: mysql_task_monitor.h:67
std::list< std::string > error
Definition: mysql_task_monitor.h:70
std::list< std::string > postamble
Definition: mysql_task_monitor.h:69