diff options
| author | Teemu Ollakka <teemu.ollakka@galeracluster.com> | 2019-12-16 05:50:15 +0000 |
|---|---|---|
| committer | Jan Lindström <jan.lindstrom@mariadb.com> | 2019-12-16 07:50:15 +0200 |
| commit | 67e063eb94c3b5618d7ccf29bead705605a50fd1 (patch) | |
| tree | c1a80e6ef7751e6e20b155c6fdeaddea4df06e67 | |
| parent | 8fa759a5762733d9f8a4050437fadcd255ecd1a2 (diff) | |
| download | mariadb-git-67e063eb94c3b5618d7ccf29bead705605a50fd1.tar.gz | |
Update wsrep-lib. (#1426)
This commit updates the wsrep-lib. The changes are a cleanup in
client_state TOI processing and stub methods for future extensions.
| -rw-r--r-- | sql/wsrep_high_priority_service.cc | 8 | ||||
| -rw-r--r-- | sql/wsrep_high_priority_service.h | 8 | ||||
| -rw-r--r-- | sql/wsrep_mysqld.cc | 4 | ||||
| m--------- | wsrep-lib | 0 |
4 files changed, 17 insertions, 3 deletions
diff --git a/sql/wsrep_high_priority_service.cc b/sql/wsrep_high_priority_service.cc index a1d39182a46..fa62ada6666 100644 --- a/sql/wsrep_high_priority_service.cc +++ b/sql/wsrep_high_priority_service.cc @@ -509,6 +509,14 @@ int Wsrep_applier_service::apply_write_set(const wsrep::ws_meta& ws_meta, DBUG_RETURN(ret); } +int Wsrep_applier_service::apply_nbo_begin(const wsrep::ws_meta& ws_meta, + const wsrep::const_buffer& data, + wsrep::mutable_buffer& err) +{ + DBUG_ENTER("Wsrep_applier_service::apply_nbo_begin"); + DBUG_RETURN(0); +} + void Wsrep_applier_service::after_apply() { DBUG_ENTER("Wsrep_applier_service::after_apply"); diff --git a/sql/wsrep_high_priority_service.h b/sql/wsrep_high_priority_service.h index cea2b5ccb5c..2c61f0126af 100644 --- a/sql/wsrep_high_priority_service.h +++ b/sql/wsrep_high_priority_service.h @@ -86,6 +86,8 @@ public: ~Wsrep_applier_service(); int apply_write_set(const wsrep::ws_meta&, const wsrep::const_buffer&, wsrep::mutable_buffer&); + int apply_nbo_begin(const wsrep::ws_meta&, const wsrep::const_buffer& data, + wsrep::mutable_buffer& err); void after_apply(); bool is_replaying() const { return false; } bool check_exit_status() const; @@ -98,6 +100,12 @@ public: ~Wsrep_replayer_service(); int apply_write_set(const wsrep::ws_meta&, const wsrep::const_buffer&, wsrep::mutable_buffer&); + int apply_nbo_begin(const wsrep::ws_meta&, const wsrep::const_buffer& data, + wsrep::mutable_buffer& err) + { + DBUG_ASSERT(0); /* DDL should never cause replaying */ + return 0; + } void after_apply() { } bool is_replaying() const { return true; } void replay_status(enum wsrep::provider::status status) diff --git a/sql/wsrep_mysqld.cc b/sql/wsrep_mysqld.cc index 597055c48b1..e7169f1dd91 100644 --- a/sql/wsrep_mysqld.cc +++ b/sql/wsrep_mysqld.cc @@ -1885,9 +1885,7 @@ static int wsrep_TOI_begin(THD *thd, const char *db, const char *table, wsrep::client_state& cs(thd->wsrep_cs()); int ret= cs.enter_toi_local(key_array, - wsrep::const_buffer(buff.ptr, buff.len), - wsrep::provider::flag::start_transaction | - wsrep::provider::flag::commit); + wsrep::const_buffer(buff.ptr, buff.len)); if (ret) { diff --git a/wsrep-lib b/wsrep-lib -Subproject 9b25cebdf11e6da25d83e513a2e4b6db0515aba +Subproject 90157ed1b0f8b3f0d1eb3d60ac93ce6d8da7ad7 |