diff options
| author | Andrew Berlin <aberlin@ydb.tech> | 2024-05-04 05:06:15 +0200 |
|---|---|---|
| committer | GitHub <noreply@github.com> | 2024-05-04 06:06:15 +0300 |
| commit | e95f95a345d8fd6c6529bebc9affc18da4e8056c (patch) | |
| tree | 0af570cfdb243589cc5dd695f9892d61dc466962 | |
| parent | b5497555af4954dfd4409404f417d4d9c4f50c41 (diff) | |
| download | ydb-e95f95a345d8fd6c6529bebc9affc18da4e8056c.tar.gz | |
Initialize MinREALHugeBlobInBytes (#4287)
| -rw-r--r-- | ydb/core/blobstorage/vdisk/skeleton/blobstorage_skeleton.cpp | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/ydb/core/blobstorage/vdisk/skeleton/blobstorage_skeleton.cpp b/ydb/core/blobstorage/vdisk/skeleton/blobstorage_skeleton.cpp index 632faf21a80..20ba724ce1b 100644 --- a/ydb/core/blobstorage/vdisk/skeleton/blobstorage_skeleton.cpp +++ b/ydb/core/blobstorage/vdisk/skeleton/blobstorage_skeleton.cpp @@ -192,6 +192,7 @@ namespace NKikimr { if (!ApplyHugeBlobSize(type.GetMinHugeBlobSizeInBytes())) { continue; } + Y_ABORT_UNLESS(MinREALHugeBlobInBytes); if (Config->RunRepl) { ctx.Send(Db->ReplID, new TEvMinHugeBlobSizeUpdate(MinREALHugeBlobInBytes)); } @@ -1828,6 +1829,7 @@ namespace NKikimr { // check status if (ev->Get()->Status == NKikimrProto::OK) { ApplyHugeBlobSize(Config->MinHugeBlobInBytes); + Y_ABORT_UNLESS(MinREALHugeBlobInBytes); // handle special case when donor disk starts and finds out that it has been wiped out if (ev->Get()->LsnMngr->GetOriginallyRecoveredLsn() == 0 && Config->BaseInfo.DonorMode) { // send drop donor cmd to NodeWarden @@ -2792,7 +2794,7 @@ namespace NKikimr { THullCtxPtr HullCtx; THugeBlobCtxPtr HugeBlobCtx; std::shared_ptr<THullLogCtx> HullLogCtx; - ui32 MinREALHugeBlobInBytes; + ui32 MinREALHugeBlobInBytes = 0; std::shared_ptr<THull> Hull; // run it after local recovery std::shared_ptr<TOutOfSpaceLogic> OutOfSpaceLogic; std::shared_ptr<TQueryCtx> QueryCtx; |