Skip to content

Commit

Permalink
change state manager version to enum
Browse files Browse the repository at this point in the history
  • Loading branch information
antoniofilipovic committed Jun 7, 2024
1 parent 330489c commit 76a574e
Showing 1 changed file with 6 additions and 4 deletions.
10 changes: 6 additions & 4 deletions src/coordination/coordinator_state_manager.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -37,7 +37,9 @@ constexpr std::string_view kTerm = "term";
constexpr std::string_view kElectionTimer = "election_timer";

constexpr std::string_view kStateManagerDurabilityVersionKey = "state_manager_durability_version";
constexpr int kActiveStateManagerDurabilityVersion = 1;

enum class StateManagerDurabilityVersion : int { kV1 = 1 };
constexpr StateManagerDurabilityVersion kActiveStateManagerDurabilityVersion{StateManagerDurabilityVersion::kV1};

constexpr std::string_view kServers = "servers";
constexpr std::string_view kPrevLogIdx = "prev_log_idx";
Expand Down Expand Up @@ -92,10 +94,10 @@ CoordinatorStateManager::CoordinatorStateManager(CoordinatorStateManagerConfig c
cluster_config_ = cs_new<cluster_config>();
cluster_config_->get_servers().push_back(my_srv_config_);

auto const version = memgraph::coordination::GetVersion(durability_, kStateManagerDurabilityVersionKey,
kActiveStateManagerDurabilityVersion, logger_);
auto const version = memgraph::coordination::GetVersion(
durability_, kStateManagerDurabilityVersionKey, static_cast<int>(kActiveStateManagerDurabilityVersion), logger_);

MG_ASSERT(version <= kActiveStateManagerDurabilityVersion && version > 0,
MG_ASSERT(static_cast<StateManagerDurabilityVersion>(version) != kActiveStateManagerDurabilityVersion,
"Unsupported version of log store with durability");
}

Expand Down

0 comments on commit 76a574e

Please sign in to comment.