MCPcopy Create free account
hub / github.com/Tencent/phxsql / after_queue_event

Method after_queue_event

phx_percona/percona/sql/rpl_handler.cc:468–484  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

466}
467
468int 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(&param, 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 (&param, event_buf, event_len, flags));
483 return ret;
484}
485
486int Binlog_relay_IO_delegate::after_reset_slave(THD *thd, Master_info *mi)
487

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected