diff options
author | unknown <brian@zim.(none)> | 2006-03-23 05:51:31 -0800 |
---|---|---|
committer | unknown <brian@zim.(none)> | 2006-03-23 05:51:31 -0800 |
commit | fd8513fa9d577b3185ed9fd18816e0af5e5932f0 (patch) | |
tree | 798167a87d35cff6ca6dc3c86b71b000dd60d31e /sql/sql_repl.cc | |
parent | 5ae7cf461e546bdade15ba21293c1bb4c3289c86 (diff) | |
download | mariadb-git-fd8513fa9d577b3185ed9fd18816e0af5e5932f0.tar.gz |
Refactored some code to remove ifdef and removed dead code related to un-useable sync code.
sql/ha_innodb.cc:
Removing dead code
sql/handler.cc:
Removing dead code
sql/handler.h:
Removing Dead code
sql/sql_class.cc:
Removing unneeded ifdef code.
sql/sql_repl.cc:
Removing dead code.
Diffstat (limited to 'sql/sql_repl.cc')
-rw-r--r-- | sql/sql_repl.cc | 21 |
1 files changed, 0 insertions, 21 deletions
diff --git a/sql/sql_repl.cc b/sql/sql_repl.cc index 743a0a6b565..e900d33f743 100644 --- a/sql/sql_repl.cc +++ b/sql/sql_repl.cc @@ -386,9 +386,6 @@ impossible position"; goto err; } - if (thd->variables.sync_replication) - ha_repl_report_sent_binlog(thd, log_file_name, pos); - /* We need to start a packet with something other than 255 to distinguish it from error @@ -475,9 +472,6 @@ impossible position"; goto err; } - if (thd->variables.sync_replication) - ha_repl_report_sent_binlog(thd, log_file_name, my_b_tell(&log)); - /* No need to save this event. We are only doing simple reads (no real parsing of the events) so we don't need it. And so @@ -536,9 +530,6 @@ impossible position"; goto err; } - if (thd->variables.sync_replication) - ha_repl_report_sent_binlog(thd, log_file_name, my_b_tell(&log)); - DBUG_PRINT("info", ("log event code %d", (*packet)[LOG_EVENT_OFFSET+1] )); if ((*packet)[LOG_EVENT_OFFSET+1] == LOAD_EVENT) @@ -652,9 +643,6 @@ impossible position"; goto err; } - if (thd->variables.sync_replication) - ha_repl_report_sent_binlog(thd, log_file_name, my_b_tell(&log)); - if ((*packet)[LOG_EVENT_OFFSET+1] == LOAD_EVENT) { if (send_file(thd)) @@ -721,18 +709,12 @@ impossible position"; goto err; } - if (thd->variables.sync_replication) - ha_repl_report_sent_binlog(thd, log_file_name, 0); - packet->length(0); packet->append('\0'); } } end: - if (thd->variables.sync_replication) - ha_repl_report_replication_stop(thd); - end_io_cache(&log); (void)my_close(file, MYF(MY_WME)); @@ -744,9 +726,6 @@ end: DBUG_VOID_RETURN; err: - if (thd->variables.sync_replication) - ha_repl_report_replication_stop(thd); - thd->proc_info = "Waiting to finalize termination"; end_io_cache(&log); /* |