mirror of
https://github.com/MariaDB/server.git
synced 2025-10-31 10:56:12 +01:00
dd99780967
PURGE BINARY LOGS did not always purge binary logs. This commit fixes
some of the issues and adds notifications if a binary log cannot be
purged.
User visible changes:
- 'PURGE BINARY LOG TO log_name' and 'PURGE BINARY LOGS BEFORE date'
worked differently. 'TO' ignored 'slave_connections_needed_for_purge'
while 'BEFORE' did not. Now both versions ignores the
'slave_connections_needed_for_purge variable'.
- 'PURGE BINARY LOG..' commands now returns 'note' if a binary log cannot
be deleted like
Note 1375 Binary log 'master-bin.000004' is not purged because it is
the current active binlog
- Automatic binary log purges, based on date or size, will write a
note to the error log if a binary log matching the size or date
cannot yet be deleted.
- If 'slave_connections_needed_for_purge' is set from a config or
command line, it is set to 0 if Galera is enabled and 1 otherwise
(old default). This ensures that automatic binary log purge works
with Galera as before the addition of
'slave_connections_needed_for_purge'.
If the variable is changed to 0, a warning will be printed to the error
log.
Code changes:
- Added THD argument to several purge_logs related functions that needed
THD.
- Added 'interactive' options to purge_logs functions. This allowed
me to remove testing of sql_command == SQLCOM_PURGE.
- Changed purge_logs_before_date() to first check if log is applicable
before calling can_purge_logs(). This ensures we do not get a
notification for logs that does not match the remove criteria.
- MYSQL_BIN_LOG::can_purge_log() will write notifications to the user
or error log if a log cannot yet be removed.
- log_in_use() will return reason why a binary log cannot be removed.
Changes to keep code consistent:
- Moved checking of binlog_format for Galera to be after Galera is
initialized (The old check never worked). If Galera is enabled
we now change the binlog_format to ROW, with a warning, instead of
aborting the server. If this change happens a warning will be printed to
the error log.
- Print a warning if Galera or FLASHBACK changes the binlog_format
to ROW. Before it was done silently.
Reviewed by: Sergei Golubchik <serg@mariadb.com>,
Kristian Nielsen <knielsen@knielsen-hq.org>
80 lines
3 KiB
C
80 lines
3 KiB
C
/* Copyright (c) 2000, 2011, Oracle and/or its affiliates. All rights reserved.
|
|
|
|
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 St, Fifth Floor, Boston, MA 02110-1335 USA */
|
|
|
|
#ifndef SQL_REPL_INCLUDED
|
|
#define SQL_REPL_INCLUDED
|
|
|
|
#include "rpl_filter.h"
|
|
|
|
#ifdef HAVE_REPLICATION
|
|
#include "slave.h"
|
|
|
|
struct slave_connection_state;
|
|
|
|
extern my_bool opt_show_slave_auth_info;
|
|
extern char *master_host, *master_info_file;
|
|
|
|
extern int max_binlog_dump_events;
|
|
extern my_bool opt_sporadic_binlog_dump_fail;
|
|
|
|
int start_slave(THD* thd, Master_info* mi, bool net_report);
|
|
int stop_slave(THD* thd, Master_info* mi, bool net_report);
|
|
bool change_master(THD* thd, Master_info* mi, bool *master_info_added);
|
|
bool mysql_show_binlog_events(THD* thd);
|
|
int reset_slave(THD *thd, Master_info* mi);
|
|
int reset_master(THD* thd, rpl_gtid *init_state, uint32 init_state_len,
|
|
ulong next_log_number);
|
|
bool purge_master_logs(THD* thd, const char* to_log);
|
|
bool purge_master_logs_before_date(THD* thd, time_t purge_time);
|
|
int log_in_use(const char* log_name, uint min_connections);
|
|
void adjust_linfo_offsets(my_off_t purge_offset);
|
|
void show_binlogs_get_fields(THD *thd, List<Item> *field_list);
|
|
bool show_binlogs(THD* thd);
|
|
extern int init_master_info(Master_info* mi);
|
|
bool kill_zombie_dump_threads(THD *thd, uint32 slave_server_id);
|
|
int check_binlog_magic(IO_CACHE* log, const char** errmsg);
|
|
int compare_log_name(const char *log_1, const char *log_2);
|
|
|
|
struct LOAD_FILE_IO_CACHE : public IO_CACHE
|
|
{
|
|
THD* thd;
|
|
my_off_t last_pos_in_file;
|
|
bool wrote_create_file, log_delayed;
|
|
int (*real_read_function)(struct st_io_cache *,uchar *,size_t);
|
|
};
|
|
|
|
int log_loaded_block(IO_CACHE* file, uchar *Buffer, size_t Count);
|
|
int init_replication_sys_vars();
|
|
void mysql_binlog_send(THD* thd, char* log_ident, my_off_t pos, ushort flags);
|
|
|
|
#ifdef HAVE_PSI_INTERFACE
|
|
extern PSI_mutex_key key_LOCK_slave_state, key_LOCK_binlog_state;
|
|
#endif
|
|
void rpl_init_gtid_slave_state();
|
|
void rpl_deinit_gtid_slave_state();
|
|
void rpl_init_gtid_waiting();
|
|
void rpl_deinit_gtid_waiting();
|
|
int gtid_state_from_binlog_pos(const char *name, uint32 pos, String *out_str);
|
|
int rpl_append_gtid_state(String *dest, bool use_binlog);
|
|
int rpl_load_gtid_state(slave_connection_state *state, bool use_binlog);
|
|
bool rpl_gtid_pos_check(THD *thd, char *str, size_t len);
|
|
bool rpl_gtid_pos_update(THD *thd, char *str, size_t len);
|
|
#else
|
|
|
|
struct LOAD_FILE_IO_CACHE : public IO_CACHE { };
|
|
|
|
#endif /* HAVE_REPLICATION */
|
|
|
|
#endif /* SQL_REPL_INCLUDED */
|