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/
108 lines
2.6 KiB
C++
108 lines
2.6 KiB
C++
/*
|
|
* Modified by ScyllaDB
|
|
* Copyright (C) 2015-present ScyllaDB
|
|
*/
|
|
|
|
/*
|
|
* SPDX-License-Identifier: (LicenseRef-ScyllaDB-Source-Available-1.0 and Apache-2.0)
|
|
*/
|
|
|
|
#pragma once
|
|
|
|
#include <stdint.h>
|
|
#include "schema/schema_fwd.hh"
|
|
#include "utils/hash.hh"
|
|
#include "sstables/version.hh"
|
|
#include "seastarx.hh"
|
|
|
|
namespace db {
|
|
|
|
using segment_id_type = uint64_t;
|
|
using position_type = uint32_t;
|
|
|
|
struct replay_position {
|
|
static constexpr size_t max_cpu_bits = 10; // 1024 cpus. should be enough for anyone
|
|
static constexpr size_t max_ts_bits = 8 * sizeof(segment_id_type) - max_cpu_bits;
|
|
static constexpr segment_id_type ts_mask = (segment_id_type(1) << max_ts_bits) - 1;
|
|
static constexpr segment_id_type cpu_mask = ~ts_mask;
|
|
|
|
segment_id_type id;
|
|
position_type pos;
|
|
|
|
replay_position(segment_id_type i = 0, position_type p = 0)
|
|
: id(i), pos(p)
|
|
{}
|
|
|
|
replay_position(unsigned shard, segment_id_type i, position_type p = 0)
|
|
: id((segment_id_type(shard) << max_ts_bits) | i), pos(p)
|
|
{
|
|
if (i & cpu_mask) {
|
|
throw std::invalid_argument("base id overflow: " + std::to_string(i));
|
|
}
|
|
}
|
|
|
|
auto operator<=>(const replay_position&) const noexcept = default;
|
|
|
|
unsigned shard_id() const {
|
|
return unsigned(id >> max_ts_bits);
|
|
}
|
|
segment_id_type base_id() const {
|
|
return id & ts_mask;
|
|
}
|
|
replay_position base() const {
|
|
return replay_position(base_id(), pos);
|
|
}
|
|
|
|
template <typename Describer>
|
|
auto describe_type(sstables::sstable_version_types v, Describer f) { return f(id, pos); }
|
|
};
|
|
|
|
class commitlog;
|
|
class cf_holder;
|
|
|
|
using cf_id_type = table_id;
|
|
|
|
class rp_handle {
|
|
public:
|
|
rp_handle() noexcept;
|
|
rp_handle(rp_handle&&) noexcept;
|
|
rp_handle& operator=(rp_handle&&) noexcept;
|
|
~rp_handle();
|
|
|
|
replay_position release();
|
|
|
|
operator bool() const {
|
|
return _h && _rp != replay_position();
|
|
}
|
|
operator const replay_position&() const {
|
|
return _rp;
|
|
}
|
|
const replay_position& rp() const {
|
|
return _rp;
|
|
}
|
|
private:
|
|
friend class commitlog;
|
|
|
|
rp_handle(shared_ptr<cf_holder>, cf_id_type, replay_position) noexcept;
|
|
|
|
::shared_ptr<cf_holder> _h;
|
|
cf_id_type _cf;
|
|
replay_position _rp;
|
|
};
|
|
|
|
}
|
|
|
|
namespace std {
|
|
template <>
|
|
struct hash<db::replay_position> {
|
|
size_t operator()(const db::replay_position& v) const {
|
|
return utils::tuple_hash()(v.id, v.pos);
|
|
}
|
|
};
|
|
}
|
|
|
|
template <> struct fmt::formatter<db::replay_position> {
|
|
constexpr auto parse(format_parse_context& ctx) { return ctx.begin(); }
|
|
auto format(const db::replay_position&, fmt::format_context& ctx) const -> decltype(ctx.out());
|
|
};
|