File tree Expand file tree Collapse file tree 1 file changed +5
-1
lines changed
ydb/core/blobstorage/vdisk/repl Expand file tree Collapse file tree 1 file changed +5
-1
lines changed Original file line number Diff line number Diff line change @@ -177,6 +177,7 @@ namespace NKikimr {
177
177
bool UnrecoveredNonphantomBlobs = false ;
178
178
bool RequestedReplicationToken = false ;
179
179
bool HoldingReplicationToken = false ;
180
+ bool CanDropDonor = false ;
180
181
181
182
TWatchdogTimer<TEvReplCheckProgress> ReplProgressWatchdog;
182
183
@@ -280,6 +281,7 @@ namespace NKikimr {
280
281
// switch to planning state
281
282
Transition (Relaxation, Plan);
282
283
284
+ CanDropDonor = true ;
283
285
RunRepl (TLogoBlobID ());
284
286
}
285
287
@@ -375,6 +377,8 @@ namespace NKikimr {
375
377
ResetReplProgressTimer (false );
376
378
}
377
379
380
+ CanDropDonor = CanDropDonor && info->DropDonor ;
381
+
378
382
bool finished = false ;
379
383
380
384
if (info->Eof ) { // when it is the last quantum for some donor, rotate the blob sets
@@ -399,7 +403,7 @@ namespace NKikimr {
399
403
}
400
404
}
401
405
if (!finished) {
402
- if (info-> DropDonor ) {
406
+ if (CanDropDonor ) {
403
407
Y_ABORT_UNLESS (!DonorQueue.empty () && DonorQueue.front ());
404
408
DropDonor (*DonorQueue.front ());
405
409
DonorQueue.pop_front ();
You can’t perform that action at this time.
0 commit comments