| 217 | |
| 218 | |
| 219 | int Trans_delegate::after_commit(THD *thd, bool all) |
| 220 | { |
| 221 | DBUG_ENTER("Trans_delegate::after_commit"); |
| 222 | Trans_param param = { 0, 0, 0, 0 }; |
| 223 | bool is_real_trans= (all || thd->transaction.all.ha_list == 0); |
| 224 | |
| 225 | if (is_real_trans) |
| 226 | param.flags = true; |
| 227 | |
| 228 | thd->get_trans_fixed_pos(¶m.log_file, ¶m.log_pos); |
| 229 | |
| 230 | DBUG_PRINT("enter", ("log_file: %s, log_pos: %llu", param.log_file, param.log_pos)); |
| 231 | |
| 232 | int ret= 0; |
| 233 | FOREACH_OBSERVER(ret, after_commit, thd, (¶m)); |
| 234 | DBUG_RETURN(ret); |
| 235 | } |
| 236 | |
| 237 | int Trans_delegate::after_rollback(THD *thd, bool all) |
| 238 | { |
nothing calls this directly
no outgoing calls
no test coverage detected