diff options
| author | alexvru <alexvru@ydb.tech> | 2023-03-15 16:03:03 +0300 |
|---|---|---|
| committer | alexvru <alexvru@ydb.tech> | 2023-03-15 16:03:03 +0300 |
| commit | 85fddb28e49cbc19fa01983cc3663a3b7d49c0cb (patch) | |
| tree | 5cf17e6b4a7f356428404de598d83c8963ed1aff | |
| parent | 436d33639b5e19bedca39b32f1ab5bbd80827d46 (diff) | |
| download | ydb-85fddb28e49cbc19fa01983cc3663a3b7d49c0cb.tar.gz | |
Fix BlobDepot bugs
| -rw-r--r-- | ydb/core/blob_depot/data_decommit.cpp | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/ydb/core/blob_depot/data_decommit.cpp b/ydb/core/blob_depot/data_decommit.cpp index bda6c47961..26b3b8f682 100644 --- a/ydb/core/blob_depot/data_decommit.cpp +++ b/ydb/core/blob_depot/data_decommit.cpp @@ -96,7 +96,7 @@ namespace NKikimr::NBlobDepot { TCoroTx::RestartTx(); } const TValue *value = Self->Data->FindKey(key); - const bool doGet = (!value && key.GetBlobId() < Self->Data->LastAssimilatedBlobId) // value not yet assimilated + const bool doGet = (!value && Self->Data->LastAssimilatedBlobId < key.GetBlobId()) // value not yet assimilated || (value && value->GoingToAssimilate && item.GetMustRestoreFirst()); // value has no local data yet if (doGet) { InvokeOtherActor(*this, &TThis::IssueGet, key.GetBlobId(), item.GetMustRestoreFirst()); @@ -111,7 +111,7 @@ namespace NKikimr::NBlobDepot { } TCoroTx::FinishTx(); - CheckIfDone(); + InvokeOtherActor(*this, &TThis::CheckIfDone); } void ScanRangeAndIssueGets(TKey from, TKey to, TScanFlags flags) { |