Skip to content

Commit ae498a7

Browse files
authored
Fix replication bug (#16021)
1 parent f99e2a2 commit ae498a7

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

ydb/core/blobstorage/vdisk/repl/blobstorage_hullrepljob.cpp

+4-4
Original file line numberDiff line numberDiff line change
@@ -124,12 +124,12 @@ namespace NKikimr {
124124

125125
if (AddingTasks) {
126126
for (; it.Valid(); it.Next()) {
127+
StartKey = it.GetCurKey().LogoBlobID();
128+
127129
if (checkRestart()) {
128130
return;
129131
}
130132

131-
StartKey = it.GetCurKey().LogoBlobID();
132-
133133
// we still have some space in recovery machine logic, so we can add new item
134134
ProcessItem(it, *barriers, allowKeepFlags);
135135
MilestoneQueue.PopIfNeeded(StartKey);
@@ -147,12 +147,12 @@ namespace NKikimr {
147147
}
148148

149149
for (; it.Valid(); it.Next()) {
150+
StartKey = it.GetCurKey().LogoBlobID();
151+
150152
if (checkRestart()) {
151153
return;
152154
}
153155

154-
StartKey = it.GetCurKey().LogoBlobID();
155-
156156
// check the milestone queue, if we have requested blob
157157
if (MilestoneQueue.Match(StartKey, &ReplInfo->ItemsTotal, &ReplInfo->WorkUnitsTotal)) {
158158
break;

0 commit comments

Comments
 (0)