tursom/memgraph
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Improve restore replication role (#1089)

Browse Source
This commit is contained in:
Andi 2023-08-01 21:51:52 +02:00 committed by GitHub
parent 514fed51c4
commit f0bac53e7b
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 16 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
src/storage/v2/inmemory/storage.cpp
View File

@ -1973,28 +1973,26 @@ void InMemoryStorage::RestoreReplicationRole() {
} }
spdlog::info("Restoring replication role."); spdlog::info("Restoring replication role.");
uint16_t port = replication::kDefaultReplicationPort; uint16_t port = replication::kDefaultReplicationPort;
for (const auto &[replica_name, replica_data] : *storage_) {
const auto maybe_replica_status = replication::JSONToReplicationStatus(nlohmann::json::parse(replica_data));
if (!maybe_replica_status.has_value()) {
LOG_FATAL("Cannot parse previously saved configuration of replica {}.", replica_name);
}
if (replica_name != replication::kReservedReplicationRoleName) { const auto replication_data = storage_->Get(replication::kReservedReplicationRoleName);
continue; if (!replication_data.has_value()) {
} spdlog::debug("Cannot find data needed for restore replication role in persisted metadata.");
return;
}
auto replica_status = *maybe_replica_status; const auto maybe_replication_status = replication::JSONToReplicationStatus(nlohmann::json::parse(*replication_data));
if (!maybe_replication_status.has_value()) {
LOG_FATAL("Cannot parse previously saved configuration of replication role {}.",
replication::kReservedReplicationRoleName);
}
if (!replica_status.role.has_value()) { const auto replication_status = *maybe_replication_status;
replication_role_.store(replication::ReplicationRole::MAIN); if (!replication_status.role.has_value()) {
} else { replication_role_.store(replication::ReplicationRole::MAIN);
replication_role_.store(*replica_status.role); } else {
port = replica_status.port; replication_role_.store(*replication_status.role);
} port = replication_status.port;
break;
} }
if (replication_role_ == replication::ReplicationRole::REPLICA) { if (replication_role_ == replication::ReplicationRole::REPLICA) {