mirror of
https://github.com/MariaDB/server.git
synced 2026-10-23 18:49:29 +03:00
d362fdc926
This is phase 2 work to support transactions spilled from binlog cache to innodb. Binlog cache that fills up is spilled into the engine binlog as out-of-band data while the transaction executes, and the spilled data is no longer in the cache. In this commit the spilled data is read back from the engine binlog for the writeset and for streaming replication fragments. Mtr test galera.galera_binlog_in_engine now replicates transactions larger than the binlog cache
119 lines
4.0 KiB
C
119 lines
4.0 KiB
C
/* Copyright (C) 2013 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_BINLOG_H
|
|
#define WSREP_BINLOG_H
|
|
|
|
#include "my_global.h"
|
|
#include "sql_class.h" // THD, IO_CACHE
|
|
|
|
#define HEAP_PAGE_SIZE 65536 /* 64K */
|
|
#define WSREP_MAX_WS_SIZE 2147483647 /* 2GB */
|
|
|
|
/*
|
|
Read the binlog cache contents of thd from log_position to the end of the
|
|
cache, when the binlog is implemented in a storage engine
|
|
(--binlog-storage-engine), including data spilled into the engine binlog.
|
|
The data is passed to the callback in one or more pieces.
|
|
|
|
@return 0 on success, 1 on error
|
|
*/
|
|
int wsrep_read_engine_cache(THD *thd, IO_CACHE *cache, my_off_t log_position,
|
|
bool (*callback)(void *arg, const uchar *data,
|
|
size_t len),
|
|
void *arg);
|
|
|
|
/*
|
|
Write the contents of a cache to a memory buffer.
|
|
|
|
This function quite the same as MYSQL_BIN_LOG::write_cache(),
|
|
with the exception that here we write in buffer instead of log file.
|
|
*/
|
|
int wsrep_write_cache_buf(IO_CACHE *cache, uchar **buf, size_t *buf_len);
|
|
|
|
/*
|
|
Write the contents of a cache to wsrep provider.
|
|
|
|
This function quite the same as MYSQL_BIN_LOG::write_cache(),
|
|
with the exception that here we write in buffer instead of log file.
|
|
|
|
@param log_position position to start writing the cache from
|
|
@param len total amount of data written
|
|
@return wsrep error status
|
|
*/
|
|
int wsrep_write_cache(THD* thd,
|
|
IO_CACHE* cache,
|
|
size_t log_position,
|
|
size_t* len);
|
|
|
|
/* Dump replication buffer to disk */
|
|
void wsrep_dump_rbr_buf(THD *thd, const void* rbr_buf, size_t buf_len);
|
|
|
|
/* Dump replication buffer along with header to a file */
|
|
void wsrep_dump_rbr_buf_with_header(THD *thd, const void *rbr_buf,
|
|
size_t buf_len);
|
|
|
|
/**
|
|
Write a skip event into binlog.
|
|
|
|
@param thd Thread object pointer
|
|
@return Zero in case of success, non-zero on failure.
|
|
*/
|
|
int wsrep_write_skip_event(THD* thd);
|
|
|
|
/*
|
|
Write dummy event into binlog in place of unused GTID.
|
|
The binlog write is done in thd context.
|
|
*/
|
|
int wsrep_write_dummy_event_low(THD *thd, const char *msg);
|
|
/*
|
|
Write dummy event to binlog in place of unused GTID and
|
|
commit. The binlog write and commit are done in temporary
|
|
thd context, the original thd state is not altered.
|
|
*/
|
|
int wsrep_write_dummy_event(THD* thd, const char *msg);
|
|
|
|
void wsrep_register_binlog_handler(THD *thd, bool trx);
|
|
|
|
/**
|
|
Return true if committing THD will write to binlog during commit.
|
|
This is the case for:
|
|
- Local THD, binlog is open
|
|
- Replaying THD, binlog is open
|
|
- Applier THD, log-slave-updates is enabled
|
|
*/
|
|
bool wsrep_commit_will_write_binlog(THD *thd);
|
|
|
|
/**
|
|
Register THD for group commit. The wsrep_trx must be in committing state,
|
|
i.e. the call must be done after wsrep_before_commit() but before
|
|
commit order is released.
|
|
|
|
This call will release commit order critical section if it is
|
|
determined that the commit will go through binlog group commit.
|
|
*/
|
|
void wsrep_register_for_group_commit(THD *thd);
|
|
|
|
/**
|
|
Deregister THD from group commit. The wsrep_trx must be in committing state,
|
|
as for wsrep_register_for_group_commit() above.
|
|
|
|
This call must be used only for THDs which will not go through
|
|
binlog group commit.
|
|
*/
|
|
void wsrep_unregister_from_group_commit(THD *thd);
|
|
|
|
#endif /* WSREP_BINLOG_H */
|