diff options
author | Kristian Nielsen <knielsen@knielsen-hq.org> | 2018-10-13 22:53:31 +0200 |
---|---|---|
committer | Kristian Nielsen <knielsen@knielsen-hq.org> | 2018-10-13 22:53:31 +0200 |
commit | 1f8b0752adacca7a2f1800084ce45ec0a435f813 (patch) | |
tree | 1c3795d880801f23ab718e24e52e266470f5e8e3 /sql | |
parent | bc2903e744de3dae7871212d1a436cbf6f472cb1 (diff) | |
parent | 61bba2a540950335c794c69221e92e136c94d060 (diff) | |
download | mariadb-git-1f8b0752adacca7a2f1800084ce45ec0a435f813.tar.gz |
Merge branch 'gtid_table_garbage_rows' into 10.1
Diffstat (limited to 'sql')
-rw-r--r-- | sql/rpl_gtid.cc | 6 |
1 files changed, 6 insertions, 0 deletions
diff --git a/sql/rpl_gtid.cc b/sql/rpl_gtid.cc index 94944b5b3e5..955763fe195 100644 --- a/sql/rpl_gtid.cc +++ b/sql/rpl_gtid.cc @@ -329,7 +329,9 @@ rpl_slave_state::update(uint32 domain_id, uint32 server_id, uint64 sub_id, } rgi->gtid_ignore_duplicate_state= rpl_group_info::GTID_DUPLICATE_NULL; +#ifdef HAVE_REPLICATION rgi->pending_gtid_deletes_clear(); +#endif } if (!(list_elem= (list_element *)my_malloc(sizeof(*list_elem), MYF(MY_WME)))) @@ -715,12 +717,16 @@ end: redundant rows in mysql.gtid_slave_pos may accumulate if transactions are rolled back and retried after record_gtid(). */ +#ifdef HAVE_REPLICATION rgi->pending_gtid_deletes_save(gtid->domain_id, elist); +#endif } else { thd->mdl_context.release_transactional_locks(); +#ifdef HAVE_REPLICATION rpl_group_info::pending_gtid_deletes_free(elist); +#endif } } thd->lex->restore_backup_query_tables_list(&lex_backup); |