diff --git a/sql/rpl_binlog_sender.cc b/sql/rpl_binlog_sender.cc index 6fe49bf16d0..f979a0b7fa2 100644 --- a/sql/rpl_binlog_sender.cc +++ b/sql/rpl_binlog_sender.cc @@ -94,7 +94,7 @@ class Observe_transmission_guard { - The event is an `XID_EVENT` - The event is an `XA_PREPARE_LOG_EVENT`. - - The event is a `QUERY_EVENT` with query equal to "XA COMMIT" or "XA ABORT" + - The event is a `QUERY_EVENT` with query equal to "XA COMMIT" or "XA ROLLBACK" or "COMMIT". - The event is the first `QUERY_EVENT` after a `GTID_EVENT` and the query is not "BEGIN" --the statement is a DDL, for instance. @@ -131,7 +131,7 @@ class Observe_transmission_guard { m_to_set = (strcmp("BEGIN", ev.query) != 0); else m_to_set = (strncmp("XA COMMIT", ev.query, 9) == 0) || - (strncmp("XA ABORT", ev.query, 8) == 0) || + (strncmp("XA ROLLBACK", ev.query, 11) == 0) || (strncmp("COMMIT", ev.query, 6) == 0); break; }