lib/wsrep-lib
1
0
Fork 0
mirror of https://github.com/codership/wsrep-lib.git synced 2025-07-21 12:22:06 +03:00
Code Activity

Add provider position field to ws_meta and view

Browse Source 
Provider position is needed in coordinated recovery
between application and provider. Pass the position
info from provider to application to allow making
it durable.
This commit is contained in:
Teemu Ollakka
2022-03-22 17:43:52 +02:00
parent 51e162d6f4
commit 7498ed424a
13 changed files with 123 additions and 86 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
dbsim/db_server_service.cpp
View File

@ -134,7 +134,8 @@ wsrep::view db::server_service::get_view(wsrep::client_service&,
stored_view.capabilities(), stored_view.capabilities(),
my_idx, my_idx,
stored_view.protocol_version(), stored_view.protocol_version(),
stored_view.members() stored_view.members(),
0
); );
return my_view; return my_view;
} }

10
include/wsrep/provider.hpp
View File

@ -124,21 +124,25 @@ namespace wsrep
, stid_() , stid_()
, depends_on_() , depends_on_()
, flags_() , flags_()
, provider_position_()
{ } { }
ws_meta(const wsrep::gtid& gtid, ws_meta(const wsrep::gtid& gtid,
const wsrep::stid& stid, const wsrep::stid& stid,
wsrep::seqno depends_on, wsrep::seqno depends_on,
int flags) int flags,
int64_t provider_position)
: gtid_(gtid) : gtid_(gtid)
, stid_(stid) , stid_(stid)
, depends_on_(depends_on) , depends_on_(depends_on)
, flags_(flags) , flags_(flags)
, provider_position_(provider_position)
{ } { }
ws_meta(const wsrep::stid& stid) ws_meta(const wsrep::stid& stid)
: gtid_() : gtid_()
, stid_(stid) , stid_(stid)
, depends_on_() , depends_on_()
, flags_() , flags_()
, provider_position_()
{ } { }
const wsrep::gtid& gtid() const { return gtid_; } const wsrep::gtid& gtid() const { return gtid_; }
const wsrep::id& group_id() const const wsrep::id& group_id() const
@ -170,6 +174,8 @@ namespace wsrep
wsrep::seqno depends_on() const { return depends_on_; } wsrep::seqno depends_on() const { return depends_on_; }
int64_t provider_position() const { return provider_position_; }
int flags() const { return flags_; } int flags() const { return flags_; }
bool operator==(const ws_meta& other) const bool operator==(const ws_meta& other) const
@ -186,6 +192,8 @@ namespace wsrep
wsrep::stid stid_; wsrep::stid stid_;
wsrep::seqno depends_on_; wsrep::seqno depends_on_;
int flags_; int flags_;
/** Field reserved for provider to report its internal position. */
int64_t provider_position_;
}; };
std::string flags_to_string(int flags); std::string flags_to_string(int flags);

10
include/wsrep/view.hpp
View File

@ -70,6 +70,7 @@ namespace wsrep
, capabilities_() , capabilities_()
, own_index_(-1) , own_index_(-1)
, protocol_version_(0) , protocol_version_(0)
, provider_position_()
, members_() , members_()
{ } { }
view(const wsrep::gtid& state_id, view(const wsrep::gtid& state_id,
@ -78,13 +79,15 @@ namespace wsrep
int capabilities, int capabilities,
ssize_t own_index, ssize_t own_index,
int protocol_version, int protocol_version,
const std::vector<wsrep::view::member>& members) const std::vector<wsrep::view::member>& members,
int64_t provider_position)
: state_id_(state_id) : state_id_(state_id)
, view_seqno_(view_seqno) , view_seqno_(view_seqno)
, status_(status) , status_(status)
, capabilities_(capabilities) , capabilities_(capabilities)
, own_index_(own_index) , own_index_(own_index)
, protocol_version_(protocol_version) , protocol_version_(protocol_version)
, provider_position_(provider_position)
, members_(members) , members_(members)
{ } { }
@ -111,6 +114,9 @@ namespace wsrep
int protocol_version() const int protocol_version() const
{ return protocol_version_; } { return protocol_version_; }
int64_t provider_position() const
{ return provider_position_; }
const std::vector<member>& members() const const std::vector<member>& members() const
{ return members_; } { return members_; }
@ -147,6 +153,8 @@ namespace wsrep
int capabilities_; int capabilities_;
ssize_t own_index_; ssize_t own_index_;
int protocol_version_; int protocol_version_;
/** Field reserved for provider to report its internal position. */
int64_t provider_position_;
std::vector<wsrep::view::member> members_; std::vector<wsrep::view::member> members_;
}; };

2
src/server_state.cpp
View File

@ -1519,7 +1519,7 @@ void wsrep::server_state::close_orphaned_sr_transactions(
wsrep::ws_meta ws_meta( wsrep::ws_meta ws_meta(
wsrep::gtid(), wsrep::gtid(),
wsrep::stid(server_id, transaction_id, wsrep::client_id()), wsrep::stid(server_id, transaction_id, wsrep::client_id()),
wsrep::seqno::undefined(), 0); wsrep::seqno::undefined(), 0, 0);
lock.unlock(); lock.unlock();
if (adopt_error == 0) if (adopt_error == 0)
{ {

6
src/wsrep_provider_v26.cpp
View File

@ -241,7 +241,7 @@ namespace
sizeof(trx_meta_.stid.node.data)), sizeof(trx_meta_.stid.node.data)),
wsrep::transaction_id(trx_meta_.stid.trx), wsrep::transaction_id(trx_meta_.stid.trx),
wsrep::client_id(trx_meta_.stid.conn)), wsrep::client_id(trx_meta_.stid.conn)),
seqno_from_native(trx_meta_.depends_on), flags_); seqno_from_native(trx_meta_.depends_on), flags_, 0);
} }
wsrep_trx_meta* native() { return &trx_meta_; } wsrep_trx_meta* native() { return &trx_meta_; }
@ -346,7 +346,7 @@ namespace
map_capabilities_from_native(view_info.capabilities), map_capabilities_from_native(view_info.capabilities),
own_idx, own_idx,
view_info.proto_ver, view_info.proto_ver,
members); members, 0);
} }
///////////////////////////////////////////////////////////////////// /////////////////////////////////////////////////////////////////////
@ -500,7 +500,7 @@ namespace
wsrep::transaction_id(meta->stid.trx), wsrep::transaction_id(meta->stid.trx),
wsrep::client_id(meta->stid.conn)), wsrep::client_id(meta->stid.conn)),
wsrep::seqno(seqno_from_native(meta->depends_on)), wsrep::seqno(seqno_from_native(meta->depends_on)),
map_flags_from_native(flags)); map_flags_from_native(flags), 0);
try try
{ {
if (high_priority_service->apply(ws_handle, ws_meta, data)) if (high_priority_service->apply(ws_handle, ws_meta, data))

24
test/client_state_fixture.hpp
View File

@ -171,13 +171,13 @@ namespace
wsrep::seqno seqno) wsrep::seqno seqno)
{ {
wsrep::ws_handle ws_handle(id, (void*)1); wsrep::ws_handle ws_handle(id, (void*)1);
wsrep::ws_meta ws_meta(wsrep::gtid(wsrep::id("1"), seqno), wsrep::ws_meta ws_meta(
wsrep::stid(sc.id(), wsrep::gtid(wsrep::id("1"), seqno),
wsrep::transaction_id(1), wsrep::stid(sc.id(), wsrep::transaction_id(1), cc.id()),
cc.id()),
wsrep::seqno(0), wsrep::seqno(0),
wsrep::provider::flag::start_transaction | wsrep::provider::flag::start_transaction
wsrep::provider::flag::commit); | wsrep::provider::flag::commit,
0);
BOOST_REQUIRE(cc.start_transaction(ws_handle, ws_meta) == 0); BOOST_REQUIRE(cc.start_transaction(ws_handle, ws_meta) == 0);
BOOST_REQUIRE(tc.active() == true); BOOST_REQUIRE(tc.active() == true);
BOOST_REQUIRE(tc.certified() == true); BOOST_REQUIRE(tc.certified() == true);
@ -207,13 +207,13 @@ namespace
BOOST_REQUIRE(cc.before_command() == 0); BOOST_REQUIRE(cc.before_command() == 0);
BOOST_REQUIRE(cc.before_statement() == 0); BOOST_REQUIRE(cc.before_statement() == 0);
wsrep::ws_handle ws_handle(wsrep::transaction_id(1), (void*)1); wsrep::ws_handle ws_handle(wsrep::transaction_id(1), (void*)1);
wsrep::ws_meta ws_meta(wsrep::gtid(wsrep::id("1"), wsrep::seqno(1)), wsrep::ws_meta ws_meta(
wsrep::stid(sc.id(), wsrep::gtid(wsrep::id("1"), wsrep::seqno(1)),
wsrep::transaction_id(1), wsrep::stid(sc.id(), wsrep::transaction_id(1), cc.id()),
cc.id()),
wsrep::seqno(0), wsrep::seqno(0),
wsrep::provider::flag::start_transaction | wsrep::provider::flag::start_transaction
wsrep::provider::flag::commit); | wsrep::provider::flag::commit,
0);
BOOST_REQUIRE(cc.start_transaction(ws_handle, ws_meta) == 0); BOOST_REQUIRE(cc.start_transaction(ws_handle, ws_meta) == 0);
BOOST_REQUIRE(tc.active() == true); BOOST_REQUIRE(tc.active() == true);
BOOST_REQUIRE(tc.certified() == true); BOOST_REQUIRE(tc.certified() == true);

23
test/mock_provider.hpp
View File

@ -116,9 +116,8 @@ namespace wsrep
{ {
++group_seqno_; ++group_seqno_;
wsrep::gtid gtid(group_id_, wsrep::seqno(group_seqno_)); wsrep::gtid gtid(group_id_, wsrep::seqno(group_seqno_));
ws_meta = wsrep::ws_meta(gtid, stid, ws_meta = wsrep::ws_meta(
wsrep::seqno(group_seqno_ - 1), gtid, stid, wsrep::seqno(group_seqno_ - 1), flags, 0);
flags);
return wsrep::provider::success; return wsrep::provider::success;
} }
else else
@ -127,16 +126,15 @@ namespace wsrep
if (it->second.is_undefined()) if (it->second.is_undefined())
{ {
ws_meta = wsrep::ws_meta(wsrep::gtid(), wsrep::stid(), ws_meta = wsrep::ws_meta(wsrep::gtid(), wsrep::stid(),
wsrep::seqno::undefined(), 0); wsrep::seqno::undefined(), 0, 0);
ret = wsrep::provider::error_certification_failed; ret = wsrep::provider::error_certification_failed;
} }
else else
{ {
++group_seqno_; ++group_seqno_;
wsrep::gtid gtid(group_id_, wsrep::seqno(group_seqno_)); wsrep::gtid gtid(group_id_, wsrep::seqno(group_seqno_));
ws_meta = wsrep::ws_meta(gtid, stid, ws_meta = wsrep::ws_meta(
wsrep::seqno(group_seqno_ - 1), gtid, stid, wsrep::seqno(group_seqno_ - 1), flags, 0);
flags);
ret = wsrep::provider::error_bf_abort; ret = wsrep::provider::error_bf_abort;
} }
bf_abort_map_.erase(it); bf_abort_map_.erase(it);
@ -215,8 +213,9 @@ namespace wsrep
wsrep::gtid(group_id_, wsrep::seqno(group_seqno_)), wsrep::gtid(group_id_, wsrep::seqno(group_seqno_)),
wsrep::stid(server_id_, tc.id(), cc.id()), wsrep::stid(server_id_, tc.id(), cc.id()),
wsrep::seqno(group_seqno_ - 1), wsrep::seqno(group_seqno_ - 1),
wsrep::provider::flag::start_transaction | wsrep::provider::flag::start_transaction
wsrep::provider::flag::commit); | wsrep::provider::flag::commit,
0);
} }
else else
{ {
@ -245,12 +244,10 @@ namespace wsrep
{ {
++group_seqno_; ++group_seqno_;
wsrep::gtid gtid(group_id_, wsrep::seqno(group_seqno_)); wsrep::gtid gtid(group_id_, wsrep::seqno(group_seqno_));
wsrep::stid stid(server_id_, wsrep::stid stid(server_id_, wsrep::transaction_id::undefined(),
wsrep::transaction_id::undefined(),
client_id); client_id);
toi_meta = wsrep::ws_meta(gtid, stid, toi_meta = wsrep::ws_meta(gtid, stid,
wsrep::seqno(group_seqno_ - 1), wsrep::seqno(group_seqno_ - 1), flags, 0);
flags);
++toi_write_sets_; ++toi_write_sets_;
if (flags & wsrep::provider::flag::start_transaction) if (flags & wsrep::provider::flag::start_transaction)
++toi_start_transaction_; ++toi_start_transaction_;

6
test/mock_server_state.hpp
View File

@ -147,7 +147,8 @@ namespace wsrep
logged_view_.capabilities(), logged_view_.capabilities(),
my_idx, my_idx,
logged_view_.protocol_version(), logged_view_.protocol_version(),
logged_view_.members() logged_view_.members(),
0
); );
return my_view; return my_view;
} }
@ -292,7 +293,8 @@ namespace wsrep
0, 0,
0, 0,
1, 1,
members); members,
0);
server_state::on_connect(bootstrap_view); server_state::on_connect(bootstrap_view);
} }
else else

12
test/nbo_test.cpp
View File

@ -103,13 +103,11 @@ BOOST_FIXTURE_TEST_CASE(test_applying_nbo,
wsrep::ws_handle ws_handle(wsrep::transaction_id::undefined(), (void*)(1)); wsrep::ws_handle ws_handle(wsrep::transaction_id::undefined(), (void*)(1));
const int nbo_begin_flags(wsrep::provider::flag::start_transaction | const int nbo_begin_flags(wsrep::provider::flag::start_transaction |
wsrep::provider::flag::isolation); wsrep::provider::flag::isolation);
wsrep::ws_meta ws_meta(wsrep::gtid(wsrep::id("cluster1"), wsrep::ws_meta ws_meta(wsrep::gtid(wsrep::id("cluster1"), wsrep::seqno(1)),
wsrep::seqno(1)),
wsrep::stid(wsrep::id("s1"), wsrep::stid(wsrep::id("s1"),
wsrep::transaction_id::undefined(), wsrep::transaction_id::undefined(),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(0), wsrep::seqno(0), nbo_begin_flags, 0);
nbo_begin_flags);
std::string nbo_begin("nbo_begin"); std::string nbo_begin("nbo_begin");
BOOST_REQUIRE(sc.on_apply(hps, ws_handle, ws_meta, BOOST_REQUIRE(sc.on_apply(hps, ws_handle, ws_meta,
wsrep::const_buffer(nbo_begin.data(), wsrep::const_buffer(nbo_begin.data(),
@ -156,13 +154,11 @@ BOOST_FIXTURE_TEST_CASE(test_applying_nbo_fail,
wsrep::ws_handle ws_handle(wsrep::transaction_id::undefined(), (void*)(1)); wsrep::ws_handle ws_handle(wsrep::transaction_id::undefined(), (void*)(1));
const int nbo_begin_flags(wsrep::provider::flag::start_transaction | const int nbo_begin_flags(wsrep::provider::flag::start_transaction |
wsrep::provider::flag::isolation); wsrep::provider::flag::isolation);
wsrep::ws_meta ws_meta(wsrep::gtid(wsrep::id("cluster1"), wsrep::ws_meta ws_meta(wsrep::gtid(wsrep::id("cluster1"), wsrep::seqno(1)),
wsrep::seqno(1)),
wsrep::stid(wsrep::id("s1"), wsrep::stid(wsrep::id("s1"),
wsrep::transaction_id::undefined(), wsrep::transaction_id::undefined(),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(0), wsrep::seqno(0), nbo_begin_flags, 0);
nbo_begin_flags);
std::string nbo_begin("nbo_begin"); std::string nbo_begin("nbo_begin");
hps.fail_next_toi_ = true; hps.fail_next_toi_ = true;
BOOST_REQUIRE(sc.on_apply(hps, ws_handle, ws_meta, BOOST_REQUIRE(sc.on_apply(hps, ws_handle, ws_meta,

69
test/server_context_test.cpp
View File

@ -39,7 +39,8 @@ namespace
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(0), wsrep::seqno(0),
wsrep::provider::flag::start_transaction | wsrep::provider::flag::start_transaction |
wsrep::provider::flag::commit) wsrep::provider::flag::commit,
0)
, cluster_id("1") , cluster_id("1")
, bootstrap_view() , bootstrap_view()
, second_view() , second_view()
@ -55,7 +56,8 @@ namespace
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
members); members,
0);
members.push_back(wsrep::view::member( members.push_back(wsrep::view::member(
wsrep::id("s2"), "s2", "")); wsrep::id("s2"), "s2", ""));
@ -65,7 +67,8 @@ namespace
0, // capabilities 0, // capabilities
1, // own index 1, // own index
1, // protocol version 1, // protocol version
members); members,
0);
members.push_back(wsrep::view::member( members.push_back(wsrep::view::member(
wsrep::id("s3"), "s3", "")); wsrep::id("s3"), "s3", ""));
@ -76,7 +79,8 @@ namespace
0, // capabilities 0, // capabilities
1, // own index 1, // own index
1, // protocol version 1, // protocol version
members); members,
0);
cc.open(cc.id()); cc.open(cc.id());
BOOST_REQUIRE(cc.before_command() == 0); BOOST_REQUIRE(cc.before_command() == 0);
@ -114,7 +118,8 @@ namespace
0, // capabilities 0, // capabilities
-1, // own_index -1, // own_index
0, // protocol ver 0, // protocol ver
std::vector<wsrep::view::member>() // members std::vector<wsrep::view::member>(),// members
0
); );
ss.on_view(view, &hps); ss.on_view(view, &hps);
} }
@ -272,7 +277,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_streaming, applying_server_fixture)
wsrep::transaction_id(1), wsrep::transaction_id(1),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(0), wsrep::seqno(0),
wsrep::provider::flag::start_transaction); wsrep::provider::flag::start_transaction,
0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, ws_meta, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, ws_meta,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);
BOOST_REQUIRE(ss.find_streaming_applier( BOOST_REQUIRE(ss.find_streaming_applier(
@ -282,6 +288,7 @@ BOOST_FIXTURE_TEST_CASE(server_state_streaming, applying_server_fixture)
wsrep::transaction_id(1), wsrep::transaction_id(1),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(1), wsrep::seqno(1),
0,
0); 0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, ws_meta, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, ws_meta,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);
@ -290,7 +297,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_streaming, applying_server_fixture)
wsrep::transaction_id(1), wsrep::transaction_id(1),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(1), wsrep::seqno(1),
wsrep::provider::flag::commit); wsrep::provider::flag::commit,
0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, ws_meta, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, ws_meta,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);
BOOST_REQUIRE(ss.find_streaming_applier( BOOST_REQUIRE(ss.find_streaming_applier(
@ -395,7 +403,8 @@ BOOST_FIXTURE_TEST_CASE(
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
members); members,
0);
ss.on_connect(view); ss.on_connect(view);
BOOST_REQUIRE(ss.state() == wsrep::server_state::s_connected); BOOST_REQUIRE(ss.state() == wsrep::server_state::s_connected);
// As storage engines have been initialized, there should not be // As storage engines have been initialized, there should not be
@ -556,7 +565,8 @@ BOOST_FIXTURE_TEST_CASE(
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
members); members,
0);
ss.on_connect(view); ss.on_connect(view);
BOOST_REQUIRE(ss.state() == wsrep::server_state::s_connected); BOOST_REQUIRE(ss.state() == wsrep::server_state::s_connected);
// As storage engines have been initialized, there should not be // As storage engines have been initialized, there should not be
@ -688,7 +698,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_close_orphaned_transactions,
wsrep::transaction_id(1), wsrep::transaction_id(1),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(1), wsrep::seqno(1),
wsrep::provider::flag::start_transaction); wsrep::provider::flag::start_transaction,
0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s2, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s2,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);
@ -701,7 +712,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_close_orphaned_transactions,
wsrep::transaction_id(1), wsrep::transaction_id(1),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(2), wsrep::seqno(2),
wsrep::provider::flag::start_transaction); wsrep::provider::flag::start_transaction,
0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s3, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s3,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);
@ -717,7 +729,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_close_orphaned_transactions,
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
members), &hps); members,
0), &hps);
// transaction from s2 is still present // transaction from s2 is still present
BOOST_REQUIRE(ss.find_streaming_applier( BOOST_REQUIRE(ss.find_streaming_applier(
@ -735,7 +748,7 @@ BOOST_FIXTURE_TEST_CASE(server_state_close_orphaned_transactions,
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
members), &hps); members, 0), &hps);
// no streaming appliers are closed on non-primary view, // no streaming appliers are closed on non-primary view,
// so transaction from s2 is still present // so transaction from s2 is still present
@ -750,7 +763,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_close_orphaned_transactions,
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
members), &hps); members,
0), &hps);
// transaction s2 is still present after non-primary view // transaction s2 is still present after non-primary view
BOOST_REQUIRE(ss.find_streaming_applier( BOOST_REQUIRE(ss.find_streaming_applier(
@ -764,7 +778,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_close_orphaned_transactions,
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
members), &hps); members,
0), &hps);
// finally, transaction from s2 is still present (part of primary view) // finally, transaction from s2 is still present (part of primary view)
// and transaction from s3 is gone // and transaction from s3 is gone
@ -779,7 +794,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_close_orphaned_transactions,
wsrep::transaction_id(1), wsrep::transaction_id(1),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(3), wsrep::seqno(3),
wsrep::provider::flag::commit); wsrep::provider::flag::commit,
0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_commit_s2, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_commit_s2,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);
@ -806,7 +822,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_equal_consecutive_views,
wsrep::transaction_id(1), wsrep::transaction_id(1),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(1), wsrep::seqno(1),
wsrep::provider::flag::start_transaction); wsrep::provider::flag::start_transaction,
0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s2, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s2,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);
@ -819,7 +836,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_equal_consecutive_views,
wsrep::transaction_id(1), wsrep::transaction_id(1),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(2), wsrep::seqno(2),
wsrep::provider::flag::start_transaction); wsrep::provider::flag::start_transaction,
0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s3, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s3,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);
@ -833,7 +851,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_equal_consecutive_views,
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
ss.current_view().members()), &hps); ss.current_view().members(),
0), &hps);
// transaction from s2 and s3 are gone // transaction from s2 and s3 are gone
BOOST_REQUIRE(not ss.find_streaming_applier( BOOST_REQUIRE(not ss.find_streaming_applier(
@ -862,7 +881,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_xa_not_orphaned,
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(1), wsrep::seqno(1),
wsrep::provider::flag::start_transaction | wsrep::provider::flag::start_transaction |
wsrep::provider::flag::prepare); wsrep::provider::flag::prepare,
0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s3, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_s3,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);
@ -879,7 +899,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_xa_not_orphaned,
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
members), &hps); members,
0), &hps);
// transaction from s3 is still present // transaction from s3 is still present
BOOST_REQUIRE(ss.find_streaming_applier( BOOST_REQUIRE(ss.find_streaming_applier(
@ -893,7 +914,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_xa_not_orphaned,
0, // capabilities 0, // capabilities
0, // own index 0, // own index
1, // protocol version 1, // protocol version
members), &hps); members,
0), &hps);
// transaction from s3 is still present // transaction from s3 is still present
BOOST_REQUIRE(ss.find_streaming_applier( BOOST_REQUIRE(ss.find_streaming_applier(
@ -905,7 +927,8 @@ BOOST_FIXTURE_TEST_CASE(server_state_xa_not_orphaned,
wsrep::transaction_id(1), wsrep::transaction_id(1),
wsrep::client_id(1)), wsrep::client_id(1)),
wsrep::seqno(3), wsrep::seqno(3),
wsrep::provider::flag::commit); wsrep::provider::flag::commit,
0);
BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_commit_s3, BOOST_REQUIRE(ss.on_apply(hps, ws_handle, meta_commit_s3,
wsrep::const_buffer("1", 1)) == 0); wsrep::const_buffer("1", 1)) == 0);

11
test/test_utils.cpp
View File

@ -58,13 +58,10 @@ void wsrep_test::terminate_streaming_applier(
mc.before_command(); mc.before_command();
wsrep::mock_high_priority_service hps(sc, &mc, false); wsrep::mock_high_priority_service hps(sc, &mc, false);
wsrep::ws_handle ws_handle(transaction_id, (void*)(1)); wsrep::ws_handle ws_handle(transaction_id, (void*)(1));
wsrep::ws_meta ws_meta(wsrep::gtid(wsrep::id("cluster1"), wsrep::ws_meta ws_meta(
wsrep::seqno(100)), wsrep::gtid(wsrep::id("cluster1"), wsrep::seqno(100)),
wsrep::stid(server_id, wsrep::stid(server_id, transaction_id, wsrep::client_id(1)),
transaction_id, wsrep::seqno(0), wsrep::provider::flag::rollback, 0);
wsrep::client_id(1)),
wsrep::seqno(0),
wsrep::provider::flag::rollback);
wsrep::const_buffer data(0, 0); wsrep::const_buffer data(0, 0);
sc.on_apply(hps, ws_handle, ws_meta, data); sc.on_apply(hps, ws_handle, ws_meta, data);
} }

12
test/toi_test.cpp
View File

@ -50,13 +50,13 @@ BOOST_FIXTURE_TEST_CASE(test_toi_applying,
applying_client_fixture) applying_client_fixture)
{ {
BOOST_REQUIRE(cc.toi_mode() == wsrep::client_state::m_undefined); BOOST_REQUIRE(cc.toi_mode() == wsrep::client_state::m_undefined);
wsrep::ws_meta ws_meta(wsrep::gtid(wsrep::id("1"), wsrep::seqno(2)), wsrep::ws_meta ws_meta(
wsrep::stid(sc.id(), wsrep::gtid(wsrep::id("1"), wsrep::seqno(2)),
wsrep::transaction_id::undefined(), wsrep::stid(sc.id(), wsrep::transaction_id::undefined(), cc.id()),
cc.id()),
wsrep::seqno(1), wsrep::seqno(1),
wsrep::provider::flag::start_transaction | wsrep::provider::flag::start_transaction
wsrep::provider::flag::commit); | wsrep::provider::flag::commit,
0);
cc.enter_toi_mode(ws_meta); cc.enter_toi_mode(ws_meta);
BOOST_REQUIRE(cc.in_toi()); BOOST_REQUIRE(cc.in_toi());
BOOST_REQUIRE(cc.toi_mode() == wsrep::client_state::m_high_priority); BOOST_REQUIRE(cc.toi_mode() == wsrep::client_state::m_high_priority);

15
test/view_test.cpp
View File

@ -33,7 +33,8 @@ BOOST_AUTO_TEST_CASE(view_test_member_index)
0, 0,
1, 1,
0, 0,
members); members,
0);
BOOST_REQUIRE(view.member_index(wsrep::id("1")) == 0); BOOST_REQUIRE(view.member_index(wsrep::id("1")) == 0);
BOOST_REQUIRE(view.member_index(wsrep::id("2")) == 1); BOOST_REQUIRE(view.member_index(wsrep::id("2")) == 1);
BOOST_REQUIRE(view.member_index(wsrep::id("3")) == 2); BOOST_REQUIRE(view.member_index(wsrep::id("3")) == 2);
@ -64,7 +65,8 @@ BOOST_AUTO_TEST_CASE(view_test_equal_membership)
0, 0,
1, 1,
0, 0,
m1); m1,
0);
wsrep::view v2(wsrep::gtid(wsrep::id("cluster"), wsrep::seqno(1)), wsrep::view v2(wsrep::gtid(wsrep::id("cluster"), wsrep::seqno(1)),
wsrep::seqno(1), wsrep::seqno(1),
@ -72,7 +74,8 @@ BOOST_AUTO_TEST_CASE(view_test_equal_membership)
0, 0,
1, 1,
0, 0,
m2); m2,
0);
wsrep::view v3(wsrep::gtid(wsrep::id("cluster"), wsrep::seqno(1)), wsrep::view v3(wsrep::gtid(wsrep::id("cluster"), wsrep::seqno(1)),
wsrep::seqno(1), wsrep::seqno(1),
@ -80,7 +83,8 @@ BOOST_AUTO_TEST_CASE(view_test_equal_membership)
0, 0,
1, 1,
0, 0,
m3); m3,
0);
BOOST_REQUIRE(v1.equal_membership(v2)); BOOST_REQUIRE(v1.equal_membership(v2));
BOOST_REQUIRE(v2.equal_membership(v1)); BOOST_REQUIRE(v2.equal_membership(v1));
@ -97,7 +101,8 @@ BOOST_AUTO_TEST_CASE(view_test_is_member)
1, 1,
0, 0,
{ wsrep::view::member(wsrep::id("1"), "", ""), { wsrep::view::member(wsrep::id("1"), "", ""),
wsrep::view::member(wsrep::id("2"), "", "") }); wsrep::view::member(wsrep::id("2"), "", "") },
0);
BOOST_REQUIRE(view.is_member(wsrep::id("2"))); BOOST_REQUIRE(view.is_member(wsrep::id("2")));
BOOST_REQUIRE(view.is_member(wsrep::id("1"))); BOOST_REQUIRE(view.is_member(wsrep::id("1")));