|
|
|
@ -2826,7 +2826,7 @@ bool MYSQL_BIN_LOG::open(const char *log_name, |
|
|
|
sql_print_error("MSYQL_BIN_LOG::open failed to sync the index file."); |
|
|
|
DBUG_RETURN(1); |
|
|
|
} |
|
|
|
DBUG_EXECUTE_IF("crash_create_non_critical_before_update_index", abort();); |
|
|
|
DBUG_EXECUTE_IF("crash_create_non_critical_before_update_index", DBUG_ABORT();); |
|
|
|
#endif
|
|
|
|
|
|
|
|
write_error= 0; |
|
|
|
@ -2923,7 +2923,7 @@ bool MYSQL_BIN_LOG::open(const char *log_name, |
|
|
|
if (write_file_name_to_index_file) |
|
|
|
{ |
|
|
|
#ifdef HAVE_REPLICATION
|
|
|
|
DBUG_EXECUTE_IF("crash_create_critical_before_update_index", abort();); |
|
|
|
DBUG_EXECUTE_IF("crash_create_critical_before_update_index", DBUG_ABORT();); |
|
|
|
#endif
|
|
|
|
|
|
|
|
DBUG_ASSERT(my_b_inited(&index_file) != 0); |
|
|
|
@ -2942,7 +2942,7 @@ bool MYSQL_BIN_LOG::open(const char *log_name, |
|
|
|
goto err; |
|
|
|
|
|
|
|
#ifdef HAVE_REPLICATION
|
|
|
|
DBUG_EXECUTE_IF("crash_create_after_update_index", abort();); |
|
|
|
DBUG_EXECUTE_IF("crash_create_after_update_index", DBUG_ABORT();); |
|
|
|
#endif
|
|
|
|
} |
|
|
|
} |
|
|
|
@ -3404,7 +3404,7 @@ int MYSQL_BIN_LOG::purge_first_log(Relay_log_info* rli, bool included) |
|
|
|
/* Store where we are in the new file for the execution thread */ |
|
|
|
flush_relay_log_info(rli); |
|
|
|
|
|
|
|
DBUG_EXECUTE_IF("crash_before_purge_logs", abort();); |
|
|
|
DBUG_EXECUTE_IF("crash_before_purge_logs", DBUG_ABORT();); |
|
|
|
|
|
|
|
mysql_mutex_lock(&rli->log_space_lock); |
|
|
|
rli->relay_log.purge_logs(to_purge_if_included, included, |
|
|
|
@ -3547,7 +3547,7 @@ int MYSQL_BIN_LOG::purge_logs(const char *to_log, |
|
|
|
goto err; |
|
|
|
} |
|
|
|
|
|
|
|
DBUG_EXECUTE_IF("crash_purge_critical_after_update_index", abort();); |
|
|
|
DBUG_EXECUTE_IF("crash_purge_critical_after_update_index", DBUG_ABORT();); |
|
|
|
|
|
|
|
err: |
|
|
|
/* Read each entry from purge_index_file and delete the file. */ |
|
|
|
@ -3557,7 +3557,7 @@ err: |
|
|
|
" that would be purged."); |
|
|
|
close_purge_index_file(); |
|
|
|
|
|
|
|
DBUG_EXECUTE_IF("crash_purge_non_critical_after_update_index", abort();); |
|
|
|
DBUG_EXECUTE_IF("crash_purge_non_critical_after_update_index", DBUG_ABORT();); |
|
|
|
|
|
|
|
if (need_mutex) |
|
|
|
mysql_mutex_unlock(&LOCK_index); |
|
|
|
@ -5101,7 +5101,7 @@ bool MYSQL_BIN_LOG::write(THD *thd, IO_CACHE *cache, Log_event *commit_event, |
|
|
|
DBUG_PRINT("info", ("error writing binlog cache: %d", |
|
|
|
write_error)); |
|
|
|
DBUG_PRINT("info", ("crashing before writing xid")); |
|
|
|
abort(); |
|
|
|
DBUG_ABORT(); |
|
|
|
}); |
|
|
|
|
|
|
|
if ((write_error= write_cache(cache, false, false))) |
|
|
|
@ -5116,7 +5116,7 @@ bool MYSQL_BIN_LOG::write(THD *thd, IO_CACHE *cache, Log_event *commit_event, |
|
|
|
bool synced= 0; |
|
|
|
if (flush_and_sync(&synced)) |
|
|
|
goto err; |
|
|
|
DBUG_EXECUTE_IF("half_binlogged_transaction", abort();); |
|
|
|
DBUG_EXECUTE_IF("half_binlogged_transaction", DBUG_ABORT();); |
|
|
|
if (cache->error) // Error on read
|
|
|
|
{ |
|
|
|
sql_print_error(ER(ER_ERROR_ON_READ), cache->file_name, errno); |
|
|
|
|