summaryrefslogtreecommitdiff
path: root/sql/rpl_parallel.h
diff options
context:
space:
mode:
Diffstat (limited to 'sql/rpl_parallel.h')
-rw-r--r--sql/rpl_parallel.h6
1 files changed, 3 insertions, 3 deletions
diff --git a/sql/rpl_parallel.h b/sql/rpl_parallel.h
index 956a31e4b7f..c4bb407e5eb 100644
--- a/sql/rpl_parallel.h
+++ b/sql/rpl_parallel.h
@@ -222,10 +222,10 @@ struct rpl_parallel {
~rpl_parallel();
void reset();
rpl_parallel_entry *find(uint32 domain_id);
- void wait_for_done(THD *thd);
+ void wait_for_done(THD *thd, Relay_log_info *rli);
+ void stop_during_until();
bool workers_idle();
- bool do_event(rpl_group_info *serial_rgi, Log_event *ev,
- ulonglong event_size);
+ int do_event(rpl_group_info *serial_rgi, Log_event *ev, ulonglong event_size);
};