diff options
| author | unknown <knielsen@knielsen-hq.org> | 2013-06-24 10:50:25 +0200 |
|---|---|---|
| committer | unknown <knielsen@knielsen-hq.org> | 2013-06-24 10:50:25 +0200 |
| commit | 26a9fbc416cc8afaf2099ce293334e85c76b50cb (patch) | |
| tree | a49b66fcdbc8775fca1b610019ab5dcc0094af20 /sql/slave.h | |
| parent | 6a0a4f00a1741df68c0d201e090f5d28f59410c8 (diff) | |
| download | mariadb-git-26a9fbc416cc8afaf2099ce293334e85c76b50cb.tar.gz | |
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.
Diffstat (limited to 'sql/slave.h')
| -rw-r--r-- | sql/slave.h | 4 |
1 files changed, 3 insertions, 1 deletions
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); |