| 466 | } |
| 467 | |
| 468 | int Binlog_relay_IO_delegate::after_queue_event(THD *thd, Master_info *mi, |
| 469 | const char *event_buf, |
| 470 | ulong event_len, |
| 471 | bool synced) |
| 472 | { |
| 473 | Binlog_relay_IO_param param; |
| 474 | init_param(¶m, mi); |
| 475 | |
| 476 | uint32 flags=0; |
| 477 | if (synced) |
| 478 | flags |= BINLOG_STORAGE_IS_SYNCED; |
| 479 | |
| 480 | int ret= 0; |
| 481 | FOREACH_OBSERVER(ret, after_queue_event, thd, |
| 482 | (¶m, event_buf, event_len, flags)); |
| 483 | return ret; |
| 484 | } |
| 485 | |
| 486 | int Binlog_relay_IO_delegate::after_reset_slave(THD *thd, Master_info *mi) |
| 487 |
nothing calls this directly
no outgoing calls
no test coverage detected