Searched refs:set_rpl_channel_type (Results 1 – 14 of 14) sorted by relevance
269 void set_rpl_channel_type(enum_rpl_channel_type rpl_channel_type_arg) { in set_rpl_channel_type() function
6295 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_worker()6297 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_worker()6300 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_worker()7435 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_sql()7437 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_sql()7440 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_sql()
6417 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_worker()6419 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_worker()6422 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_worker()7502 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_sql()7504 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_sql()7507 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_sql()
6207 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_worker()6209 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_worker()6212 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_worker()7286 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_sql()7288 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_sql()7291 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_sql()
6188 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_worker()6190 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_worker()6193 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_worker()7264 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_sql()7266 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_sql()7269 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_sql()
304 void set_rpl_channel_type(enum_rpl_channel_type rpl_channel_type_arg) { in set_rpl_channel_type() function
5732 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_worker()5734 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_worker()5737 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_worker()6734 thd->rpl_thd_ctx.set_rpl_channel_type(GR_APPLIER_CHANNEL); in handle_slave_sql()6736 thd->rpl_thd_ctx.set_rpl_channel_type(GR_RECOVERY_CHANNEL); in handle_slave_sql()6739 thd->rpl_thd_ctx.set_rpl_channel_type(RPL_STANDARD_CHANNEL); in handle_slave_sql()