From 26a9fbc416cc8afaf2099ce293334e85c76b50cb Mon Sep 17 00:00:00 2001 From: unknown Date: Mon, 24 Jun 2013 10:50:25 +0200 Subject: MDEV-4506: Parallel replication of group-committed transactions: Intermediate commit First very rough sketch. We spawn and retire a pool of slave threads. Test main.alias works, most likely not much else does. --- sql/slave.h | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) (limited to 'sql/slave.h') diff --git a/sql/slave.h b/sql/slave.h index 565f40b7236..69b0e011a39 100644 --- a/sql/slave.h +++ b/sql/slave.h @@ -51,6 +51,7 @@ class Relay_log_info; class Master_info; class Master_info_index; +struct rpl_parallel_thread; int init_intvar_from_file(int* var, IO_CACHE* f, int default_val); int init_strvar_from_file(char *var, int max_size, IO_CACHE *f, @@ -227,7 +228,8 @@ int purge_relay_logs(Relay_log_info* rli, THD *thd, bool just_reset, void set_slave_thread_options(THD* thd); void set_slave_thread_default_charset(THD *thd, Relay_log_info const *rli); int rotate_relay_log(Master_info* mi); -int apply_event_and_update_pos(Log_event* ev, THD* thd, Relay_log_info* rli); +int apply_event_and_update_pos(Log_event* ev, THD* thd, Relay_log_info* rli, + rpl_parallel_thread *rpt); pthread_handler_t handle_slave_io(void *arg); pthread_handler_t handle_slave_sql(void *arg); -- cgit v1.2.1