sql/log.cc (2,456 lines of code) (raw):
/* Copyright (c) 2000, 2016, 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-1301 USA */
/**
@file
@brief
logging of commands
@todo
Abort logging when we get an error in reading or writing log files
*/
#include "my_global.h" /* NO_EMBEDDED_ACCESS_CHECKS */
#include "sql_priv.h"
#include "log.h"
#include "sql_base.h" // open_log_table
#include "sql_delete.h" // mysql_truncate
#include "sql_parse.h" // command_name
#include "sql_time.h" // calc_time_from_sec, my_time_compare
#include "tztime.h" // my_tz_OFFSET0, struct Time_zone
#include "sql_acl.h" // SUPER_ACL
#include "sql_audit.h"
#include "mysql/service_my_plugin_log.h"
#include <my_dir.h>
#include <stdarg.h>
#include <m_ctype.h> // For test_if_number
#ifdef _WIN32
#include "message.h"
#endif
using std::min;
using std::max;
/* max size of log messages (error log, plugins' logging, general log) */
#ifndef DBUG_OFF
#define MAX_LOG_BUFFER_SIZE 1024 * 10
#else
#define MAX_LOG_BUFFER_SIZE 1024
#endif
#define MAX_TIME_SIZE 32
static
const TABLE_FIELD_TYPE slow_query_log_table_fields[SQLT_FIELD_COUNT] =
{
{
{ C_STRING_WITH_LEN("start_time") },
{ C_STRING_WITH_LEN("timestamp") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("user_host") },
{ C_STRING_WITH_LEN("mediumtext") },
{ C_STRING_WITH_LEN("utf8") }
},
{
{ C_STRING_WITH_LEN("query_time") },
{ C_STRING_WITH_LEN("time") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("lock_time") },
{ C_STRING_WITH_LEN("time") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("rows_sent") },
{ C_STRING_WITH_LEN("int(11)") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("rows_examined") },
{ C_STRING_WITH_LEN("int(11)") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("db") },
{ C_STRING_WITH_LEN("varchar(512)") },
{ C_STRING_WITH_LEN("utf8") }
},
{
{ C_STRING_WITH_LEN("last_insert_id") },
{ C_STRING_WITH_LEN("int(11)") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("insert_id") },
{ C_STRING_WITH_LEN("int(11)") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("server_id") },
{ C_STRING_WITH_LEN("int(10) unsigned") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("sql_text") },
{ C_STRING_WITH_LEN("mediumtext") },
{ C_STRING_WITH_LEN("utf8") }
},
{
{ C_STRING_WITH_LEN("thread_id") },
{ C_STRING_WITH_LEN("bigint(21) unsigned") },
{ NULL, 0 }
}
};
static const TABLE_FIELD_DEF
slow_query_log_table_def= {SQLT_FIELD_COUNT, slow_query_log_table_fields};
class Slow_query_log_table_intact : public Table_check_intact
{
protected:
void report_error(uint, const char *fmt, ...)
{
va_list args;
va_start(args, fmt);
error_log_print(ERROR_LEVEL, fmt, args);
va_end(args);
}
};
/** In case of an error, a message is printed to the error log. */
static Slow_query_log_table_intact sqlt_intact;
static
const TABLE_FIELD_TYPE general_log_table_fields[GLT_FIELD_COUNT] =
{
{
{ C_STRING_WITH_LEN("event_time") },
{ C_STRING_WITH_LEN("timestamp") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("user_host") },
{ C_STRING_WITH_LEN("mediumtext") },
{ C_STRING_WITH_LEN("utf8") }
},
{
{ C_STRING_WITH_LEN("thread_id") },
{ C_STRING_WITH_LEN("bigint(21) unsigned") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("server_id") },
{ C_STRING_WITH_LEN("int(10) unsigned") },
{ NULL, 0 }
},
{
{ C_STRING_WITH_LEN("command_type") },
{ C_STRING_WITH_LEN("varchar(64)") },
{ C_STRING_WITH_LEN("utf8") }
},
{
{ C_STRING_WITH_LEN("argument") },
{ C_STRING_WITH_LEN("mediumtext") },
{ C_STRING_WITH_LEN("utf8") }
}
};
static const TABLE_FIELD_DEF
general_log_table_def= {GLT_FIELD_COUNT, general_log_table_fields};
class General_log_table_intact : public Table_check_intact
{
protected:
void report_error(uint, const char *fmt, ...)
{
va_list args;
va_start(args, fmt);
error_log_print(ERROR_LEVEL, fmt, args);
va_end(args);
}
};
/** In case of an error, a message is printed to the error log. */
static General_log_table_intact glt_intact;
LOGGER logger;
ulong max_slowlog_size;
ulong max_slowlog_files;
static bool test_if_number(const char *str,
ulong *res, bool allow_wildcards);
/**
purge logs, master and slave sides both, related error code
convertor.
Called from @c purge_error_message(), @c MYSQL_BIN_LOG::reset_logs()
@param res an internal to purging routines error code
@return the user level error code ER_*
*/
uint purge_log_get_error_code(int res)
{
uint errcode= 0;
switch (res) {
case 0: break;
case LOG_INFO_EOF: errcode= ER_UNKNOWN_TARGET_BINLOG; break;
case LOG_INFO_IO: errcode= ER_IO_ERR_LOG_INDEX_READ; break;
case LOG_INFO_INVALID:errcode= ER_BINLOG_PURGE_PROHIBITED; break;
case LOG_INFO_SEEK: errcode= ER_FSEEK_FAIL; break;
case LOG_INFO_MEM: errcode= ER_OUT_OF_RESOURCES; break;
case LOG_INFO_FATAL: errcode= ER_BINLOG_PURGE_FATAL_ERR; break;
case LOG_INFO_IN_USE: errcode= ER_LOG_IN_USE; break;
case LOG_INFO_EMFILE: errcode= ER_BINLOG_PURGE_EMFILE; break;
default: errcode= ER_LOG_PURGE_UNKNOWN_ERR; break;
}
return errcode;
}
/**
Silence all errors and warnings reported when performing a write
to a log table.
Errors and warnings are not reported to the client or SQL exception
handlers, so that the presence of logging does not interfere and affect
the logic of an application.
*/
class Silence_log_table_errors : public Internal_error_handler
{
char m_message[MYSQL_ERRMSG_SIZE];
public:
Silence_log_table_errors()
{
m_message[0]= '\0';
}
virtual ~Silence_log_table_errors() {}
virtual bool handle_condition(THD *thd,
uint sql_errno,
const char* sql_state,
Sql_condition::enum_warning_level level,
const char* msg,
Sql_condition ** cond_hdl);
const char *message() const { return m_message; }
};
bool
Silence_log_table_errors::handle_condition(THD *,
uint,
const char*,
Sql_condition::enum_warning_level,
const char* msg,
Sql_condition ** cond_hdl)
{
*cond_hdl= NULL;
strmake(m_message, msg, sizeof(m_message)-1);
return TRUE;
}
sql_print_message_func sql_print_message_handlers[3] =
{
sql_print_information,
sql_print_warning,
sql_print_error
};
/**
Create the name of the log specified.
This method forms a new path + file name for the
log specified in @c name.
@param[IN] buff Location for building new string.
@param[IN] name Name of the log file.
@param[IN] log_ext The extension for the log (e.g. .log).
@returns Pointer to new string containing the name.
*/
char *make_log_name(char *buff, const char *name, const char* log_ext)
{
strmake(buff, name, FN_REFLEN-5);
return fn_format(buff, buff, mysql_real_data_home, log_ext,
MYF(MY_UNPACK_FILENAME|MY_REPLACE_EXT));
}
bool LOGGER::is_log_table_enabled(uint log_table_type)
{
switch (log_table_type) {
case QUERY_LOG_SLOW:
return (table_log_handler != NULL) && opt_slow_log;
case QUERY_LOG_GENERAL:
return (table_log_handler != NULL) && opt_log ;
default:
DBUG_ASSERT(0);
return FALSE; /* make compiler happy */
}
}
/* Check if a given table is opened log table */
int check_if_log_table(size_t db_len, const char *db, size_t table_name_len,
const char *table_name, bool check_if_opened)
{
if (db_len == 5 &&
!(lower_case_table_names ?
my_strcasecmp(system_charset_info, db, "mysql") :
strcmp(db, "mysql")))
{
if (table_name_len == 11 && !(lower_case_table_names ?
my_strcasecmp(system_charset_info,
table_name, "general_log") :
strcmp(table_name, "general_log")))
{
if (!check_if_opened || logger.is_log_table_enabled(QUERY_LOG_GENERAL))
return QUERY_LOG_GENERAL;
return 0;
}
if (table_name_len == 8 && !(lower_case_table_names ?
my_strcasecmp(system_charset_info, table_name, "slow_log") :
strcmp(table_name, "slow_log")))
{
if (!check_if_opened || logger.is_log_table_enabled(QUERY_LOG_SLOW))
return QUERY_LOG_SLOW;
return 0;
}
}
return 0;
}
Log_to_csv_event_handler::Log_to_csv_event_handler()
{
}
Log_to_csv_event_handler::~Log_to_csv_event_handler()
{
}
void Log_to_csv_event_handler::cleanup()
{
logger.is_log_tables_initialized= FALSE;
}
/* log event handlers */
/**
Log command to the general log table
Log given command to the general log table.
@param event_time command start timestamp
@param user_host the pointer to the string with user@host info
@param user_host_len length of the user_host string. this is computed
once and passed to all general log event handlers
@param thread_id Id of the thread, issued a query
@param command_type the type of the command being logged
@param command_type_len the length of the string above
@param sql_text the very text of the query being executed
@param sql_text_len the length of sql_text string
@return This function attempts to never call my_error(). This is
necessary, because general logging happens already after a statement
status has been sent to the client, so the client can not see the
error anyway. Besides, the error is not related to the statement
being executed and is internal, and thus should be handled
internally (@todo: how?).
If a write to the table has failed, the function attempts to
write to a short error message to the file. The failure is also
indicated in the return value.
@retval FALSE OK
@retval TRUE error occured
*/
bool Log_to_csv_event_handler::
log_general(THD *thd, time_t event_time, const char *user_host,
uint user_host_len, my_thread_id thread_id,
const char *command_type, uint command_type_len,
const char *sql_text, uint sql_text_len,
const CHARSET_INFO *client_cs)
{
TABLE_LIST table_list;
TABLE *table;
bool result= TRUE;
bool need_close= FALSE;
bool need_pop= FALSE;
bool need_rnd_end= FALSE;
uint field_index;
Silence_log_table_errors error_handler;
Open_tables_backup open_tables_backup;
ulonglong save_thd_options;
bool save_time_zone_used;
/*
CSV uses TIME_to_timestamp() internally if table needs to be repaired
which will set thd->time_zone_used
*/
save_time_zone_used= thd->time_zone_used;
save_thd_options= thd->variables.option_bits;
thd->variables.option_bits&= ~OPTION_BIN_LOG;
table_list.init_one_table(MYSQL_SCHEMA_NAME.str, MYSQL_SCHEMA_NAME.length,
GENERAL_LOG_NAME.str, GENERAL_LOG_NAME.length,
GENERAL_LOG_NAME.str,
TL_WRITE_CONCURRENT_INSERT);
/*
1) open_log_table generates an error if the
table can not be opened or is corrupted.
2) "INSERT INTO general_log" can generate warning sometimes.
Suppress these warnings and errors, they can't be dealt with
properly anyway.
QQ: this problem needs to be studied in more detail.
Comment this 2 lines and run "cast.test" to see what's happening.
*/
thd->push_internal_handler(& error_handler);
need_pop= TRUE;
if (!(table= open_log_table(thd, &table_list, &open_tables_backup)))
goto err;
need_close= TRUE;
if (glt_intact.check(table_list.table, &general_log_table_def))
goto err;
if (table->file->extra(HA_EXTRA_MARK_AS_LOG_TABLE) ||
table->file->ha_rnd_init(0))
goto err;
need_rnd_end= TRUE;
/* Honor next number columns if present */
table->next_number_field= table->found_next_number_field;
/*
NOTE: we do not call restore_record() here, as all fields are
filled by the Logger (=> no need to load default ones).
*/
/*
We do not set a value for table->field[0], as it will use
default value (which is CURRENT_TIMESTAMP).
*/
/* check that all columns exist */
if (table->s->fields < 6)
goto err;
DBUG_ASSERT(table->field[GLT_FIELD_EVENT_TIME]->type() == MYSQL_TYPE_TIMESTAMP);
table->field[GLT_FIELD_EVENT_TIME]->store_timestamp(event_time);
/* do a write */
if (table->field[GLT_FIELD_USER_HOST]->store(user_host, user_host_len,
client_cs) ||
table->field[GLT_FIELD_THREAD_ID]->store((longlong) thread_id, TRUE) ||
table->field[GLT_FIELD_SERVER_ID]->store((longlong) server_id, TRUE) ||
table->field[GLT_FIELD_COMMAND_TYPE]->store(command_type,
command_type_len, client_cs))
goto err;
/*
A positive return value in store() means truncation.
Still logging a message in the log in this case.
*/
table->field[GLT_FIELD_ARGUMENT]->flags|= FIELDFLAG_HEX_ESCAPE;
if (table->field[GLT_FIELD_ARGUMENT]->store(sql_text, sql_text_len,
client_cs) < 0)
goto err;
/* mark all fields as not null */
table->field[GLT_FIELD_USER_HOST]->set_notnull();
table->field[GLT_FIELD_THREAD_ID]->set_notnull();
table->field[GLT_FIELD_SERVER_ID]->set_notnull();
table->field[GLT_FIELD_COMMAND_TYPE]->set_notnull();
table->field[GLT_FIELD_ARGUMENT]->set_notnull();
/* Set any extra columns to their default values */
for (field_index= GLT_FIELD_COUNT ;
field_index < table->s->fields ;
field_index++)
{
table->field[field_index]->set_default();
}
/* log table entries are not replicated */
if (table->file->ha_write_row(table->record[0]))
goto err;
result= FALSE;
err:
if (result && !thd->killed &&
(command_type_len != 4 || strcmp(command_type, "Quit") != 0)) {
/* Don't generate the error if the current thd or its attached session
* (if any) has been killed. */
auto srv_session = thd->get_attached_srv_session();
if (!srv_session || !srv_session->get_thd()->killed) {
/* NO_LINT_DEBUG */
sql_print_error("Failed to write to mysql.general_log: %s",
error_handler.message());
}
}
if (need_rnd_end)
{
table->file->ha_rnd_end();
table->file->ha_release_auto_increment();
}
if (need_pop)
thd->pop_internal_handler();
if (need_close)
close_log_table(thd, &open_tables_backup);
thd->variables.option_bits= save_thd_options;
thd->time_zone_used= save_time_zone_used;
return result;
}
/*
Log a query to the slow log table
SYNOPSIS
log_slow()
thd THD of the query
current_time current timestamp
query_start_arg command start timestamp
user_host the pointer to the string with user@host info
user_host_len length of the user_host string. this is computed once
and passed to all general log event handlers
query_time Amount of time the query took to execute (in microseconds)
lock_time Amount of time the query was locked (in microseconds)
is_command The flag, which determines, whether the sql_text is a
query or an administrator command (these are treated
differently by the old logging routines)
sql_text the very text of the query or administrator command
processed
sql_text_len the length of sql_text string
DESCRIPTION
Log a query to the slow log table
RETURN
FALSE - OK
TRUE - error occured
*/
bool Log_to_csv_event_handler::
log_slow(THD *thd, time_t current_time, time_t query_start_arg,
const char *user_host, uint user_host_len,
ulonglong query_utime, ulonglong lock_utime, bool is_command,
const char *sql_text, uint sql_text_len,
struct system_status_var *query_start_status)
{
TABLE_LIST table_list;
TABLE *table;
bool result= TRUE;
bool need_close= FALSE;
bool need_rnd_end= FALSE;
Silence_log_table_errors error_handler;
Open_tables_backup open_tables_backup;
const CHARSET_INFO *client_cs= thd->variables.character_set_client;
bool save_time_zone_used;
DBUG_ENTER("Log_to_csv_event_handler::log_slow");
thd->push_internal_handler(& error_handler);
/*
CSV uses TIME_to_timestamp() internally if table needs to be repaired
which will set thd->time_zone_used
*/
save_time_zone_used= thd->time_zone_used;
table_list.init_one_table(MYSQL_SCHEMA_NAME.str, MYSQL_SCHEMA_NAME.length,
SLOW_LOG_NAME.str, SLOW_LOG_NAME.length,
SLOW_LOG_NAME.str,
TL_WRITE_CONCURRENT_INSERT);
if (!(table= open_log_table(thd, &table_list, &open_tables_backup)))
goto err;
need_close= TRUE;
if (sqlt_intact.check(table_list.table, &slow_query_log_table_def))
goto err;
if (table->file->extra(HA_EXTRA_MARK_AS_LOG_TABLE) ||
table->file->ha_rnd_init(0))
goto err;
need_rnd_end= TRUE;
/* Honor next number columns if present */
table->next_number_field= table->found_next_number_field;
restore_record(table, s->default_values); // Get empty record
/* store the time and user values */
DBUG_ASSERT(table->field[SQLT_FIELD_START_TIME]->type() == MYSQL_TYPE_TIMESTAMP);
table->field[SQLT_FIELD_START_TIME]->store_timestamp(current_time);
if (table->field[SQLT_FIELD_USER_HOST]->store(user_host, user_host_len,
client_cs))
goto err;
if (query_start_arg)
{
longlong query_time= (longlong) (query_utime/1000000);
longlong lock_time= (longlong) (lock_utime/1000000);
/*
A TIME field can not hold the full longlong range; query_time or
lock_time may be truncated without warning here, if greater than
839 hours (~35 days)
*/
MYSQL_TIME t;
t.neg= 0;
/* fill in query_time field */
calc_time_from_sec(&t, min<long>(query_time, (longlong) TIME_MAX_VALUE_SECONDS), 0);
if (table->field[SQLT_FIELD_QUERY_TIME]->store_time(&t))
goto err;
/* lock_time */
calc_time_from_sec(&t, min<long>(lock_time, (longlong) TIME_MAX_VALUE_SECONDS), 0);
if (table->field[SQLT_FIELD_LOCK_TIME]->store_time(&t))
goto err;
/* rows_sent */
if (table->field[SQLT_FIELD_ROWS_SENT]->store((longlong) thd->get_sent_row_count(), TRUE))
goto err;
/* rows_examined */
if (table->field[SQLT_FIELD_ROWS_EXAMINED]->store((longlong) thd->get_examined_row_count(), TRUE))
goto err;
}
else
{
table->field[SQLT_FIELD_QUERY_TIME]->set_null();
table->field[SQLT_FIELD_LOCK_TIME]->set_null();
table->field[SQLT_FIELD_ROWS_SENT]->set_null();
table->field[SQLT_FIELD_ROWS_EXAMINED]->set_null();
}
/* fill database field */
if (thd->db)
{
if (table->field[SQLT_FIELD_DATABASE]->store(thd->db, thd->db_length,
client_cs))
goto err;
table->field[SQLT_FIELD_DATABASE]->set_notnull();
}
if (thd->stmt_depends_on_first_successful_insert_id_in_prev_stmt)
{
if (table->
field[SQLT_FIELD_LAST_INSERT_ID]->store((longlong)
thd->first_successful_insert_id_in_prev_stmt_for_binlog,
TRUE))
goto err;
table->field[SQLT_FIELD_LAST_INSERT_ID]->set_notnull();
}
/*
Set value if we do an insert on autoincrement column. Note that for
some engines (those for which get_auto_increment() does not leave a
table lock until the statement ends), this is just the first value and
the next ones used may not be contiguous to it.
*/
if (thd->auto_inc_intervals_in_cur_stmt_for_binlog.nb_elements() > 0)
{
if (table->
field[SQLT_FIELD_INSERT_ID]->store((longlong)
thd->auto_inc_intervals_in_cur_stmt_for_binlog.minimum(), TRUE))
goto err;
table->field[SQLT_FIELD_INSERT_ID]->set_notnull();
}
if (table->field[SQLT_FIELD_SERVER_ID]->store((longlong) server_id, TRUE))
goto err;
table->field[SQLT_FIELD_SERVER_ID]->set_notnull();
/*
Column sql_text.
A positive return value in store() means truncation.
Still logging a message in the log in this case.
*/
if (table->field[SQLT_FIELD_SQL_TEXT]->store(sql_text, sql_text_len,
client_cs) < 0)
goto err;
if (table->field[SQLT_FIELD_THREAD_ID]->store((longlong) thd->thread_id(),
TRUE))
goto err;
/* log table entries are not replicated */
if (table->file->ha_write_row(table->record[0]))
goto err;
result= FALSE;
err:
thd->pop_internal_handler();
if (result && !thd->killed)
sql_print_error("Failed to write to mysql.slow_log: %s",
error_handler.message());
if (need_rnd_end)
{
table->file->ha_rnd_end();
table->file->ha_release_auto_increment();
}
if (need_close)
close_log_table(thd, &open_tables_backup);
thd->time_zone_used= save_time_zone_used;
DBUG_RETURN(result);
}
int Log_to_csv_event_handler::
activate_log(THD *thd, uint log_table_type)
{
TABLE_LIST table_list;
TABLE *table;
LEX_STRING *UNINIT_VAR(log_name);
int result;
Open_tables_backup open_tables_backup;
DBUG_ENTER("Log_to_csv_event_handler::activate_log");
if (log_table_type == QUERY_LOG_GENERAL)
{
log_name= &GENERAL_LOG_NAME;
}
else
{
DBUG_ASSERT(log_table_type == QUERY_LOG_SLOW);
log_name= &SLOW_LOG_NAME;
}
table_list.init_one_table(MYSQL_SCHEMA_NAME.str, MYSQL_SCHEMA_NAME.length,
log_name->str, log_name->length, log_name->str,
TL_WRITE_CONCURRENT_INSERT);
table= open_log_table(thd, &table_list, &open_tables_backup);
if (table)
{
result= 0;
close_log_table(thd, &open_tables_backup);
}
else
result= 1;
DBUG_RETURN(result);
}
bool Log_to_csv_event_handler::
log_error(enum loglevel level, const char *format, va_list args)
{
/* No log table is implemented */
DBUG_ASSERT(0);
return FALSE;
}
bool Log_to_file_event_handler::
log_error(enum loglevel level, const char *format,
va_list args)
{
return vprint_msg_to_log(level, format, args);
}
void Log_to_file_event_handler::init_pthread_objects()
{
mysql_log.init_pthread_objects();
mysql_slow_log.init_pthread_objects();
mysql_gap_lock_log.init_pthread_objects();
}
/** Wrapper around MYSQL_LOG::write() for slow log. */
bool Log_to_file_event_handler::
log_slow(THD *thd, time_t current_time, time_t query_start_arg,
const char *user_host, uint user_host_len,
ulonglong query_utime, ulonglong lock_utime, bool is_command,
const char *sql_text, uint sql_text_len,
struct system_status_var *query_start_status)
{
Silence_log_table_errors error_handler;
thd->push_internal_handler(&error_handler);
bool retval= mysql_slow_log.write(thd, current_time, query_start_arg,
user_host, user_host_len,
query_utime, lock_utime, is_command,
sql_text, sql_text_len,
query_start_status);
thd->pop_internal_handler();
return retval;
}
/**
Wrapper around MYSQL_LOG::write() for general log. We need it since we
want all log event handlers to have the same signature.
*/
bool Log_to_file_event_handler::
log_general(THD *thd, time_t event_time, const char *user_host,
uint user_host_len, my_thread_id thread_id,
const char *command_type, uint command_type_len,
const char *sql_text, uint sql_text_len,
const CHARSET_INFO *client_cs)
{
Silence_log_table_errors error_handler;
thd->push_internal_handler(&error_handler);
bool retval= mysql_log.write(event_time, user_host, user_host_len,
thread_id, command_type, command_type_len,
sql_text, sql_text_len);
thd->pop_internal_handler();
return retval;
}
bool Log_to_file_event_handler::
log_gap_lock(THD *thd, time_t event_time, const char *user_host,
uint user_host_len, my_thread_id thread_id,
const char *command_type, uint command_type_len,
const char *sql_text, uint sql_text_len)
{
bool retval= mysql_gap_lock_log.write(event_time, user_host, user_host_len,
thread_id, command_type,
command_type_len,
sql_text, sql_text_len);
return retval;
}
bool Log_to_file_event_handler::init()
{
if (!is_initialized)
{
if (opt_slow_log)
mysql_slow_log.open_slow_log(opt_slow_logname);
if (opt_log)
mysql_log.open_query_log(opt_logname);
mysql_gap_lock_log.open_gap_lock_log(opt_gap_lock_logname);
is_initialized= TRUE;
}
return FALSE;
}
void Log_to_file_event_handler::cleanup()
{
mysql_log.cleanup();
mysql_slow_log.cleanup();
mysql_gap_lock_log.cleanup();
}
void Log_to_file_event_handler::flush()
{
/* reopen log files */
if (opt_log)
mysql_log.reopen_file();
if (opt_slow_log)
mysql_slow_log.reopen_file();
mysql_gap_lock_log.reopen_file();
}
bool Log_to_csv_event_handler::
log_gap_lock(THD *thd, time_t event_time, const char *user_host,
uint user_host_len, my_thread_id thread_id,
const char *command_type, uint command_type_len,
const char *sql_text, uint sql_text_len)
{
/* No log table is implemented */
DBUG_ASSERT(0);
return FALSE;
}
/*
Log error with all enabled log event handlers
SYNOPSIS
error_log_print()
level The level of the error significance: NOTE,
WARNING or ERROR.
format format string for the error message
args list of arguments for the format string
RETURN
FALSE - OK
TRUE - error occured
*/
bool LOGGER::error_log_print(enum loglevel level, const char *format,
va_list args)
{
bool error= FALSE;
Log_event_handler **current_handler;
/* currently we don't need locking here as there is no error_log table */
for (current_handler= error_log_handler_list ; *current_handler ;)
error= (*current_handler++)->log_error(level, format, args) || error;
return error;
}
void LOGGER::cleanup_base()
{
DBUG_ASSERT(inited == 1);
mysql_rwlock_destroy(&LOCK_logger);
if (table_log_handler)
{
table_log_handler->cleanup();
delete table_log_handler;
table_log_handler= NULL;
}
if (file_log_handler)
file_log_handler->cleanup();
}
void LOGGER::cleanup_end()
{
DBUG_ASSERT(inited == 1);
if (file_log_handler)
{
delete file_log_handler;
file_log_handler=NULL;
}
inited= 0;
}
/**
Perform basic log initialization: create file-based log handler and
init error log.
*/
void LOGGER::init_base()
{
DBUG_ASSERT(inited == 0);
inited= 1;
/*
Here we create file log handler. We don't do it for the table log handler
here as it cannot be created so early. The reason is THD initialization,
which depends on the system variables (parsed later).
*/
if (!file_log_handler)
file_log_handler= new Log_to_file_event_handler;
/* by default we use traditional error log */
init_error_log(LOG_FILE);
file_log_handler->init_pthread_objects();
mysql_rwlock_init(key_rwlock_LOCK_logger, &LOCK_logger);
}
void LOGGER::init_log_tables()
{
if (!table_log_handler)
table_log_handler= new Log_to_csv_event_handler;
if (!is_log_tables_initialized &&
!table_log_handler->init() && !file_log_handler->init())
is_log_tables_initialized= TRUE;
}
bool LOGGER::flush_logs(THD *thd)
{
int rc= 0;
/*
Now we lock logger, as nobody should be able to use logging routines while
log tables are closed
*/
logger.lock_exclusive();
/* reopen log files */
file_log_handler->flush();
/* end of log flush */
logger.unlock();
return rc;
}
/**
Close and reopen the slow log (with locks).
@returns FALSE.
*/
bool LOGGER::flush_slow_log()
{
/*
Now we lock logger, as nobody should be able to use logging routines while
log tables are closed
*/
logger.lock_exclusive();
/* Reopen slow log file */
if (opt_slow_log)
file_log_handler->get_mysql_slow_log()->reopen_file();
/* End of log flush */
logger.unlock();
return 0;
}
/**
Close and reopen the general log (with locks).
@returns FALSE.
*/
bool LOGGER::flush_general_log()
{
/*
Now we lock logger, as nobody should be able to use logging routines while
log tables are closed
*/
logger.lock_exclusive();
/* Reopen general log file */
if (opt_log)
file_log_handler->get_mysql_log()->reopen_file();
/* End of log flush */
logger.unlock();
return 0;
}
bool LOGGER::flush_gap_lock_log()
{
logger.lock_exclusive();
file_log_handler->get_mysql_gap_lock_log()->reopen_file();
logger.unlock();
return 0;
}
/*
Log slow query with all enabled log event handlers
SYNOPSIS
slow_log_print()
thd THD of the query being logged
query The query being logged
query_length The length of the query string
RETURN
FALSE OK
TRUE error occured
*/
bool LOGGER::slow_log_print(THD *thd, const char *query, uint query_length,
struct system_status_var *query_start_status)
{
bool error= FALSE;
Log_event_handler **current_handler;
bool is_command= FALSE;
char user_host_buff[MAX_USER_HOST_SIZE + 1];
Security_context *sctx= thd->security_ctx;
uint user_host_len= 0;
ulonglong query_utime, lock_utime, current_utime;
DBUG_ASSERT(thd->enable_slow_log);
/*
Print the message to the buffer if we have slow log enabled
*/
if (*slow_log_handler_list)
{
time_t current_time;
/* do not log slow queries from replication threads */
if (thd->slave_thread && !opt_log_slow_slave_statements)
return 0;
lock_shared();
if (!opt_slow_log)
{
unlock();
return 0;
}
/* fill in user_host value: the format is "%s[%s] @ %s [%s]" */
user_host_len= (strxnmov(user_host_buff, MAX_USER_HOST_SIZE,
sctx->priv_user, "[",
sctx->user ? sctx->user : "", "] @ ",
sctx->get_host()->length() ?
sctx->get_host()->ptr() : "", " [",
sctx->get_ip()->length() ? sctx->get_ip()->ptr() :
"", "]", NullS) - user_host_buff);
current_utime= thd->current_utime();
current_time= my_time_possible_from_micro(current_utime);
if (thd->start_utime)
{
query_utime= (current_utime - thd->start_utime);
lock_utime= (thd->utime_after_lock - thd->start_utime);
}
else
{
query_utime= lock_utime= 0;
}
if (!query)
{
is_command= TRUE;
query= command_name[thd->get_command()].str;
query_length= command_name[thd->get_command()].length;
}
for (current_handler= slow_log_handler_list; *current_handler ;)
error= (*current_handler++)->log_slow(thd, current_time,
thd->start_time.tv_sec,
user_host_buff, user_host_len,
query_utime, lock_utime, is_command,
query, query_length,
query_start_status) || error;
unlock();
}
return error;
}
bool LOGGER::general_log_write(THD *thd, enum enum_server_command command,
const char *query, uint query_length)
{
bool error= FALSE;
Log_event_handler **current_handler= general_log_handler_list;
char user_host_buff[MAX_USER_HOST_SIZE + 1];
uint user_host_len= 0;
time_t current_time;
DBUG_ASSERT(thd);
lock_shared();
if (!opt_log)
{
unlock();
return 0;
}
user_host_len= make_user_name(thd, user_host_buff);
current_time= my_time(0);
while (*current_handler)
error|= (*current_handler++)->
log_general(thd, current_time, user_host_buff,
user_host_len, thd->thread_id(),
command_name[(uint) command].str,
command_name[(uint) command].length,
query, query_length,
thd->variables.character_set_client) || error;
unlock();
return error;
}
bool LOGGER::gap_lock_log_write(THD *thd, enum enum_server_command command,
const char *query, uint query_length)
{
bool error= FALSE;
Log_event_handler **current_handler= gap_lock_log_handler_list;
char user_host_buff[MAX_USER_HOST_SIZE + 1];
uint user_host_len= 0;
time_t current_time;
DBUG_ASSERT(thd);
lock_shared();
user_host_len= make_user_name(thd, user_host_buff);
current_time= my_time(0);
while (*current_handler)
error|= (*current_handler++)->
log_gap_lock(thd, current_time, user_host_buff,
user_host_len, thd->thread_id(),
command_name[(uint) command].str,
command_name[(uint) command].length,
query, query_length) || error;
unlock();
return error;
}
void LOGGER::init_error_log(uint error_log_printer)
{
if (error_log_printer & LOG_NONE)
{
error_log_handler_list[0]= 0;
return;
}
switch (error_log_printer) {
case LOG_FILE:
error_log_handler_list[0]= file_log_handler;
error_log_handler_list[1]= 0;
break;
/* these two are disabled for now */
case LOG_TABLE:
DBUG_ASSERT(0);
break;
case LOG_TABLE|LOG_FILE:
DBUG_ASSERT(0);
break;
}
}
void LOGGER::init_slow_log(uint slow_log_printer)
{
if (slow_log_printer & LOG_NONE)
{
slow_log_handler_list[0]= 0;
return;
}
switch (slow_log_printer) {
case LOG_FILE:
slow_log_handler_list[0]= file_log_handler;
slow_log_handler_list[1]= 0;
break;
case LOG_TABLE:
slow_log_handler_list[0]= table_log_handler;
slow_log_handler_list[1]= 0;
break;
case LOG_TABLE|LOG_FILE:
slow_log_handler_list[0]= file_log_handler;
slow_log_handler_list[1]= table_log_handler;
slow_log_handler_list[2]= 0;
break;
}
}
void LOGGER::init_general_log(uint general_log_printer)
{
if (general_log_printer & LOG_NONE)
{
general_log_handler_list[0]= 0;
return;
}
switch (general_log_printer) {
case LOG_FILE:
general_log_handler_list[0]= file_log_handler;
general_log_handler_list[1]= 0;
break;
case LOG_TABLE:
general_log_handler_list[0]= table_log_handler;
general_log_handler_list[1]= 0;
break;
case LOG_TABLE|LOG_FILE:
general_log_handler_list[0]= file_log_handler;
general_log_handler_list[1]= table_log_handler;
general_log_handler_list[2]= 0;
break;
}
}
void LOGGER::init_gap_lock_log(uint gap_lock_log_printer)
{
if (gap_lock_log_printer & LOG_NONE)
{
gap_lock_log_handler_list[0]= 0;
return;
}
switch (gap_lock_log_printer) {
case LOG_FILE:
gap_lock_log_handler_list[0]= file_log_handler;
gap_lock_log_handler_list[1]= 0;
break;
/* these two are disabled for now */
case LOG_TABLE:
DBUG_ASSERT(0);
break;
case LOG_TABLE|LOG_FILE:
DBUG_ASSERT(0);
break;
}
}
bool LOGGER::activate_log_handler(THD* thd, uint log_type)
{
MYSQL_QUERY_LOG *file_log;
bool res= FALSE;
lock_exclusive();
switch (log_type) {
case QUERY_LOG_SLOW:
if (!opt_slow_log)
{
file_log= file_log_handler->get_mysql_slow_log();
file_log->open_slow_log(opt_slow_logname);
if (table_log_handler->activate_log(thd, QUERY_LOG_SLOW))
{
/* Error printed by open table in activate_log() */
res= TRUE;
file_log->close(0);
}
else
{
init_slow_log(log_output_options);
opt_slow_log= TRUE;
}
}
break;
case QUERY_LOG_GENERAL:
if (!opt_log)
{
file_log= file_log_handler->get_mysql_log();
file_log->open_query_log(opt_logname);
if (table_log_handler->activate_log(thd, QUERY_LOG_GENERAL))
{
/* Error printed by open table in activate_log() */
res= TRUE;
file_log->close(0);
}
else
{
init_general_log(log_output_options);
opt_log= TRUE;
}
}
break;
default:
DBUG_ASSERT(0);
}
unlock();
return res;
}
void LOGGER::deactivate_log_handler(THD *thd, uint log_type)
{
my_bool *tmp_opt= 0;
MYSQL_LOG *file_log= NULL;
switch (log_type) {
case QUERY_LOG_SLOW:
tmp_opt= &opt_slow_log;
file_log= file_log_handler->get_mysql_slow_log();
break;
case QUERY_LOG_GENERAL:
tmp_opt= &opt_log;
file_log= file_log_handler->get_mysql_log();
break;
default:
MY_ASSERT_UNREACHABLE();
}
if (!(*tmp_opt))
return;
lock_exclusive();
file_log->close(0);
*tmp_opt= FALSE;
unlock();
}
/* the parameters are unused for the log tables */
bool Log_to_csv_event_handler::init()
{
return 0;
}
int LOGGER::set_handlers(uint error_log_printer,
uint slow_log_printer,
uint general_log_printer,
uint gap_lock_log_printer)
{
/* error log table is not supported yet */
DBUG_ASSERT(error_log_printer < LOG_TABLE);
lock_exclusive();
if ((slow_log_printer & LOG_TABLE || general_log_printer & LOG_TABLE) &&
!is_log_tables_initialized)
{
slow_log_printer= (slow_log_printer & ~LOG_TABLE) | LOG_FILE;
general_log_printer= (general_log_printer & ~LOG_TABLE) | LOG_FILE;
sql_print_error("Failed to initialize log tables. "
"Falling back to the old-fashioned logs");
}
init_error_log(error_log_printer);
init_slow_log(slow_log_printer);
init_general_log(general_log_printer);
init_gap_lock_log(gap_lock_log_printer);
unlock();
return 0;
}
#ifdef _WIN32
static int eventSource = 0;
static void setup_windows_event_source()
{
HKEY hRegKey= NULL;
DWORD dwError= 0;
TCHAR szPath[MAX_PATH];
DWORD dwTypes;
if (eventSource) // Ensure that we are only called once
return;
eventSource= 1;
// Create the event source registry key
dwError= RegCreateKey(HKEY_LOCAL_MACHINE,
"SYSTEM\\CurrentControlSet\\Services\\EventLog\\Application\\MySQL",
&hRegKey);
/* Name of the PE module that contains the message resource */
GetModuleFileName(NULL, szPath, MAX_PATH);
/* Register EventMessageFile */
dwError = RegSetValueEx(hRegKey, "EventMessageFile", 0, REG_EXPAND_SZ,
(PBYTE) szPath, (DWORD) (strlen(szPath) + 1));
/* Register supported event types */
dwTypes= (EVENTLOG_ERROR_TYPE | EVENTLOG_WARNING_TYPE |
EVENTLOG_INFORMATION_TYPE);
dwError= RegSetValueEx(hRegKey, "TypesSupported", 0, REG_DWORD,
(LPBYTE) &dwTypes, sizeof dwTypes);
RegCloseKey(hRegKey);
}
#endif /* _WIN32 */
/**
Find a unique filename for 'filename.#'.
Set '#' to the number next to the maximum found in the most
recent log file extension.
This function will return nonzero if: (i) the generated name
exceeds FN_REFLEN; (ii) if the number of extensions is exhausted;
or (iii) some other error happened while examining the filesystem.
@return
nonzero if not possible to get unique filename.
*/
static int find_uniq_filename(char *name, ulong *next, bool need_next)
{
uint i;
char buff[FN_REFLEN], ext_buf[FN_REFLEN];
struct st_my_dir *dir_info;
reg1 struct fileinfo *file_info;
ulong max_found= 0, number= 0;
size_t buf_length, length;
char *start, *end;
int error= 0;
DBUG_ENTER("find_uniq_filename");
length= dirname_part(buff, name, &buf_length);
start= name + length;
end= strend(start);
*end='.';
length= (size_t) (end - start + 1);
if ((DBUG_EVALUATE_IF("error_unique_log_filename", 1,
!(dir_info= my_dir(buff,MYF(MY_DONT_SORT))))))
{ // This shouldn't happen
strmov(end,".1"); // use name+1
DBUG_RETURN(1);
}
file_info= dir_info->dir_entry;
for (i= dir_info->number_off_files ; i-- ; file_info++)
{
if (strncmp(file_info->name, start, length) == 0 &&
test_if_number(file_info->name+length, &number,0))
{
set_if_bigger(max_found,(ulong) number);
}
}
my_dirend(dir_info);
/* check if reached the maximum possible extension number */
if (max_found == MAX_LOG_UNIQUE_FN_EXT)
{
sql_print_error("Log filename extension number exhausted: %06lu. \
Please fix this by archiving old logs and \
updating the index files.", max_found);
error= 1;
goto end;
}
*next= (need_next || max_found == 0) ? max_found + 1 : max_found;
if (sprintf(ext_buf, "%06lu", *next)<0)
{
error= 1;
goto end;
}
*end++='.';
/*
Check if the generated extension size + the file name exceeds the
buffer size used. If one did not check this, then the filename might be
truncated, resulting in error.
*/
if (((strlen(ext_buf) + (end - name)) >= FN_REFLEN))
{
sql_print_error("Log filename too large: %s%s (%zu). \
Please fix this by archiving old logs and updating the \
index files.", name, ext_buf, (strlen(ext_buf) + (end - name)));
error= 1;
goto end;
}
if (sprintf(end, "%06lu", *next)<0)
{
error= 1;
goto end;
}
/* print warning if reaching the end of available extensions. */
if ((*next > (MAX_LOG_UNIQUE_FN_EXT - LOG_WARN_UNIQUE_FN_EXT_LEFT)))
sql_print_warning("Next log extension: %lu. \
Remaining log filename extensions: %lu. \
Please consider archiving some logs.", *next, (MAX_LOG_UNIQUE_FN_EXT - *next));
end:
DBUG_RETURN(error);
}
void MYSQL_LOG::init(enum_log_type log_type_arg,
enum cache_type io_cache_type_arg)
{
DBUG_ENTER("MYSQL_LOG::init");
log_type= log_type_arg;
io_cache_type= io_cache_type_arg;
DBUG_PRINT("info",("log_type: %d", log_type));
DBUG_VOID_RETURN;
}
bool MYSQL_LOG::init_and_set_log_file_name(const char *log_name,
const char *new_name,
enum_log_type log_type_arg,
enum cache_type io_cache_type_arg)
{
init(log_type_arg, io_cache_type_arg);
if (new_name && !strmov(log_file_name, new_name))
return TRUE;
else if (!new_name && generate_new_name(log_file_name, log_name))
return TRUE;
return FALSE;
}
bool is_valid_log_name(const char *name, size_t len)
{
if (len > 3)
{
const char *tail= name + len - 4;
if (my_strcasecmp(system_charset_info, tail, ".ini") == 0 ||
my_strcasecmp(system_charset_info, tail, ".cnf") == 0)
{
return false;
}
}
return true;
}
/**
Get the real log file name, and possibly reopen file.
Use realpath() to get the path with symbolic links
expanded. Then, close the file, and reopen the real path using the
O_NOFOLLOW flag. This will reject following symbolic links.
@param file File descriptor.
@param log_file_key Key for P_S instrumentation.
@param open_flags Flags to use for opening the file.
@param opened_file_name Name of the open fd.
@retval file descriptor to open file with 'real_file_name', or '-1'
in case of errors.
*/
#ifndef _WIN32
static File mysql_file_real_name_reopen(File file,
#ifdef HAVE_PSI_INTERFACE
PSI_file_key log_file_key,
#endif
int open_flags,
const char *opened_file_name)
{
DBUG_ASSERT(file);
DBUG_ASSERT(opened_file_name);
/* Buffer for realpath must have capacity for PATH_MAX. */
char real_file_name[PATH_MAX];
/* Get realpath, validate, open realpath with O_NOFOLLOW. */
if (realpath(opened_file_name, real_file_name) == NULL)
{
(void) mysql_file_close(file, MYF(0));
return -1;
}
if (mysql_file_close(file, MYF(0)))
return -1;
if (strlen(real_file_name) > FN_REFLEN)
return -1;
if (!is_valid_log_name(real_file_name, strlen(real_file_name)))
{
sql_print_error("Invalid log file name after expanding symlinks: '%s'",
real_file_name);
return -1;
}
return mysql_file_open(log_file_key, real_file_name,
open_flags | O_NOFOLLOW,
MYF(MY_WME | ME_WAITTANG));
}
#endif // _WIN32
/*
Open a (new) log file.
SYNOPSIS
open()
log_name The name of the log to open
log_type_arg The type of the log. E.g. LOG_NORMAL
new_name The new name for the logfile. This is only needed
when the method is used to open the binlog file.
io_cache_type_arg The type of the IO_CACHE to use for this log file
DESCRIPTION
Open the logfile, init IO_CACHE and write startup messages
(in case of general and slow query logs).
RETURN VALUES
0 ok
1 error
*/
bool MYSQL_LOG::open(
#ifdef HAVE_PSI_INTERFACE
PSI_file_key log_file_key,
#endif
const char *log_name, enum_log_type log_type_arg,
const char *new_name, enum cache_type io_cache_type_arg)
{
char buff[FN_REFLEN];
MY_STAT f_stat;
File file= -1;
my_off_t pos= 0;
int open_flags= O_CREAT | O_BINARY;
DBUG_ENTER("MYSQL_LOG::open");
DBUG_PRINT("enter", ("log_type: %d", (int) log_type_arg));
write_error= 0;
if (!(name= my_strdup(log_name, MYF(MY_WME))))
{
name= (char *)log_name; // for the error message
goto err;
}
if (init_and_set_log_file_name(name, new_name,
log_type_arg, io_cache_type_arg) ||
DBUG_EVALUATE_IF("fault_injection_init_name", log_type == LOG_BIN, 0))
goto err;
/* File is regular writable file */
if (my_stat(log_file_name, &f_stat, MYF(0)) && !MY_S_ISREG(f_stat.st_mode))
goto err;
if (io_cache_type == SEQ_READ_APPEND)
open_flags |= O_RDWR | O_APPEND;
else
open_flags |= O_WRONLY | (log_type == LOG_BIN ? 0 : O_APPEND);
db[0]= 0;
#ifdef HAVE_PSI_INTERFACE
/* Keep the key for reopen */
m_log_file_key= log_file_key;
#endif
if ((file= mysql_file_open(log_file_key,
log_file_name, open_flags,
MYF(MY_WME | ME_WAITTANG))) < 0)
goto err;
#ifndef _WIN32
/* Reopen and validate path. */
if ((log_type_arg == LOG_UNKNOWN || log_type_arg == LOG_NORMAL) &&
(file= mysql_file_real_name_reopen(file,
#ifdef HAVE_PSI_INTERFACE
log_file_key,
#endif
open_flags,
log_file_name)) < 0)
goto err;
#endif // _WIN32
if ((pos= mysql_file_tell(file, MYF(MY_WME))) == MY_FILEPOS_ERROR)
{
if (my_errno == ESPIPE)
pos= 0;
else
goto err;
}
if (init_io_cache(&log_file, file, IO_SIZE, io_cache_type, pos, 0,
MYF(MY_WME | MY_NABP |
((log_type == LOG_BIN) ? MY_WAIT_IF_FULL : 0))))
goto err;
if (log_type == LOG_NORMAL)
{
char *end;
int len=my_snprintf(buff, sizeof(buff), "%s, Version: %s (%s). "
#ifdef EMBEDDED_LIBRARY
"embedded library\n",
my_progname, server_version, MYSQL_COMPILATION_COMMENT
#elif _WIN32
"started with:\nTCP Port: %d, Named Pipe: %s\n",
my_progname, server_version, MYSQL_COMPILATION_COMMENT,
mysqld_port, mysqld_unix_port
#else
"started with:\nTcp port: %d Unix socket: %s\n",
my_progname, server_version, MYSQL_COMPILATION_COMMENT,
mysqld_port, mysqld_unix_port
#endif
);
end= strnmov(buff + len, "Time Id Command Argument\n",
sizeof(buff) - len);
if (my_b_write(&log_file, (uchar*) buff, (uint) (end-buff)) ||
flush_io_cache(&log_file))
goto err;
}
log_state= LOG_OPENED;
DBUG_RETURN(0);
err:
if (log_type == LOG_BIN && (binlog_error_action == ABORT_SERVER ||
binlog_error_action == ROLLBACK_TRX))
{
exec_binlog_error_action_abort("Either disk is full or file system is read "
"only while opening the binlog. Aborting the"
" server.");
}
else
sql_print_error("Could not open %s for logging (error %d). "
"Turning logging off for the whole duration "
"of the MySQL server process. To turn it on "
"again: fix the cause, shutdown the MySQL "
"server and restart it.",
name, errno);
if (file >= 0)
mysql_file_close(file, MYF(0));
end_io_cache(&log_file);
my_free(name);
name= NULL;
log_state= LOG_CLOSED;
DBUG_RETURN(1);
}
/*
Open an (existing) log file. To be used only by Raft flow
SYNOPSIS
open_existing()
log_file_name, io_cache_type and log_type have been set previously
DESCRIPTION
Open the logfile, init IO_CACHE and write startup messages
RETURN VALUES
0 ok
1 error
*/
bool MYSQL_LOG::open_existing(
#ifdef HAVE_PSI_INTERFACE
PSI_file_key log_file_key
#endif
)
{
MY_STAT f_stat;
File file= -1;
my_off_t pos= 0;
int open_flags= O_CREAT | O_BINARY;
DBUG_ENTER("MYSQL_LOG::open_existing");
write_error= 0;
/* File is regular writable file */
if (my_stat(log_file_name, &f_stat, MYF(0)) && !MY_S_ISREG(f_stat.st_mode))
goto err;
if (io_cache_type == SEQ_READ_APPEND)
open_flags |= O_RDWR | O_APPEND;
else
open_flags |= O_WRONLY | (log_type == LOG_BIN ? 0 : O_APPEND);
db[0]= 0;
#ifdef HAVE_PSI_INTERFACE
/* Keep the key for reopen */
m_log_file_key= log_file_key;
#endif
if ((file= mysql_file_open(log_file_key, log_file_name, open_flags,
MYF(MY_WME | ME_WAITTANG))) < 0)
goto err;
// seek to end of file
mysql_file_seek(file, 0L, MY_SEEK_END, MYF(0));
if ((pos= mysql_file_tell(file, MYF(MY_WME))) == MY_FILEPOS_ERROR)
{
if (my_errno == ESPIPE)
pos= 0;
else
goto err;
}
// sets the IO cache and opens it
if (init_io_cache(&log_file, file, IO_SIZE, io_cache_type, pos, 0,
MYF(MY_WME | MY_NABP | MY_WAIT_IF_FULL)))
goto err;
log_state= LOG_OPENED;
DBUG_RETURN(0);
err:
if (log_type == LOG_BIN && (binlog_error_action == ABORT_SERVER ||
binlog_error_action == ROLLBACK_TRX))
{
exec_binlog_error_action_abort("Either disk is full or file system is read "
"only while opening the binlog. Aborting the"
" server.");
}
else
sql_print_error("Could not open %s for logging (error %d). "
"Turning logging off for the whole duration "
"of the MySQL server process. To turn it on "
"again: fix the cause, shutdown the MySQL "
"server and restart it.",
name, errno);
if (file >= 0)
mysql_file_close(file, MYF(0));
end_io_cache(&log_file);
my_free(name);
name= NULL;
log_state= LOG_CLOSED;
DBUG_RETURN(1);
}
MYSQL_LOG::MYSQL_LOG()
: name(0), write_error(FALSE), inited(FALSE), log_type(LOG_UNKNOWN),
log_state(LOG_CLOSED), cur_log_ext(-1)
#ifdef HAVE_PSI_INTERFACE
, m_key_LOCK_log(key_LOG_LOCK_log)
#endif
{
/*
We don't want to initialize LOCK_Log here as such initialization depends on
safe_mutex (when using safe_mutex) which depends on MY_INIT(), which is
called only in main(). Doing initialization here would make it happen
before main().
*/
memset(&log_file, 0, sizeof(log_file));
}
void MYSQL_LOG::init_pthread_objects()
{
DBUG_ASSERT(inited == 0);
inited= 1;
mysql_mutex_init(m_key_LOCK_log, &LOCK_log, MY_MUTEX_INIT_SLOW);
}
/*
Close the log file
SYNOPSIS
close()
exiting Bitmask. For the slow and general logs the only used bit is
LOG_CLOSE_TO_BE_OPENED. This is used if we intend to call
open at once after close.
NOTES
One can do an open on the object at once after doing a close.
The internal structures are not freed until cleanup() is called
*/
void MYSQL_LOG::close(uint exiting)
{ // One can't set log_type here!
DBUG_ENTER("MYSQL_LOG::close");
DBUG_PRINT("enter",("exiting: %d", (int) exiting));
if (log_state == LOG_OPENED)
{
end_io_cache(&log_file);
if (mysql_file_sync(log_file.file, MYF(MY_WME)) && ! write_error)
{
char errbuf[MYSYS_STRERROR_SIZE];
write_error= 1;
sql_print_error(ER_DEFAULT(ER_ERROR_ON_WRITE), name, errno,
my_strerror(errbuf, sizeof(errbuf), errno));
}
if (mysql_file_close(log_file.file, MYF(MY_WME)) && ! write_error)
{
char errbuf[MYSYS_STRERROR_SIZE];
write_error= 1;
sql_print_error(ER_DEFAULT(ER_ERROR_ON_WRITE), name, errno,
my_strerror(errbuf, sizeof(errbuf), errno));
}
}
log_state= (exiting & LOG_CLOSE_TO_BE_OPENED) ? LOG_TO_BE_OPENED : LOG_CLOSED;
my_free(name);
name= NULL;
DBUG_VOID_RETURN;
}
/** This is called only once. */
void MYSQL_LOG::cleanup()
{
DBUG_ENTER("cleanup");
if (inited)
{
inited= 0;
mysql_mutex_destroy(&LOCK_log);
close(0);
}
DBUG_VOID_RETURN;
}
// Mimic what generate_new_name does but do not increment the file ext
// after finding the last file, thus returning the current latest file
int MYSQL_LOG::find_existing_last_file(char *new_name, const char *log_name)
{
fn_format(new_name, log_name, mysql_data_home, "", 4);
if (fn_ext(log_name)[0])
return 0;
if (find_uniq_filename(new_name, &cur_log_ext, false /* need next */))
{
my_printf_error(ER_NO_UNIQUE_LOGFILE, ER(ER_NO_UNIQUE_LOGFILE),
MYF(ME_FATALERROR), log_name);
sql_print_error(ER(ER_NO_UNIQUE_LOGFILE), log_name);
return 1;
}
return 0;
}
int MYSQL_LOG::generate_new_name(char *new_name, const char *log_name)
{
fn_format(new_name, log_name, mysql_data_home, "", 4);
if (log_type == LOG_BIN || max_slowlog_size > 0)
{
if (!fn_ext(log_name)[0])
{
if (find_uniq_filename(new_name, &cur_log_ext, log_type == LOG_BIN))
{
my_printf_error(ER_NO_UNIQUE_LOGFILE, ER(ER_NO_UNIQUE_LOGFILE),
MYF(ME_FATALERROR), log_name);
sql_print_error(ER(ER_NO_UNIQUE_LOGFILE), log_name);
return 1;
}
}
}
return 0;
}
int MYSQL_LOG::purge_up_to(ulong to_ext, const char *log_name)
{
char buff[FN_REFLEN];
int error= 0;
DBUG_ENTER("MYSQL_LOG::purge_up_to");
do {
snprintf(buff, sizeof(buff), "%s.%06lu", name, to_ext);
if ((error= unlink(buff)))
{
if (my_errno == ENOENT)
error= 0;
break;
}
--to_ext;
} while (to_ext > 0);
DBUG_RETURN(error);
}
/*
Reopen the log file
SYNOPSIS
reopen_file()
DESCRIPTION
Reopen the log file. The method is used during FLUSH LOGS
and locks LOCK_log mutex
*/
void MYSQL_QUERY_LOG::reopen_file()
{
char *save_name;
DBUG_ENTER("MYSQL_LOG::reopen_file");
if (!is_open())
{
DBUG_PRINT("info",("log is closed"));
DBUG_VOID_RETURN;
}
mysql_mutex_lock(&LOCK_log);
save_name= name;
name= 0; // Don't free name
close(LOG_CLOSE_TO_BE_OPENED);
/*
Note that at this point, log_state != LOG_CLOSED (important for is_open()).
*/
open(
#ifdef HAVE_PSI_INTERFACE
m_log_file_key,
#endif
save_name, log_type, 0, io_cache_type);
my_free(save_name);
mysql_mutex_unlock(&LOCK_log);
DBUG_VOID_RETURN;
}
/*
Write a command to traditional general log file
SYNOPSIS
write()
event_time command start timestamp
user_host the pointer to the string with user@host info
user_host_len length of the user_host string. this is computed once
and passed to all general log event handlers
thread_id Id of the thread, issued a query
command_type the type of the command being logged
command_type_len the length of the string above
sql_text the very text of the query being executed
sql_text_len the length of sql_text string
DESCRIPTION
Log given command to to normal (not rotable) log file
RETURN
FASE - OK
TRUE - error occured
*/
bool MYSQL_QUERY_LOG::write(time_t event_time, const char *user_host,
uint user_host_len, my_thread_id thread_id,
const char *command_type, uint command_type_len,
const char *sql_text, uint sql_text_len)
{
char buff[32];
uint length= 0;
char local_time_buff[MAX_TIME_SIZE];
struct tm start;
uint time_buff_len= 0;
mysql_mutex_lock(&LOCK_log);
/* Test if someone closed between the is_open test and lock */
if (is_open())
{
/* for testing output of timestamp and thread id */
DBUG_EXECUTE_IF("reset_log_last_time", last_time= 0;);
/* Note that my_b_write() assumes it knows the length for this */
if (event_time != last_time)
{
last_time= event_time;
localtime_r(&event_time, &start);
time_buff_len= my_snprintf(local_time_buff, MAX_TIME_SIZE,
"%02d%02d%02d %2d:%02d:%02d\t",
start.tm_year % 100, start.tm_mon + 1,
start.tm_mday, start.tm_hour,
start.tm_min, start.tm_sec);
if (my_b_write(&log_file, (uchar*) local_time_buff, time_buff_len))
goto err;
}
else
if (my_b_write(&log_file, (uchar*) "\t\t" ,2) < 0)
goto err;
length= my_snprintf(buff, 32, "%5lu ", thread_id);
if (my_b_write(&log_file, (uchar*) buff, length))
goto err;
if (my_b_write(&log_file, (uchar*) command_type, command_type_len))
goto err;
if (my_b_write(&log_file, (uchar*) "\t", 1))
goto err;
/* sql_text */
if (my_b_write(&log_file, (uchar*) sql_text, sql_text_len))
goto err;
if (my_b_write(&log_file, (uchar*) "\n", 1) ||
flush_io_cache(&log_file))
goto err;
}
mysql_mutex_unlock(&LOCK_log);
return FALSE;
err:
if (!write_error)
{
char errbuf[MYSYS_STRERROR_SIZE];
write_error= 1;
sql_print_error(ER(ER_ERROR_ON_WRITE), name, errno,
my_strerror(errbuf, sizeof(errbuf), errno));
}
mysql_mutex_unlock(&LOCK_log);
return TRUE;
}
/*
Log a query to the traditional slow log file
SYNOPSIS
write()
thd THD of the query
current_time current timestamp
query_start_arg command start timestamp
user_host the pointer to the string with user@host info
user_host_len length of the user_host string. this is computed once
and passed to all general log event handlers
query_utime Amount of time the query took to execute (in microseconds)
lock_utime Amount of time the query was locked (in microseconds)
is_command The flag, which determines, whether the sql_text is a
query or an administrator command.
sql_text the very text of the query or administrator command
processed
sql_text_len the length of sql_text string
DESCRIPTION
Log a query to the slow log file.
RETURN
FALSE - OK
TRUE - error occured
*/
bool MYSQL_QUERY_LOG::write(THD *thd, time_t current_time,
time_t query_start_arg, const char *user_host,
uint user_host_len, ulonglong query_utime,
ulonglong lock_utime, bool is_command,
const char *sql_text, uint sql_text_len,
struct system_status_var *query_start)
{
bool error= 0;
bool need_purge= false;
char buff[80] = "";
char start_time_buff[80] = "";
char end_time_buff[80] = "";
char read_time_buff[80] = "";
char semisync_ack_time_buff[80] = "";
char engine_commit_time_buff[80] = "";
char query_time_buff[22+7], lock_time_buff[22+7];
bool use_query_start = false;
uint buff_len= 0;
DBUG_ENTER("MYSQL_QUERY_LOG::write");
if (!is_open())
{
DBUG_RETURN(0);
}
// If the query start status is valid - i.e. the current thread's
// status values should be no less than the query start status,
// we substract the query_start from current_status.
// Also skip when query_start points to the same data
if (query_start && query_start != &thd->status_var &&
thd->status_var.bytes_received >= query_start->bytes_received &&
thd->status_var.bytes_sent >= query_start->bytes_sent &&
thd->status_var.ha_read_first_count >= query_start->ha_read_first_count &&
thd->status_var.ha_read_last_count >= query_start->ha_read_last_count &&
thd->status_var.ha_read_key_count >= query_start->ha_read_key_count &&
thd->status_var.ha_read_next_count >= query_start->ha_read_next_count &&
thd->status_var.ha_read_prev_count >= query_start->ha_read_prev_count &&
thd->status_var.ha_read_rnd_count >= query_start->ha_read_rnd_count &&
thd->status_var.ha_read_rnd_next_count >= query_start->ha_read_rnd_next_count &&
thd->status_var.ha_key_skipped_count >= query_start->ha_key_skipped_count &&
thd->status_var.ha_delete_skipped_count >= query_start->ha_delete_skipped_count &&
thd->status_var.filesort_merge_passes >= query_start->filesort_merge_passes &&
thd->status_var.filesort_range_count >= query_start->filesort_range_count &&
thd->status_var.filesort_rows >= query_start->filesort_rows &&
thd->status_var.filesort_scan_count >= query_start->filesort_scan_count &&
thd->status_var.created_tmp_disk_tables >= query_start->created_tmp_disk_tables &&
thd->status_var.created_tmp_tables >= query_start->created_tmp_tables &&
thd->status_var.tmp_table_bytes_written >= query_start->tmp_table_bytes_written &&
thd->status_var.read_requests >= query_start->read_requests &&
thd->status_var.read_time >= query_start->read_time)
use_query_start = true;
if (!(specialflag & SPECIAL_SHORT_LOG_FORMAT))
{
/* Explicitly done before LOCK_log is locked */
if (current_time != last_time)
{
struct tm start;
localtime_r(¤t_time, &start);
buff_len= my_snprintf(buff, sizeof buff,
"# Time: %02d%02d%02d %2d:%02d:%02d\n",
start.tm_year % 100, start.tm_mon + 1,
start.tm_mday, start.tm_hour,
start.tm_min, start.tm_sec);
}
}
/* For slow query log */
sprintf(query_time_buff, "%.6f", ulonglong2double(query_utime)/1000000.0);
sprintf(lock_time_buff, "%.6f", ulonglong2double(lock_utime)/1000000.0);
/*Semisync ack time and Engine commit time */
sprintf(semisync_ack_time_buff,"%.6f",
my_timer_to_seconds(thd->semisync_ack_time));
sprintf(engine_commit_time_buff,"%.6f",
my_timer_to_seconds(thd->engine_commit_time));
if (opt_log_slow_extra && query_start_arg && query_start)
{
struct tm tm_tmp;
current_time=time(NULL);
localtime_r(¤t_time,&tm_tmp);
sprintf(end_time_buff,"%2d:%02d:%02d",
tm_tmp.tm_hour, tm_tmp.tm_min, tm_tmp.tm_sec);
localtime_r(&query_start_arg,&tm_tmp);
sprintf(start_time_buff,"%2d:%02d:%02d",
tm_tmp.tm_hour, tm_tmp.tm_min, tm_tmp.tm_sec);
sprintf(read_time_buff,"%.6f",
my_timer_to_seconds((use_query_start ?
thd->status_var.read_time - query_start->read_time :
thd->status_var.read_time)));
}
bool tid_present = !(thd->trace_id.empty());
mysql_mutex_lock(&LOCK_log);
if (is_open())
{ // Safety agains reopen
int tmp_errno= 0;
char *end = buff;
if (max_slowlog_size > 0)
error= rotate(max_slowlog_size, &need_purge);
if (!(specialflag & SPECIAL_SHORT_LOG_FORMAT))
{
if (current_time != last_time)
{
last_time= current_time;
/* Note that my_b_write() assumes it knows the length for this */
if (my_b_write(&log_file, (uchar*) buff, buff_len))
tmp_errno= errno;
}
buff_len= my_snprintf(buff, 32, "%5u", thd->thread_id());
if (my_b_printf(&log_file, "# User@Host: %s Id: %s\n", user_host, buff)
== (uint) -1)
tmp_errno= errno;
}
if (!query_start)
{
if (my_b_printf(&log_file,
"# Query_time: %s Lock_time: %s"
" Rows_sent: %lu Rows_examined: %lu\n",
query_time_buff, lock_time_buff,
(ulong) thd->get_sent_row_count(),
(ulong) thd->get_examined_row_count()) == (uint) -1)
tmp_errno= errno;
}
else if (use_query_start)
{
if (my_b_printf(&log_file,
"# Query_time: %s Lock_time: %s"
" Rows_sent: %lu Rows_examined: %lu"
" Thread_id: %lu Errno: %lu Killed: %lu"
" Bytes_received: %lu Bytes_sent: %lu"
" Read_first: %lu Read_last: %lu Read_key: %lu"
" Read_next: %lu Read_prev: %lu"
" Read_rnd: %lu Read_rnd_next: %lu"
" RocksDB_key_skipped: %lu RocksDB_del_skipped: %lu"
" Sort_merge_passes: %lu Sort_range_count: %lu"
" Sort_rows: %lu Sort_scan_count: %lu"
" Created_tmp_disk_tables: %lu"
" Created_tmp_tables: %lu"
" Tmp_table_bytes_written: %lu"
" Start: %s End: %s"
" Reads: %lu Read_time: %s"
" Trace_Id: %s Instruction_Cost: %lu"
" Semisync_ack_time: %s Engine_commit_time: %s\n",
query_time_buff, lock_time_buff,
(ulong) thd->get_sent_row_count(),
(ulong) thd->get_examined_row_count(),
(ulong) thd->thread_id(),
(ulong) thd->get_net()->last_errno,
(ulong) thd->killed,
(ulong) (thd->status_var.bytes_received -
query_start->bytes_received),
(ulong) (thd->status_var.bytes_sent -
query_start->bytes_sent),
(ulong) (thd->status_var.ha_read_first_count -
query_start->ha_read_first_count),
(ulong) (thd->status_var.ha_read_last_count -
query_start->ha_read_last_count),
(ulong) (thd->status_var.ha_read_key_count -
query_start->ha_read_key_count),
(ulong) (thd->status_var.ha_read_next_count -
query_start->ha_read_next_count),
(ulong) (thd->status_var.ha_read_prev_count -
query_start->ha_read_prev_count),
(ulong) (thd->status_var.ha_read_rnd_count -
query_start->ha_read_rnd_count),
(ulong) (thd->status_var.ha_read_rnd_next_count -
query_start->ha_read_rnd_next_count),
(ulong) (thd->status_var.ha_key_skipped_count -
query_start->ha_key_skipped_count),
(ulong) (thd->status_var.ha_delete_skipped_count -
query_start->ha_delete_skipped_count),
(ulong) (thd->status_var.filesort_merge_passes -
query_start->filesort_merge_passes),
(ulong) (thd->status_var.filesort_range_count -
query_start->filesort_range_count),
(ulong) (thd->status_var.filesort_rows -
query_start->filesort_rows),
(ulong) (thd->status_var.filesort_scan_count -
query_start->filesort_scan_count),
(ulong) (thd->status_var.created_tmp_disk_tables -
query_start->created_tmp_disk_tables),
(ulong) (thd->status_var.created_tmp_tables -
query_start->created_tmp_tables),
(ulong) (thd->status_var.tmp_table_bytes_written -
query_start->tmp_table_bytes_written),
start_time_buff, end_time_buff,
(ulong) (thd->status_var.read_requests -
query_start->read_requests),
read_time_buff,
(tid_present ? thd->trace_id.c_str() : "NA"),
(tid_present ? thd->pc_val : 0),
semisync_ack_time_buff,
engine_commit_time_buff) == (uint) -1)
tmp_errno=errno;
}
else // don't substract query_start status
{
if (my_b_printf(&log_file,
"# Query_time: %s Lock_time: %s"
" Rows_sent: %lu Rows_examined: %lu"
" Thread_id: %lu Errno: %lu Killed: %lu"
" Bytes_received: %lu Bytes_sent: %lu"
" Read_first: %lu Read_last: %lu Read_key: %lu"
" Read_next: %lu Read_prev: %lu"
" Read_rnd: %lu Read_rnd_next: %lu"
" RocksDB_key_skipped: %lu RocksDB_del_skipped: %lu"
" Sort_merge_passes: %lu Sort_range_count: %lu"
" Sort_rows: %lu Sort_scan_count: %lu"
" Created_tmp_disk_tables: %lu"
" Created_tmp_tables: %lu"
" Tmp_table_bytes_written: %lu"
" Start: %s End: %s"
" Reads: %lu Read_time: %s"
" Trace_Id: %s Instruction_Cost: %lu"
" Semisync_ack_time: %s Engine_commit_time: %s\n",
query_time_buff, lock_time_buff,
(ulong) thd->get_sent_row_count(),
(ulong) thd->get_examined_row_count(),
(ulong) thd->thread_id(),
(ulong) thd->get_net()->last_errno,
(ulong) thd->killed,
(ulong) thd->status_var.bytes_received,
(ulong) thd->status_var.bytes_sent,
(ulong) thd->status_var.ha_read_first_count,
(ulong) thd->status_var.ha_read_last_count,
(ulong) thd->status_var.ha_read_key_count,
(ulong) thd->status_var.ha_read_next_count,
(ulong) thd->status_var.ha_read_prev_count,
(ulong) thd->status_var.ha_read_rnd_count,
(ulong) thd->status_var.ha_read_rnd_next_count,
(ulong) thd->status_var.ha_key_skipped_count,
(ulong) thd->status_var.ha_delete_skipped_count,
(ulong) thd->status_var.filesort_merge_passes,
(ulong) thd->status_var.filesort_range_count,
(ulong) thd->status_var.filesort_rows,
(ulong) thd->status_var.filesort_scan_count,
(ulong) thd->status_var.created_tmp_disk_tables,
(ulong) thd->status_var.created_tmp_tables,
(ulong) thd->status_var.tmp_table_bytes_written,
start_time_buff, end_time_buff,
(ulong) thd->status_var.read_requests,
read_time_buff,
(tid_present ? thd->trace_id.c_str() : "NA"),
(tid_present ? thd->pc_val : 0),
semisync_ack_time_buff,
engine_commit_time_buff) == (uint) -1)
tmp_errno=errno;
}
if (thd->db && strcmp(thd->db, db))
{ // Database changed
if (my_b_printf(&log_file,"use %s;\n",thd->db) == (uint) -1)
tmp_errno= errno;
strmov(db,thd->db);
}
if (thd->stmt_depends_on_first_successful_insert_id_in_prev_stmt)
{
end=strmov(end, ",last_insert_id=");
end=longlong10_to_str((longlong)
thd->first_successful_insert_id_in_prev_stmt_for_binlog,
end, -10);
}
// Save value if we do an insert.
if (thd->auto_inc_intervals_in_cur_stmt_for_binlog.nb_elements() > 0)
{
if (!(specialflag & SPECIAL_SHORT_LOG_FORMAT))
{
end=strmov(end,",insert_id=");
end=longlong10_to_str((longlong)
thd->auto_inc_intervals_in_cur_stmt_for_binlog.minimum(),
end, -10);
}
}
/*
The timestamp used to only be set when the query had checked the
start time. Now the slow log always logs the query start time.
This ensures logs can be used to replicate queries accurately.
*/
end= strmov(end, ",timestamp=");
end= int10_to_str((long) query_start_arg, end, 10);
if (end != buff)
{
*end++=';';
*end='\n';
if (my_b_write(&log_file, (uchar*) "SET ", 4) ||
my_b_write(&log_file, (uchar*) buff + 1, (uint) (end-buff)))
tmp_errno= errno;
}
if (is_command)
{
end= strxmov(buff, "# administrator command: ", NullS);
buff_len= (ulong) (end - buff);
DBUG_EXECUTE_IF("simulate_slow_log_write_error",
{DBUG_SET("+d,simulate_file_write_error");});
if(my_b_write(&log_file, (uchar*) buff, buff_len))
tmp_errno= errno;
}
if (my_b_write(&log_file, (uchar*) sql_text, sql_text_len) ||
my_b_write(&log_file, (uchar*) ";\n",2) ||
flush_io_cache(&log_file))
tmp_errno= errno;
if (tmp_errno)
{
error= 1;
if (! write_error)
{
char errbuf[MYSYS_STRERROR_SIZE];
write_error= 1;
sql_print_error(ER(ER_ERROR_ON_WRITE), name, error,
my_strerror(errbuf, sizeof(errbuf), errno));
}
}
}
ulong save_cur_ext = cur_log_ext;
mysql_mutex_unlock(&LOCK_log);
if (max_slowlog_files && need_purge && !error)
{
error= purge_up_to(save_cur_ext > max_slowlog_files ?
save_cur_ext - max_slowlog_files : 0,
log_file_name);
}
DBUG_RETURN(error);
}
int MYSQL_QUERY_LOG::rotate(ulong max_size, bool *need_purge)
{
int error;
DBUG_ENTER("MYSQL_QUERY_LOG::rotate");
*need_purge= false;
if (my_b_tell(&log_file) > max_size)
{
if ((error= new_file()))
DBUG_RETURN(error);
*need_purge= true;
}
DBUG_RETURN(0);
}
int MYSQL_QUERY_LOG::new_file()
{
int error= 0, close_on_error= FALSE;
char new_name[FN_REFLEN], *old_name;
DBUG_ENTER("MYSQL_QUERY_LOG::new_file");
if (!is_open())
{
DBUG_PRINT("info",("log is closed"));
DBUG_RETURN(error);
}
mysql_mutex_assert_owner(&LOCK_log);
if (cur_log_ext == (ulong)-1)
{
strcpy(new_name, name);
if ((error= generate_new_name(new_name, name)))
goto end;
}
else
{
if (cur_log_ext == MAX_LOG_UNIQUE_FN_EXT)
{
error= 1;
goto end;
}
snprintf(new_name, sizeof(new_name), "%s.%06lu", name, ++cur_log_ext);
}
/*
close will try to free name and zero name pointer,
We saving current name value and zeroing the pointer to
prvent it.
*/
old_name= name;
name= NULL;
close(LOG_CLOSE_TO_BE_OPENED);
name= old_name;
error= open(
#ifdef HAVE_PSI_INTERFACE
key_file_query_log,
#endif
name,
LOG_NORMAL, new_name, WRITE_CACHE);
my_free(old_name);
end:
if (error && close_on_error /* rotate or reopen failed */)
{
sql_print_error("Could not open %s for logging (error %d). "
"Turning logging off for the whole duration "
"of the MySQL server process. To turn it on "
"again: fix the cause, shutdown the MySQL "
"server and restart it.",
new_name, errno);
}
DBUG_RETURN(error);
}
/**
@todo
The following should be using fn_format(); We just need to
first change fn_format() to cut the file name if it's too long.
*/
const char *MYSQL_LOG::generate_name(const char *log_name,
const char *suffix,
bool strip_ext, char *buff)
{
if (!log_name || !log_name[0])
{
strmake(buff, pidfile_name, FN_REFLEN - strlen(suffix) - 1);
return (const char *)
fn_format(buff, buff, "", suffix, MYF(MY_REPLACE_EXT|MY_REPLACE_DIR));
}
// get rid of extension if the log is binary to avoid problems
if (strip_ext)
{
char *p= fn_ext(log_name);
uint length= (uint) (p - log_name);
strmake(buff, log_name, min<size_t>(length, FN_REFLEN-1));
return (const char*)buff;
}
return log_name;
}
int error_log_print(enum loglevel level, const char *format,
va_list args)
{
return logger.error_log_print(level, format, args);
}
bool slow_log_print(THD *thd, const char *query, uint query_length,
struct system_status_var *query_start_status)
{
return logger.slow_log_print(thd, query, query_length,
query_start_status);
}
bool LOGGER::log_command(THD *thd, enum enum_server_command command,
const char *query_str, size_t query_length)
{
#ifndef NO_EMBEDDED_ACCESS_CHECKS
Security_context *sctx= thd->security_ctx;
#endif
/*
Log command if we have at least one log event handler enabled and want
to log this king of commands
*/
/* Audit notification when no general log handler present */
mysql_audit_general_log(thd, command_name[(uint) command].str,
command_name[(uint) command].length,
query_str, query_length);
if (*general_log_handler_list && (what_to_log & (1L << (uint) command)))
{
if ((thd->variables.option_bits & OPTION_LOG_OFF)
#ifndef NO_EMBEDDED_ACCESS_CHECKS
&& (sctx->master_access & SUPER_ACL)
#endif
)
{
/* No logging */
return FALSE;
}
return TRUE;
}
return FALSE;
}
bool general_log_print(THD *thd, enum enum_server_command command,
const char *format, ...)
{
va_list args;
uint error= 0;
uint message_buff_len= 0;
char message_buff[MAX_LOG_BUFFER_SIZE];
/* prepare message */
va_start(args, format);
if (format)
message_buff_len= my_vsnprintf(message_buff, sizeof(message_buff),
format, args);
else
message_buff[0]= '\0';
va_end(args);
/* Print the message to the buffer if we want to log this kind of command */
if (! logger.log_command(thd, command, message_buff, message_buff_len))
return FALSE;
error= logger.general_log_write(thd, command, message_buff, message_buff_len);
return error;
}
bool general_log_write(THD *thd, enum enum_server_command command,
const char *query, uint query_length)
{
/* Write the message to the log if we want to log this king of commands */
if (logger.log_command(thd, command, query, query_length))
return logger.general_log_write(thd, command, query, query_length);
return FALSE;
}
bool gap_lock_log_write(THD *thd, enum enum_server_command command,
const char *query, uint query_length)
{
if (thd->variables.gap_lock_write_log && !thd->m_gap_lock_log_written)
{
thd->m_gap_lock_log_written= true;
return logger.gap_lock_log_write(thd, command, query, query_length);
}
return FALSE;
}
/**
Check if a string is a valid number.
@param str String to test
@param res Store value here
@param allow_wildcards Set to 1 if we should ignore '%' and '_'
@note
For the moment the allow_wildcards argument is not used
Should be move to some other file.
@retval
1 String is a number
@retval
0 String is not a number
*/
static bool test_if_number(register const char *str,
ulong *res, bool allow_wildcards)
{
reg2 int flag;
const char *start;
DBUG_ENTER("test_if_number");
flag=0; start=str;
while (*str++ == ' ') ;
if (*--str == '-' || *str == '+')
str++;
while (my_isdigit(files_charset_info,*str) ||
(allow_wildcards && (*str == wild_many || *str == wild_one)))
{
flag=1;
str++;
}
if (*str == '.')
{
for (str++ ;
my_isdigit(files_charset_info,*str) ||
(allow_wildcards && (*str == wild_many || *str == wild_one)) ;
str++, flag=1) ;
}
if (*str != 0 || flag == 0)
DBUG_RETURN(0);
if (res)
*res=atol(start);
DBUG_RETURN(1); /* Number ok */
} /* test_if_number */
void sql_perror(const char *message)
{
#ifdef HAVE_STRERROR
sql_print_error("%s: %s",message, strerror(errno));
#else
perror(message);
#endif
}
/*
Change the file associated with two output streams. Used to
redirect stdout and stderr to a file. The streams are reopened
only for appending (writing at end of file).
*/
extern "C" my_bool reopen_fstreams(const char *filename,
FILE *outstream, FILE *errstream)
{
int retries= 2, errors= 0;
do
{
errors= 0;
if (errstream && !my_freopen(filename, "a", errstream))
errors++;
if (outstream && !my_freopen(filename, "a", outstream))
errors++;
}
while (retries-- && errors);
if (errors)
return true;
/* The error stream must be unbuffered. */
if (errstream)
setbuf(errstream, NULL);
return FALSE;
}
/*
Unfortunately, there seems to be no good way
to restore the original streams upon failure.
*/
static bool redirect_std_streams(const char *file)
{
if (reopen_fstreams(file, stdout, stderr))
return TRUE;
setbuf(stderr, NULL);
return FALSE;
}
bool flush_error_log()
{
bool result= 0;
if (opt_error_log)
{
mysql_mutex_lock(&LOCK_error_log);
if (redirect_std_streams(log_error_file))
result= 1;
mysql_mutex_unlock(&LOCK_error_log);
}
return result;
}
#ifdef _WIN32
static void print_buffer_to_nt_eventlog(enum loglevel level, char *buff,
size_t length, size_t buffLen)
{
HANDLE event;
char *buffptr= buff;
DBUG_ENTER("print_buffer_to_nt_eventlog");
/* Add ending CR/LF's to string, overwrite last chars if necessary */
strmov(buffptr+min(length, buffLen-5), "\r\n\r\n");
setup_windows_event_source();
if ((event= RegisterEventSource(NULL,"MySQL")))
{
switch (level) {
case ERROR_LEVEL:
ReportEvent(event, EVENTLOG_ERROR_TYPE, 0, MSG_DEFAULT, NULL, 1, 0,
(LPCSTR*)&buffptr, NULL);
break;
case WARNING_LEVEL:
ReportEvent(event, EVENTLOG_WARNING_TYPE, 0, MSG_DEFAULT, NULL, 1, 0,
(LPCSTR*) &buffptr, NULL);
break;
case INFORMATION_LEVEL:
ReportEvent(event, EVENTLOG_INFORMATION_TYPE, 0, MSG_DEFAULT, NULL, 1,
0, (LPCSTR*) &buffptr, NULL);
break;
}
DeregisterEventSource(event);
}
DBUG_VOID_RETURN;
}
#endif /* _WIN32 */
#ifndef EMBEDDED_LIBRARY
static void print_buffer_to_file(enum loglevel level, const char *buffer,
size_t length)
{
time_t skr;
struct tm tm_tmp;
struct tm *start;
DBUG_ENTER("print_buffer_to_file");
DBUG_PRINT("enter",("buffer: %s", buffer));
mysql_mutex_lock(&LOCK_error_log);
skr= my_time(0);
localtime_r(&skr, &tm_tmp);
start=&tm_tmp;
fprintf(stderr, "%d-%02d-%02d %02d:%02d:%02d %lu [%s] %.*s\n",
start->tm_year + 1900,
start->tm_mon + 1,
start->tm_mday,
start->tm_hour,
start->tm_min,
start->tm_sec,
current_pid,
(level == ERROR_LEVEL ? "ERROR" : level == WARNING_LEVEL ?
"Warning" : "Note"),
(int) length, buffer);
fflush(stderr);
mysql_mutex_unlock(&LOCK_error_log);
DBUG_VOID_RETURN;
}
/**
Prints a printf style message to the error log and, under NT, to the
Windows event log.
This function prints the message into a buffer and then sends that buffer
to other functions to write that message to other logging sources.
@param level The level of the msg significance
@param format Printf style format of message
@param args va_list list of arguments for the message
@returns
The function always returns 0. The return value is present in the
signature to be compatible with other logging routines, which could
return an error (e.g. logging to the log tables)
*/
int vprint_msg_to_log(enum loglevel level, const char *format, va_list args)
{
char buff[MAX_LOG_BUFFER_SIZE];
size_t length;
DBUG_ENTER("vprint_msg_to_log");
length= my_vsnprintf(buff, sizeof(buff), format, args);
print_buffer_to_file(level, buff, length);
#ifdef _WIN32
print_buffer_to_nt_eventlog(level, buff, length, sizeof(buff));
#endif
DBUG_RETURN(0);
}
#endif /* EMBEDDED_LIBRARY */
void sql_print_error(const char *format, ...)
{
va_list args;
DBUG_ENTER("sql_print_error");
va_start(args, format);
error_log_print(ERROR_LEVEL, format, args);
va_end(args);
DBUG_VOID_RETURN;
}
void sql_print_warning(const char *format, ...)
{
va_list args;
DBUG_ENTER("sql_print_warning");
va_start(args, format);
error_log_print(WARNING_LEVEL, format, args);
va_end(args);
DBUG_VOID_RETURN;
}
void sql_print_information(const char *format, ...)
{
va_list args;
DBUG_ENTER("sql_print_information");
va_start(args, format);
error_log_print(INFORMATION_LEVEL, format, args);
va_end(args);
DBUG_VOID_RETURN;
}
extern "C"
int my_plugin_log_message(MYSQL_PLUGIN *plugin_ptr, plugin_log_level level,
const char *format, ...)
{
char format2[MAX_LOG_BUFFER_SIZE];
int ret;
loglevel lvl;
struct st_plugin_int *plugin = static_cast<st_plugin_int *> (*plugin_ptr);
va_list args;
DBUG_ASSERT(level >= MY_ERROR_LEVEL || level <= MY_INFORMATION_LEVEL);
switch (level)
{
case MY_ERROR_LEVEL: lvl= ERROR_LEVEL; break;
case MY_WARNING_LEVEL: lvl= WARNING_LEVEL; break;
case MY_INFORMATION_LEVEL: lvl= INFORMATION_LEVEL; break;
default: return 1;
}
va_start(args, format);
snprintf(format2, sizeof (format2) - 1, "Plugin %.*s reported: '%s'",
(int) plugin->name.length, plugin->name.str, format);
ret= error_log_print(lvl, format2, args);
va_end(args);
return ret;
}
/********* transaction coordinator log for 2pc - mmap() based solution *******/
/*
the log consists of a file, mmapped to a memory.
file is divided on pages of tc_log_page_size size.
(usable size of the first page is smaller because of log header)
there's PAGE control structure for each page
each page (or rather PAGE control structure) can be in one of three
states - active, syncing, pool.
there could be only one page in active or syncing states,
but many in pool - pool is fifo queue.
usual lifecycle of a page is pool->active->syncing->pool
"active" page - is a page where new xid's are logged.
the page stays active as long as syncing slot is taken.
"syncing" page is being synced to disk. no new xid can be added to it.
when the sync is done the page is moved to a pool and an active page
becomes "syncing".
the result of such an architecture is a natural "commit grouping" -
If commits are coming faster than the system can sync, they do not
stall. Instead, all commit that came since the last sync are
logged to the same page, and they all are synced with the next -
one - sync. Thus, thought individual commits are delayed, throughput
is not decreasing.
when a xid is added to an active page, the thread of this xid waits
for a page's condition until the page is synced. when syncing slot
becomes vacant one of these waiters is awaken to take care of syncing.
it syncs the page and signals all waiters that the page is synced.
PAGE::waiters is used to count these waiters, and a page may never
become active again until waiters==0 (that is all waiters from the
previous sync have noticed the sync was completed)
note, that the page becomes "dirty" and has to be synced only when a
new xid is added into it. Removing a xid from a page does not make it
dirty - we don't sync removals to disk.
*/
ulong tc_log_page_waits= 0;
#ifdef HAVE_MMAP
#define TC_LOG_HEADER_SIZE (sizeof(tc_log_magic)+1)
static const char tc_log_magic[]={(char) 254, 0x23, 0x05, 0x74};
ulong opt_tc_log_size= TC_LOG_MIN_SIZE;
ulong tc_log_max_pages_used=0, tc_log_page_size=0, tc_log_cur_pages_used=0;
int TC_LOG_MMAP::open(const char *opt_name)
{
uint i;
bool crashed=FALSE;
PAGE *pg;
DBUG_ASSERT(total_ha_2pc > 1);
DBUG_ASSERT(opt_name && opt_name[0]);
tc_log_page_size= my_getpagesize();
if (TC_LOG_PAGE_SIZE > tc_log_page_size)
{
DBUG_ASSERT(TC_LOG_PAGE_SIZE % tc_log_page_size == 0);
}
fn_format(logname,opt_name,mysql_data_home,"",MY_UNPACK_FILENAME);
if ((fd= mysql_file_open(key_file_tclog, logname, O_RDWR, MYF(0))) < 0)
{
if (my_errno != ENOENT)
goto err;
if (using_heuristic_recover())
return 1;
if ((fd= mysql_file_create(key_file_tclog, logname, CREATE_MODE,
O_RDWR, MYF(MY_WME))) < 0)
goto err;
inited=1;
file_length= opt_tc_log_size;
if (mysql_file_chsize(fd, file_length, 0, MYF(MY_WME)))
goto err;
}
else
{
inited= 1;
crashed= TRUE;
sql_print_information("Recovering after a crash using %s", opt_name);
if (tc_heuristic_recover)
{
sql_print_error("Cannot perform automatic crash recovery when "
"--tc-heuristic-recover is used");
goto err;
}
file_length= mysql_file_seek(fd, 0L, MY_SEEK_END, MYF(MY_WME+MY_FAE));
if (file_length == MY_FILEPOS_ERROR || file_length % tc_log_page_size)
goto err;
}
data= (uchar *)my_mmap(0, (size_t)file_length, PROT_READ|PROT_WRITE,
MAP_NOSYNC|MAP_SHARED, fd, 0);
if (data == MAP_FAILED)
{
my_errno=errno;
goto err;
}
inited=2;
npages=(uint)file_length/tc_log_page_size;
DBUG_ASSERT(npages >= 3); // to guarantee non-empty pool
if (!(pages=(PAGE *)my_malloc(npages*sizeof(PAGE), MYF(MY_WME|MY_ZEROFILL))))
goto err;
inited=3;
for (pg=pages, i=0; i < npages; i++, pg++)
{
pg->next=pg+1;
pg->waiters=0;
pg->state=PS_POOL;
mysql_mutex_init(key_PAGE_lock, &pg->lock, MY_MUTEX_INIT_FAST);
mysql_cond_init(key_PAGE_cond, &pg->cond, 0);
pg->size=pg->free=tc_log_page_size/sizeof(my_xid);
pg->start=(my_xid *)(data + i*tc_log_page_size);
pg->end=pg->start + pg->size;
pg->ptr= pg->start;
}
pages[0].size=pages[0].free=
(tc_log_page_size-TC_LOG_HEADER_SIZE)/sizeof(my_xid);
pages[0].start=pages[0].end-pages[0].size;
pages[npages-1].next=0;
inited=4;
if (crashed && recover())
goto err;
memcpy(data, tc_log_magic, sizeof(tc_log_magic));
data[sizeof(tc_log_magic)]= (uchar)total_ha_2pc;
my_msync(fd, data, tc_log_page_size, MS_SYNC);
inited=5;
mysql_mutex_init(key_LOCK_sync, &LOCK_sync, MY_MUTEX_INIT_FAST);
mysql_mutex_init(key_LOCK_active, &LOCK_active, MY_MUTEX_INIT_FAST);
mysql_mutex_init(key_LOCK_pool, &LOCK_pool, MY_MUTEX_INIT_FAST);
mysql_cond_init(key_COND_active, &COND_active, 0);
mysql_cond_init(key_COND_pool, &COND_pool, 0);
inited=6;
syncing= 0;
active=pages;
pool=pages+1;
pool_last=pages+npages-1;
return 0;
err:
close();
return 1;
}
/**
there is no active page, let's got one from the pool.
Two strategies here:
-# take the first from the pool
-# if there're waiters - take the one with the most free space.
@todo
TODO page merging. try to allocate adjacent page first,
so that they can be flushed both in one sync
*/
void TC_LOG_MMAP::get_active_from_pool()
{
PAGE **p, **best_p=0;
int best_free;
if (syncing)
mysql_mutex_lock(&LOCK_pool);
do
{
best_p= p= &pool;
if ((*p)->waiters == 0) // can the first page be used ?
break; // yes - take it.
best_free=0; // no - trying second strategy
for (p=&(*p)->next; *p; p=&(*p)->next)
{
if ((*p)->waiters == 0 && (*p)->free > best_free)
{
best_free=(*p)->free;
best_p=p;
}
}
}
while ((*best_p == 0 || best_free == 0) && overflow());
active=*best_p;
if (active->free == active->size) // we've chosen an empty page
{
tc_log_cur_pages_used++;
set_if_bigger(tc_log_max_pages_used, tc_log_cur_pages_used);
}
if ((*best_p)->next) // unlink the page from the pool
*best_p=(*best_p)->next;
else
pool_last=*best_p;
if (syncing)
mysql_mutex_unlock(&LOCK_pool);
}
/**
@todo
perhaps, increase log size ?
*/
int TC_LOG_MMAP::overflow()
{
/*
simple overflow handling - just wait
TODO perhaps, increase log size ?
let's check the behaviour of tc_log_page_waits first
*/
tc_log_page_waits++;
mysql_cond_wait(&COND_pool, &LOCK_pool);
return 1; // always return 1
}
/**
Commit the transaction.
@note When the TC_LOG inteface was changed, this function was added
and uses the functions that were there with the old interface to
implement the logic.
*/
TC_LOG::enum_result TC_LOG_MMAP::commit(THD *thd, bool all, bool async)
{
DBUG_ENTER("TC_LOG_MMAP::commit");
unsigned long cookie= 0;
my_xid xid= thd->transaction.xid_state.xid.get_my_xid();
if (all && xid)
if (!(cookie= log_xid(thd, xid, async)))
DBUG_RETURN(RESULT_ABORTED); // Failed to log the transaction
if (ha_commit_low(thd, all, async))
DBUG_RETURN(RESULT_INCONSISTENT); // Transaction logged, but not committed
/* If cookie is non-zero, something was logged */
if (cookie)
if (unlog(cookie, xid))
DBUG_RETURN(RESULT_INCONSISTENT); // Transaction logged, committed, but not unlogged.
DBUG_RETURN(RESULT_SUCCESS);
}
/**
Record that transaction XID is committed on the persistent storage.
This function is called in the middle of two-phase commit:
First all resources prepare the transaction, then tc_log->log() is called,
then all resources commit the transaction, then tc_log->unlog() is called.
All access to active page is serialized but it's not a problem, as
we're assuming that fsync() will be a main bottleneck.
That is, parallelizing writes to log pages we'll decrease number of
threads waiting for a page, but then all these threads will be waiting
for a fsync() anyway
If tc_log == MYSQL_LOG then tc_log writes transaction to binlog and
records XID in a special Xid_log_event.
If tc_log = TC_LOG_MMAP then xid is written in a special memory-mapped
log.
@retval
0 - error
@retval
\# - otherwise, "cookie", a number that will be passed as an argument
to unlog() call. tc_log can define it any way it wants,
and use for whatever purposes. TC_LOG_MMAP sets it
to the position in memory where xid was logged to.
*/
int TC_LOG_MMAP::log_xid(THD *thd, my_xid xid, bool async)
{
int err;
PAGE *p;
ulong cookie;
mysql_mutex_lock(&LOCK_active);
/*
if active page is full - just wait...
frankly speaking, active->free here accessed outside of mutex
protection, but it's safe, because it only means we may miss an
unlog() for the active page, and we're not waiting for it here -
unlog() does not signal COND_active.
*/
while (unlikely(active && active->free == 0))
mysql_cond_wait(&COND_active, &LOCK_active);
/* no active page ? take one from the pool */
if (active == 0)
get_active_from_pool();
p=active;
mysql_mutex_lock(&p->lock);
/* searching for an empty slot */
while (*p->ptr)
{
p->ptr++;
DBUG_ASSERT(p->ptr < p->end); // because p->free > 0
}
/* found! store xid there and mark the page dirty */
cookie= (ulong)((uchar *)p->ptr - data); // can never be zero
*p->ptr++= xid;
p->free--;
p->state= PS_DIRTY;
/* to sync or not to sync - this is the question */
mysql_mutex_unlock(&LOCK_active);
mysql_mutex_lock(&LOCK_sync);
mysql_mutex_unlock(&p->lock);
if (syncing)
{ // somebody's syncing. let's wait
p->waiters++;
/*
note - it must be while (), not do ... while () here
as p->state may be not PS_DIRTY when we come here
*/
while (p->state == PS_DIRTY && syncing)
mysql_cond_wait(&p->cond, &LOCK_sync);
p->waiters--;
err= p->state == PS_ERROR;
if (p->state != PS_DIRTY) // page was synced
{
if (p->waiters == 0)
mysql_cond_signal(&COND_pool); // in case somebody's waiting
mysql_mutex_unlock(&LOCK_sync);
goto done; // we're done
}
} // page was not synced! do it now
DBUG_ASSERT(active == p && syncing == 0);
mysql_mutex_lock(&LOCK_active);
syncing=p; // place is vacant - take it
active=0; // page is not active anymore
mysql_cond_broadcast(&COND_active); // in case somebody's waiting
mysql_mutex_unlock(&LOCK_active);
mysql_mutex_unlock(&LOCK_sync);
err= sync();
done:
return err ? 0 : cookie;
}
int TC_LOG_MMAP::sync()
{
int err;
DBUG_ASSERT(syncing != active);
/*
sit down and relax - this can take a while...
note - no locks are held at this point
*/
err= my_msync(fd, syncing->start, 1, MS_SYNC);
/* page is synced. let's move it to the pool */
mysql_mutex_lock(&LOCK_pool);
pool_last->next=syncing;
pool_last=syncing;
syncing->next=0;
syncing->state= err ? PS_ERROR : PS_POOL;
mysql_cond_broadcast(&syncing->cond); // signal "sync done"
mysql_cond_signal(&COND_pool); // in case somebody's waiting
mysql_mutex_unlock(&LOCK_pool);
/* marking 'syncing' slot free */
mysql_mutex_lock(&LOCK_sync);
syncing=0;
if (active)
{
mysql_cond_signal(&active->cond); // wake up a new syncer
}
mysql_mutex_unlock(&LOCK_sync);
return err;
}
/**
erase xid from the page, update page free space counters/pointers.
cookie points directly to the memory where xid was logged.
*/
int TC_LOG_MMAP::unlog(ulong cookie, my_xid xid)
{
PAGE *p=pages+(cookie/tc_log_page_size);
my_xid *x=(my_xid *)(data+cookie);
DBUG_ASSERT(*x == xid);
DBUG_ASSERT(x >= p->start && x < p->end);
*x=0;
mysql_mutex_lock(&p->lock);
p->free++;
DBUG_ASSERT(p->free <= p->size);
set_if_smaller(p->ptr, x);
if (p->free == p->size) // the page is completely empty
statistic_decrement(tc_log_cur_pages_used, &LOCK_status);
if (p->waiters == 0) // the page is in pool and ready to rock
mysql_cond_signal(&COND_pool); // ping ... for overflow()
mysql_mutex_unlock(&p->lock);
return 0;
}
void TC_LOG_MMAP::close()
{
uint i;
switch (inited) {
case 6:
mysql_mutex_destroy(&LOCK_sync);
mysql_mutex_destroy(&LOCK_active);
mysql_mutex_destroy(&LOCK_pool);
mysql_cond_destroy(&COND_pool);
case 5:
data[0]='A'; // garble the first (signature) byte, in case mysql_file_delete fails
case 4:
for (i=0; i < npages; i++)
{
if (pages[i].ptr == 0)
break;
mysql_mutex_destroy(&pages[i].lock);
mysql_cond_destroy(&pages[i].cond);
}
case 3:
my_free(pages);
case 2:
my_munmap((char*)data, (size_t)file_length);
case 1:
mysql_file_close(fd, MYF(0));
}
if (inited>=5) // cannot do in the switch because of Windows
mysql_file_delete(key_file_tclog, logname, MYF(MY_WME));
inited=0;
}
int TC_LOG_MMAP::recover()
{
HASH xids;
PAGE *p=pages, *end_p=pages+npages;
if (memcmp(data, tc_log_magic, sizeof(tc_log_magic)))
{
sql_print_error("Bad magic header in tc log");
goto err1;
}
/*
the first byte after magic signature is set to current
number of storage engines on startup
*/
if (data[sizeof(tc_log_magic)] != total_ha_2pc)
{
sql_print_error("Recovery failed! You must enable "
"exactly %d storage engines that support "
"two-phase commit protocol",
data[sizeof(tc_log_magic)]);
goto err1;
}
if (my_hash_init(&xids, &my_charset_bin, tc_log_page_size/3, 0,
sizeof(my_xid), 0, 0, MYF(0)))
goto err1;
for ( ; p < end_p ; p++)
{
for (my_xid *x=p->start; x < p->end; x++)
if (*x && my_hash_insert(&xids, (uchar *)x))
goto err2; // OOM
}
if (ha_recover(&xids))
goto err2;
my_hash_free(&xids);
memset(data, 0, (size_t)file_length);
return 0;
err2:
my_hash_free(&xids);
err1:
sql_print_error("Crash recovery failed. Either correct the problem "
"(if it's, for example, out of memory error) and restart, "
"or delete tc log and start mysqld with "
"--tc-heuristic-recover={commit|rollback}");
return 1;
}
#endif
TC_LOG *tc_log;
TC_LOG_DUMMY tc_log_dummy;
TC_LOG_MMAP tc_log_mmap;
/**
Perform heuristic recovery, if --tc-heuristic-recover was used.
@note
no matter whether heuristic recovery was successful or not
mysqld must exit. So, return value is the same in both cases.
@retval
0 no heuristic recovery was requested
@retval
1 heuristic recovery was performed
*/
int TC_LOG::using_heuristic_recover()
{
if (!tc_heuristic_recover)
return 0;
sql_print_information("Heuristic crash recovery mode");
if (ha_recover(0))
sql_print_error("Heuristic crash recovery failed");
sql_print_information("Please restart mysqld without --tc-heuristic-recover");
return 1;
}
/**
When a fatal error occurs due to which binary logging becomes impossible and
the user specified binlog_error_action= ABORT_SERVER the following function is
invoked. This function pushes the appropriate error message to client and logs
the same to server error log and then aborts the server.
@param err_string Error string which specifies the exact error
message from the caller.
@retval
none
*/
void exec_binlog_error_action_abort(const char* err_string)
{
THD *thd= current_thd;
/*
When the code enters here it means that there was an error at higher layer
and my_error function could have been invoked to let the client know what
went wrong during the execution.
But these errors will not let the client know that the server is going to
abort. Even if we add an additional my_error function call at this point
client will be able to see only the first error message that was set
during the very first invocation of my_error function call.
The advantage of having multiple my_error function calls are visible when
the server is up and running and user issues SHOW WARNINGS or SHOW ERROR
calls. In this special scenario server will be immediately aborted and
user will not be able execute the above SHOW commands.
Hence we clear the previous errors and push one critical error message to
clients.
*/
thd->clear_error();
/*
Adding ME_NOREFRESH flag will ensure that the error is sent to both
client and to the server error log as well.
*/
my_error(ER_BINLOG_LOGGING_IMPOSSIBLE, MYF(ME_NOREFRESH + ME_FATALERROR),
err_string);
thd->protocol->end_statement(thd);
abort();
}