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

Method flush_pending_event

phx_percona/percona/sql/binlog.cc:493–502  ·  view source on GitHub ↗

Flush pending event to the cache buffer. */

Source from the content-addressed store, hash-verified

491 Flush pending event to the cache buffer.
492 */
493 int flush_pending_event(THD *thd) {
494 if (m_pending)
495 {
496 m_pending->set_flags(Rows_log_event::STMT_END_F);
497 if (int error= write_event(thd, m_pending))
498 return error;
499 thd->clear_binlog_table_maps();
500 }
501 return 0;
502 }
503
504 /**
505 Remove the pending event.

Callers

nothing calls this directly

Calls

no outgoing calls

Tested by

no test coverage detected