From 67e063eb94c3b5618d7ccf29bead705605a50fd1 Mon Sep 17 00:00:00 2001 From: Teemu Ollakka Date: Mon, 16 Dec 2019 05:50:15 +0000 Subject: 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. --- sql/wsrep_high_priority_service.cc | 8 ++++++++ sql/wsrep_high_priority_service.h | 8 ++++++++ sql/wsrep_mysqld.cc | 4 +--- wsrep-lib | 2 +- 4 files changed, 18 insertions(+), 4 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 index 9b25cebdf11..90157ed1b0f 160000 --- a/wsrep-lib +++ b/wsrep-lib @@ -1 +1 @@ -Subproject commit 9b25cebdf11e6da25d83e513a2e4b6db0515abad +Subproject commit 90157ed1b0f8b3f0d1eb3d60ac93ce6d8da7ad77 -- cgit v1.2.1