mirror of
https://github.com/scylladb/scylladb.git
synced 2026-04-25 19:10:42 +00:00
f3eade2f62
Drop the AGPL license in favor of a source-available license. See the blog post [1] for details. [1] https://www.scylladb.com/2024/12/18/why-were-moving-to-a-source-available-license/
58 lines
1.7 KiB
C++
58 lines
1.7 KiB
C++
/*
|
|
* Copyright (C) 2021-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#include "test/lib/alternator_test_env.hh"
|
|
#include "alternator/rmw_operation.hh"
|
|
#include "replica/database.hh"
|
|
#include <seastar/core/coroutine.hh>
|
|
|
|
#include "service/storage_proxy.hh"
|
|
|
|
using namespace std::chrono_literals;
|
|
|
|
future<> alternator_test_env::start(std::string_view isolation_level) {
|
|
smp_service_group_config c;
|
|
c.max_nonlocal_requests = 5000;
|
|
smp_service_group ssg = co_await create_smp_service_group(c);
|
|
utils::updateable_value<uint32_t> timeout_in_ms;
|
|
|
|
co_await _sdks.start(std::ref(_qp), std::ref(_mm), std::ref(_proxy));
|
|
co_await _cdc_metadata.start();
|
|
auto get_timeout_in_ms = sharded_parameter([] {
|
|
std::chrono::milliseconds ms = 10s;
|
|
return utils::updateable_value<uint32_t>(ms.count());
|
|
});
|
|
co_await _executor.start(
|
|
std::ref(_gossiper),
|
|
std::ref(_proxy),
|
|
std::ref(_mm),
|
|
// parameters below are only touched by alternator streams;
|
|
// not really interesting for this use case
|
|
std::ref(_sdks),
|
|
std::ref(_cdc_metadata),
|
|
// end-of-streams-parameters
|
|
ssg,
|
|
get_timeout_in_ms);
|
|
try {
|
|
alternator::rmw_operation::set_default_write_isolation(isolation_level);
|
|
} catch (const std::runtime_error& e) {
|
|
std::cout << e.what() << std::endl;
|
|
throw;
|
|
}
|
|
}
|
|
|
|
future<> alternator_test_env::stop() {
|
|
co_await _executor.stop();
|
|
co_await _cdc_metadata.stop();
|
|
co_await _sdks.stop();
|
|
}
|
|
|
|
future<> alternator_test_env::flush_memtables() {
|
|
return _proxy.local().get_db().invoke_on_all(&replica::database::flush_all_memtables);
|
|
}
|