Method after_rollback

phx_percona/percona/sql/rpl_handler.cc:237–248

}

int Trans_delegate::after_rollback(THD *thd, bool all)
{
  Trans_param param = { 0, 0, 0, 0 };
  bool is_real_trans= (all || thd->transaction.all.ha_list == 0);

  if (is_real_trans)
    param.flags|= TRANS_IS_REAL_TRANS;
  thd->get_trans_fixed_pos(&param.log_file, &param.log_pos);
  int ret= 0;
  FOREACH_OBSERVER(ret, after_rollback, thd, (&param));
  return ret;
}


int Binlog_storage_delegate::after_flush(THD *thd,