7ff0d7ba98
This commit eliminates unused boost header includes from the tree. Removing these unnecessary includes reduces dependencies on the external Boost.Adapters library, leading to faster compile times and a slightly cleaner codebase. Signed-off-by: Kefu Chai <kefu.chai@scylladb.com> Closes scylladb/scylladb#22857
96 lines
3.4 KiB
C++
96 lines
3.4 KiB
C++
/*
|
|
* Copyright (C) 2018-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: LicenseRef-ScyllaDB-Source-Available-1.0
|
|
*/
|
|
|
|
#define BOOST_TEST_MODULE partition_data
|
|
#include <boost/test/unit_test.hpp>
|
|
|
|
#include <random>
|
|
|
|
#include "test/lib/random_utils.hh"
|
|
#include "utils/disk-error-handler.hh"
|
|
#include "mutation/atomic_cell.hh"
|
|
#include "types/types.hh"
|
|
|
|
BOOST_AUTO_TEST_CASE(test_atomic_cell) {
|
|
struct test_case {
|
|
bool live;
|
|
bool fixed_size;
|
|
bytes value;
|
|
bool expiring;
|
|
bool counter_update;
|
|
};
|
|
|
|
auto cases = std::vector<test_case> {
|
|
// Live, fixed-size, empty cell
|
|
{ true, true, bytes(), false },
|
|
// Live, small cell
|
|
{ true, false, tests::random::get_bytes(1024), false, false },
|
|
// Live, large cell
|
|
{ true, false, tests::random::get_bytes(129 * 1024), false, false },
|
|
// Live, empty cell
|
|
{ true, false, bytes(), false, false },
|
|
// Live, expiring cell
|
|
{ true, false, tests::random::get_bytes(1024), true, false },
|
|
// Dead cell
|
|
{ false, false, bytes(), false, false },
|
|
// Counter update cell
|
|
{ true, false, bytes(), false, true },
|
|
};
|
|
|
|
for (auto tc : cases) {
|
|
auto& live = tc.live;
|
|
auto& value = tc.value;
|
|
auto& expiring = tc.expiring;
|
|
auto& counter_update = tc.counter_update;
|
|
auto timestamp = tests::random::get_int<api::timestamp_type>();
|
|
auto ttl = gc_clock::duration(tests::random::get_int<int32_t>(1, std::numeric_limits<int32_t>::max()));
|
|
auto expiry_time = gc_clock::time_point(gc_clock::duration(tests::random::get_int<int32_t>(1, std::numeric_limits<int32_t>::max())));
|
|
auto deletion_time = expiry_time;
|
|
auto counter_update_value = tests::random::get_int<int64_t>();
|
|
|
|
auto test_cell = [&] (auto cell) {
|
|
auto verify_cell = [&] (auto view) {
|
|
if (!live) {
|
|
BOOST_CHECK(!view.is_live());
|
|
BOOST_CHECK(view.deletion_time() == deletion_time);
|
|
return;
|
|
}
|
|
BOOST_CHECK(view.is_live());
|
|
BOOST_CHECK_EQUAL(view.timestamp(), timestamp);
|
|
if (counter_update) {
|
|
BOOST_CHECK(view.is_counter_update());
|
|
BOOST_CHECK_EQUAL(view.counter_update_value(), counter_update_value);
|
|
} else {
|
|
BOOST_CHECK(!view.is_counter_update());
|
|
BOOST_CHECK(view.value() == managed_bytes_view(bytes_view(value)));
|
|
}
|
|
BOOST_CHECK_EQUAL(view.is_live_and_has_ttl(), expiring);
|
|
if (expiring) {
|
|
BOOST_CHECK(view.ttl() == ttl);
|
|
BOOST_CHECK(view.expiry() == expiry_time);
|
|
}
|
|
};
|
|
|
|
auto view = atomic_cell_view(cell);
|
|
verify_cell(view);
|
|
};
|
|
|
|
if (live) {
|
|
if (counter_update) {
|
|
test_cell(atomic_cell::make_live_counter_update(timestamp, counter_update_value));
|
|
} else if (expiring) {
|
|
test_cell(atomic_cell::make_live(*bytes_type, timestamp, value, expiry_time, ttl));
|
|
} else {
|
|
test_cell(atomic_cell::make_live(*bytes_type, timestamp, value));
|
|
}
|
|
} else {
|
|
test_cell(atomic_cell::make_dead(timestamp, deletion_time));
|
|
}
|
|
}
|
|
}
|