diff options
author | unknown <monty@bitch.mysql.fi> | 2002-06-08 21:02:01 +0300 |
---|---|---|
committer | unknown <monty@bitch.mysql.fi> | 2002-06-08 21:02:01 +0300 |
commit | 224869afe8973372d6447d84a2f2c98b733c2c43 (patch) | |
tree | dd6fcd7f2120c05a87f087ac245b6ceed6597399 /sql/log_event.cc | |
parent | 7b0eeb208aab4832c55cf25c3590d12b45f0ef85 (diff) | |
download | mariadb-git-224869afe8973372d6447d84a2f2c98b733c2c43.tar.gz |
Added a lot of DBUG_xxx statements to be able to find replication bug.
Fixed critical bug on 64 bit systems.
Cleanups
BUILD/compile-solaris-sparc-purify:
Added --debug option.
sql/log_event.cc:
Added DBUG_xxx statements.
Cleanup
sql/opt_range.h:
Dummy fix to remove warnings in purify
sql/repl_failsafe.cc:
Cleanup
sql/slave.cc:
Added DBUG statements to be able to find bugs.
Optimized code.
Fixed critical bug on 64 bit systems.
sql/sql_repl.cc:
Added DBUG_xx statements.
Diffstat (limited to 'sql/log_event.cc')
-rw-r--r-- | sql/log_event.cc | 26 |
1 files changed, 17 insertions, 9 deletions
diff --git a/sql/log_event.cc b/sql/log_event.cc index 9315baa0de5..0d66185c8dd 100644 --- a/sql/log_event.cc +++ b/sql/log_event.cc @@ -1240,8 +1240,9 @@ Slave_log_event::Slave_log_event(THD* thd_arg, struct st_relay_log_info* rli): Log_event(thd_arg),mem_pool(0),master_host(0) { + DBUG_ENTER("Slave_log_event"); if (!rli->inited) - return; + DBUG_VOID_RETURN; MASTER_INFO* mi = rli->mi; // TODO: re-write this better without holding both locks at the same time @@ -1259,11 +1260,14 @@ Slave_log_event::Slave_log_event(THD* thd_arg, memcpy(master_log, rli->master_log_name, master_log_len + 1); master_port = mi->port; master_pos = rli->master_log_pos; + DBUG_PRINT("info", ("master_log: %s pos: %d", master_log, + (ulong) master_pos)); } else sql_print_error("Out of memory while recording slave event"); pthread_mutex_unlock(&rli->data_lock); pthread_mutex_unlock(&mi->data_lock); + DBUG_VOID_RETURN; } @@ -1284,8 +1288,8 @@ void Slave_log_event::print(FILE* file, bool short_form, char* last_db) return; print_header(file); fputc('\n', file); - fprintf(file, "Slave: master_host='%s' master_port=%d \ - master_log=%s master_pos=%s\n", + fprintf(file, "Slave: master_host: '%s' master_port: %d \ +master_log: '%s' master_pos: %s\n", master_host, master_port, master_log, llstr(master_pos, llbuff)); } @@ -1791,9 +1795,13 @@ int Rotate_log_event::exec_event(struct st_relay_log_info* rli) { bool rotate_binlog = 0, write_slave_event = 0; char* log_name = rli->master_log_name; + DBUG_ENTER("Rotate_log_event::exec_event"); + pthread_mutex_lock(&rli->data_lock); - // TODO: probably needs re-write - // rotate local binlog only if the name of remote has changed + /* + TODO: probably needs re-write + rotate local binlog only if the name of remote has changed + */ if (!*log_name || !(log_name[ident_len] == 0 && !memcmp(log_name, new_log_ident, ident_len))) { @@ -1801,7 +1809,7 @@ int Rotate_log_event::exec_event(struct st_relay_log_info* rli) && mysql_bin_log.is_open()); rotate_binlog = (*log_name && write_slave_event); if (ident_len >= sizeof(rli->master_log_name)) - return 1; + DBUG_RETURN(1); memcpy(log_name, new_log_ident,ident_len); log_name[ident_len] = 0; } @@ -1812,6 +1820,7 @@ int Rotate_log_event::exec_event(struct st_relay_log_info* rli) mysql_bin_log.new_file(); rli->master_log_pos = 4; } + DBUG_PRINT("info", ("master_log_pos: %d", (ulong) rli->master_log_pos)); pthread_cond_broadcast(&rli->data_cond); pthread_mutex_unlock(&rli->data_lock); flush_relay_log_info(rli); @@ -1826,13 +1835,12 @@ int Rotate_log_event::exec_event(struct st_relay_log_info* rli) mysql_bin_log.write(&s); } } - return 0; + DBUG_RETURN(0); } int Intvar_log_event::exec_event(struct st_relay_log_info* rli) { - switch (type) - { + switch (type) { case LAST_INSERT_ID_EVENT: thd->last_insert_id_used = 1; thd->last_insert_id = val; |