mirror of
https://github.com/MariaDB/server.git
synced 2025-01-16 12:02:42 +01:00
047754a728
* Removed all references related to wsrep_thd_pool (which was removed) * Removed unused declarations in wsrep_schema.h * The following would result invalid reads in Wsrep_schema::replay_transaction(): ``` frag_table->field[4]->val_str(&buf); Wsrep_schema_impl::end_index_scan(frag_table); Wsrep_schema_impl::finish_stmt(thd); ret= wsrep_apply_events(thd, rli, buf.c_ptr_safe(), buf.length()); ``` because `buf` was accessed after closing the table. The fix is to perform storage reads using a different THD. * In Wsrep_schema::recover_sr_transactions(), cluster_table was opened for write, however it is only read here. And frag_table was opened for read, wereas write is potentially needed. Also, avoid copy caused by String::c_ptr() to zero terminate the c string, use c_ptr_quick instead.
144 lines
4.4 KiB
C++
144 lines
4.4 KiB
C++
/* Copyright (C) 2015-2019 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-1301 USA. */
|
|
|
|
|
|
#ifndef WSREP_SCHEMA_H
|
|
#define WSREP_SCHEMA_H
|
|
|
|
/* wsrep-lib */
|
|
#include "wsrep_types.h"
|
|
|
|
#include "mysqld.h"
|
|
#include "wsrep_mysqld.h"
|
|
|
|
/*
|
|
Forward decls
|
|
*/
|
|
class THD;
|
|
class Relay_log_info;
|
|
struct TABLE;
|
|
struct TABLE_LIST;
|
|
struct st_mysql_lex_string;
|
|
typedef struct st_mysql_lex_string LEX_STRING;
|
|
|
|
/** Name of the table in `wsrep_schema_str` used for storing streaming
|
|
replication data. In an InnoDB full format, e.g. "database/tablename". */
|
|
extern const char* wsrep_sr_table_name_full;
|
|
|
|
class Wsrep_schema
|
|
{
|
|
public:
|
|
|
|
Wsrep_schema();
|
|
~Wsrep_schema();
|
|
|
|
/*
|
|
Initialize wsrep schema. Storage engines must be running before
|
|
calling this function.
|
|
*/
|
|
int init();
|
|
|
|
/*
|
|
Store wsrep view info into wsrep schema.
|
|
*/
|
|
int store_view(THD*, const Wsrep_view& view);
|
|
|
|
/*
|
|
Restore view info from stable storage.
|
|
*/
|
|
Wsrep_view restore_view(THD* thd, const Wsrep_id& own_id) const;
|
|
|
|
/**
|
|
Append transaction fragment to fragment storage.
|
|
Transaction must have been started for THD before this call.
|
|
In order to make changes durable, transaction must be committed
|
|
separately after this call.
|
|
|
|
@param thd THD object
|
|
@param server_id Wsrep server identifier
|
|
@param transaction_id Transaction identifier
|
|
@param flags Flags for the fragment
|
|
@param data Fragment data buffer
|
|
|
|
@return Zero in case of success, non-zero on failure.
|
|
*/
|
|
int append_fragment(THD* thd,
|
|
const wsrep::id& server_id,
|
|
wsrep::transaction_id transaction_id,
|
|
wsrep::seqno seqno,
|
|
int flags,
|
|
const wsrep::const_buffer& data);
|
|
/**
|
|
Update existing fragment meta data. The fragment must have been
|
|
inserted before using append_fragment().
|
|
|
|
@param thd THD object
|
|
@param ws_meta Wsrep meta data
|
|
|
|
@return Zero in case of success, non-zero on failure.
|
|
*/
|
|
int update_fragment_meta(THD* thd,
|
|
const wsrep::ws_meta& ws_meta);
|
|
|
|
/**
|
|
Remove fragments from storage. This method must be called
|
|
inside active transaction. Fragment removal will be committed
|
|
once the transaction commits.
|
|
|
|
@param thd Pointer to THD object
|
|
@param server_id Identifier of the running server
|
|
@param transaction_id Identifier of the current transaction
|
|
@param fragments Vector of fragment seqnos to be removed
|
|
*/
|
|
int remove_fragments(THD* thd,
|
|
const wsrep::id& server_id,
|
|
wsrep::transaction_id transaction_id,
|
|
const std::vector<wsrep::seqno>& fragments);
|
|
|
|
/**
|
|
Replay a transaction from stored fragments. The caller must have
|
|
started a transaction for a thd.
|
|
|
|
@param thd Pointer to THD object
|
|
@param ws_meta Write set meta data for commit fragment.
|
|
@param fragments Vector of fragments to be replayed
|
|
|
|
@return Zero on success, non-zero on failure.
|
|
*/
|
|
int replay_transaction(THD* thd,
|
|
Relay_log_info* rli,
|
|
const wsrep::ws_meta& ws_meta,
|
|
const std::vector<wsrep::seqno>& fragments);
|
|
|
|
/**
|
|
Recover streaming transactions from SR table.
|
|
This method should be called after storage enignes are initialized.
|
|
It will scan SR table and replay found streaming transactions.
|
|
|
|
@param orig_thd The THD object of the calling thread.
|
|
|
|
@return Zero on success, non-zero on failure.
|
|
*/
|
|
int recover_sr_transactions(THD* orig_thd);
|
|
|
|
private:
|
|
/* Non-copyable */
|
|
Wsrep_schema(const Wsrep_schema&);
|
|
Wsrep_schema& operator=(const Wsrep_schema&);
|
|
};
|
|
|
|
extern Wsrep_schema* wsrep_schema;
|
|
|
|
#endif /* !WSREP_SCHEMA_H */
|