diff options
| author | Kristian Nielsen <knielsen@knielsen-hq.org> | 2014-12-05 16:09:48 +0100 |
|---|---|---|
| committer | Kristian Nielsen <knielsen@knielsen-hq.org> | 2014-12-06 08:49:50 +0100 |
| commit | db21fddc3740dfa48f3443751c48282467afac5e (patch) | |
| tree | 3ed31a4a5ce9abf3fe98cdd9c9bdf68ba8b5832b /sql/sql_delete.cc | |
| parent | 1e3f09f1638e2bdec6029f6c98317d17d7ca76d1 (diff) | |
| download | mariadb-git-db21fddc3740dfa48f3443751c48282467afac5e.tar.gz | |
MDEV-6676: Optimistic parallel replication
Implement a new mode for parallel replication. In this mode, all transactions
are optimistically attempted applied in parallel. In case of conflicts, the
offending transaction is rolled back and retried later non-parallel.
This is an early-release patch to facilitate testing, more changes to user
interface / options will be expected. The new mode is not enabled by default.
Diffstat (limited to 'sql/sql_delete.cc')
| -rw-r--r-- | sql/sql_delete.cc | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/sql/sql_delete.cc b/sql/sql_delete.cc index b32d2257a21..e16aade6bcb 100644 --- a/sql/sql_delete.cc +++ b/sql/sql_delete.cc @@ -1089,6 +1089,8 @@ void multi_delete::abort_result_set() if (thd->transaction.stmt.modified_non_trans_table) thd->transaction.all.modified_non_trans_table= TRUE; + thd->transaction.all.m_unsafe_rollback_flags|= + (thd->transaction.stmt.m_unsafe_rollback_flags & THD_TRANS::DID_WAIT); /* If rows from the first table only has been deleted and it is @@ -1280,6 +1282,8 @@ bool multi_delete::send_eof() if (thd->transaction.stmt.modified_non_trans_table) thd->transaction.all.modified_non_trans_table= TRUE; + thd->transaction.all.m_unsafe_rollback_flags|= + (thd->transaction.stmt.m_unsafe_rollback_flags & THD_TRANS::DID_WAIT); /* We must invalidate the query cache before binlog writing and |