mirror of
https://github.com/MariaDB/server.git
synced 2025-03-24 16:08:42 +01:00
b167730499
Problem was that initial GTID was set on wsrep_before_prepare out-of-order. In practice GTID was set to same as previous executed transaction GTID. In recovery valid GTID was found from prepared transaction and this transaction is committed leading to fact that same GTID was executed twice. This is fixed by setting invalid GTID at wsrep_before_prepare and later in wsrep_before_commit actual correct GTID is set and this setting is done while we are in commit monitor i.e. assigment is done in order of replication. In recovery if prepared transaction is found we check its GTID, if it is invalid transaction will be rolled back and if it is valid it will be committed. Initialize gtid seqno from recovered seqno when bootstrapping a new cluster. Added two test cases for both mariabackup and rsync SST methods to show that GTIDs remain consistent on cluster and that all expected rows are in the table. Added tests for wsrep GTID recovery with binlog on and off. Signed-off-by: Julius Goryavsky <julius.goryavsky@mariadb.com>
41 lines
1.5 KiB
C++
41 lines
1.5 KiB
C++
/* Copyright (C) 2015-2025 Codership Oy <info@codership.com>
|
|
|
|
This program is free software; you can redistribute it and/or modify
|
|
it under the terms of the GNU General Public License as published by
|
|
the Free Software Foundation; version 2 of the License.
|
|
|
|
This program is distributed in the hope that it will be useful,
|
|
but WITHOUT ANY WARRANTY; without even the implied warranty of
|
|
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
|
|
GNU General Public License for more details.
|
|
|
|
You should have received a copy of the GNU General Public License along
|
|
with this program; if not, write to the Free Software Foundation, Inc.,
|
|
51 Franklin Street, Fifth Floor, Boston, MA 02110-1335 USA. */
|
|
|
|
#ifndef WSREP_XID_H
|
|
#define WSREP_XID_H
|
|
|
|
#include <my_config.h>
|
|
|
|
#ifdef WITH_WSREP
|
|
|
|
#include "wsrep_mysqld.h"
|
|
#include "wsrep/gtid.hpp"
|
|
#include "handler.h" // XID typedef
|
|
|
|
void wsrep_xid_init(xid_t*, const wsrep::gtid&, const wsrep_server_gtid_t&);
|
|
const wsrep::id& wsrep_xid_uuid(const XID&);
|
|
wsrep::seqno wsrep_xid_seqno(const XID&);
|
|
|
|
template<typename T> T wsrep_get_SE_checkpoint();
|
|
bool wsrep_set_SE_checkpoint(const wsrep::gtid& gtid, const wsrep_server_gtid_t&);
|
|
//void wsrep_get_SE_checkpoint(XID&); /* uncomment if needed */
|
|
//void wsrep_set_SE_checkpoint(XID&); /* uncomment if needed */
|
|
|
|
void wsrep_sort_xid_array(XID *array, int len);
|
|
std::string wsrep_xid_print(const XID *xid);
|
|
bool wsrep_is_xid_gtid_undefined(const XID *xid);
|
|
|
|
#endif /* WITH_WSREP */
|
|
#endif /* WSREP_UTILS_H */
|