summaryrefslogtreecommitdiff
path: root/sql/rpl_injector.cc
diff options
context:
space:
mode:
authorVicențiu Ciorbaru <vicentiu@mariadb.org>2015-04-02 19:22:41 +0300
committerVicențiu Ciorbaru <vicentiu@mariadb.org>2015-06-30 13:17:09 +0300
commitc096caee71b35198d9f1fb35d1fbd5ea796cf878 (patch)
treef0b06e1b3cc6dcfa3f23db295e90f5052b4c3d23 /sql/rpl_injector.cc
parente53ad95b733e5a3b67b31d231616b619b634c6da (diff)
downloadmariadb-git-c096caee71b35198d9f1fb35d1fbd5ea796cf878.tar.gz
[MDEV-6877] Removed unneded code from rpl_injector
The rpl_injector code is now considered dead code. This patch only removes the minimum number of function calls to allow implementing binlog_row_image. The other functions are to be removed in a subsequent patch.
Diffstat (limited to 'sql/rpl_injector.cc')
-rw-r--r--sql/rpl_injector.cc56
1 files changed, 0 insertions, 56 deletions
diff --git a/sql/rpl_injector.cc b/sql/rpl_injector.cc
index 19b193729fd..caa84d867ad 100644
--- a/sql/rpl_injector.cc
+++ b/sql/rpl_injector.cc
@@ -118,62 +118,6 @@ int injector::transaction::use_table(server_id_type sid, table tbl)
}
-int injector::transaction::write_row (server_id_type sid, table tbl,
- MY_BITMAP const* cols, size_t colcnt,
- record_type record)
-{
- DBUG_ENTER("injector::transaction::write_row(...)");
-
- int error= check_state(ROW_STATE);
- if (error)
- DBUG_RETURN(error);
-
- server_id_type save_id= m_thd->variables.server_id;
- m_thd->set_server_id(sid);
- error= m_thd->binlog_write_row(tbl.get_table(), tbl.is_transactional(),
- cols, colcnt, record);
- m_thd->set_server_id(save_id);
- DBUG_RETURN(error);
-}
-
-
-int injector::transaction::delete_row(server_id_type sid, table tbl,
- MY_BITMAP const* cols, size_t colcnt,
- record_type record)
-{
- DBUG_ENTER("injector::transaction::delete_row(...)");
-
- int error= check_state(ROW_STATE);
- if (error)
- DBUG_RETURN(error);
-
- server_id_type save_id= m_thd->variables.server_id;
- m_thd->set_server_id(sid);
- error= m_thd->binlog_delete_row(tbl.get_table(), tbl.is_transactional(),
- cols, colcnt, record);
- m_thd->set_server_id(save_id);
- DBUG_RETURN(error);
-}
-
-
-int injector::transaction::update_row(server_id_type sid, table tbl,
- MY_BITMAP const* cols, size_t colcnt,
- record_type before, record_type after)
-{
- DBUG_ENTER("injector::transaction::update_row(...)");
-
- int error= check_state(ROW_STATE);
- if (error)
- DBUG_RETURN(error);
-
- server_id_type save_id= m_thd->variables.server_id;
- m_thd->set_server_id(sid);
- error= m_thd->binlog_update_row(tbl.get_table(), tbl.is_transactional(),
- cols, colcnt, before, after);
- m_thd->set_server_id(save_id);
- DBUG_RETURN(error);
-}
-
injector::transaction::binlog_pos injector::transaction::start_pos() const
{