Skip to content

Commit a2c3a12

Browse files
authored
Fix VDisk bugs regarding scrubbing and blob restoration (#21533)
1 parent 101b6e5 commit a2c3a12

File tree

2 files changed

+2
-3
lines changed

2 files changed

+2
-3
lines changed

ydb/core/blobstorage/vdisk/query/query_extr.cpp

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -374,11 +374,11 @@ namespace NKikimr {
374374
if (a) {
375375
auto aid = ctx.Register(a.release());
376376
ActiveActors.Insert(aid, __FILE__, __LINE__, ctx, NKikimrServices::BLOBSTORAGE);
377-
Become(&TThis::StateFunc);
378377
// wait for reply
379378
} else {
380379
Finish(ctx);
381380
}
381+
Become(&TThis::StateFunc);
382382
}
383383

384384
BarriersEssence.Reset();

ydb/core/blobstorage/vdisk/skeleton/blobstorage_skeleton.cpp

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -765,8 +765,7 @@ namespace NKikimr {
765765
const ui64 bufSize = info.Buffer.GetSize();
766766

767767
try {
768-
info.IsHugeBlob = ev->Get()->RewriteBlob || // if we are rewriting a huge blob, keep it that way
769-
HugeBlobCtx->IsHugeBlob(VCtx->Top->GType, id.FullID(), MinHugeBlobInBytes);
768+
info.IsHugeBlob = HugeBlobCtx->IsHugeBlob(VCtx->Top->GType, id.FullID(), MinHugeBlobInBytes);
770769
} catch (yexception ex) {
771770
LOG_ERROR_S(ctx, BS_VDISK_PUT, VCtx->VDiskLogPrefix << ex.what() << " Marker# BSVS41");
772771
info.HullStatus = {NKikimrProto::ERROR, "", false};

0 commit comments

Comments
 (0)