mirrors/dragonfly
1
0
Fork 0
mirror of https://github.com/dragonflydb/dragonfly.git synced 2025-05-11 18:35:46 +02:00
Code Issues Projects Releases Packages Wiki Activity Actions 5

feat server: support partial sync from last master

Browse source 
Signed-off-by: adi_holden <adi@dragonflydb.io>
This commit is contained in:
adi_holden 2025-04-28 14:51:26 +03:00
parent 614096d547
commit a90a5a28b5
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
src/server/replica.cc
View file

@ -141,7 +141,6 @@ std::optional<Replica::LastMasterSyncData> Replica::Stop() {
VLOG(1) << "Stopping replication " << this;
// Stops the loop in MainReplicationFb.
// bool is_stable_sync = state_mask_.load() & R_SYNC_OK;
proactor_->Await([this] {
state_mask_.store(0); // Specifically ~R_ENABLED.
exec_st_.ReportCancelError(); // Context is fully resposible for cleanup.
@ -155,6 +154,7 @@ std::optional<Replica::LastMasterSyncData> Replica::Stop() {
for (auto& flow : shard_flows_) {
flow.reset();
}
if (last_journal_LSNs_.has_value()) {
LastMasterSyncData data;
data.id = master_context_.master_repl_id;