Master_info:用于IO线程的参数,包括连接master实例的信息。
Relay_log_info:用于sql线程,表示relay log相关的信息。
Slave_worker:继承Relay_log_info,包括一个job队列,用于并行的worker线程。
binlog event的类结构:
slave启动的函数栈:
dispatch_command
start_slave
start_slave_threads
start_slave_thread
start_slave:初始化master_info和relay_log_info两个对象
start_slave_threads:启动两个线程,分别是handle_slave_io
io线程,handle_slave_sql sql线程。
handle_slave_io: 启动io线程,根据master_info对象的连接信息,连接master主库。
while(!io_slave_killed(thd,mi))
request_dump:循环发送dump协议指令到master,接受event写入relay_log.
handle_slave_sql:启动sql线程,
1. 当没有使用并行复制的时候。
while (!sql_slave_killed(thd,rli))
exec_relay_log_event(thd,rli): 循环从relay_log中读取event,并执行apply。
exec_relay_log_event的调用栈:
apply_event_and_update_pos
Log_event::apply_event
Query_log_event::do_apply_event
Query_log_event::do_apply_event
2. 当设置了opt_slave_parallel_workers时,启用了并行复制
slave_start_workers:初始化relay_log_info中关于mts的变量。
slave_start_single_worker:启动多个并发线程。
handle_slave_worker:
while (!error)
error= slave_worker_exec_job(w,
rli):根据jobs_queue中的值,pop出event进行apply。
3,如果不能并行的,需要wait_for_workers_to_finish所有worker结束后,本线程自己独立执行。