mirrors/scylladb
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

test/boost: memtable_test: perform schema operations on shard 0

Browse Source 
Will be a prerequisite with Raft enabled.
This commit is contained in:
Kamil Braun
2022-06-19 22:48:10 +02:00
parent 3be376f6c5
commit 411231da75
1 changed files with 12 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

22
test/boost/memtable_test.cc
View File

@@ -959,19 +959,21 @@ SEASTAR_TEST_CASE(flushing_rate_is_reduced_if_compaction_doesnt_keep_up) {
}
future<> create_table(schema_ptr s) {
service::migration_manager& mm = env.migration_manager().local();
auto group0_guard = co_await mm.start_group0_operation();
auto ts = group0_guard.write_timestamp();
auto announcement = co_await mm.prepare_new_column_family_announcement(s, ts);
co_await mm.announce(std::move(announcement), std::move(group0_guard));
return env.migration_manager().invoke_on(0, [s = global_schema_ptr(std::move(s))] (service::migration_manager& mm) -> future<> {
auto group0_guard = co_await mm.start_group0_operation();
auto ts = group0_guard.write_timestamp();
auto announcement = co_await mm.prepare_new_column_family_announcement(s, ts);
co_await mm.announce(std::move(announcement), std::move(group0_guard));
});
}
future<> drop_table() {
service::migration_manager& mm = env.migration_manager().local();
auto group0_guard = co_await mm.start_group0_operation();
auto ts = group0_guard.write_timestamp();
auto announcement = co_await mm.prepare_column_family_drop_announcement(ks_name(), cf_name(this_shard_id()), api::new_timestamp());
co_await mm.announce(std::move(announcement), std::move(group0_guard));
return env.migration_manager().invoke_on(0, [shard = this_shard_id()] (service::migration_manager& mm) -> future<> {
auto group0_guard = co_await mm.start_group0_operation();
auto ts = group0_guard.write_timestamp();
auto announcement = co_await mm.prepare_column_family_drop_announcement(ks_name(), cf_name(shard), ts);
co_await mm.announce(std::move(announcement), std::move(group0_guard));
});
}
future<> operator()() {