Skip to content

Commit

Permalink
Fix failing asan tests (#13105)
Browse files Browse the repository at this point in the history
  • Loading branch information
mregrock authored Dec 28, 2024
1 parent 731cf81 commit 312885a
Showing 1 changed file with 4 additions and 2 deletions.
6 changes: 4 additions & 2 deletions ydb/core/mind/bscontroller/console_interaction.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -54,8 +54,8 @@ namespace NKikimr::NBsController {

void TBlobStorageController::TConsoleInteraction::MakeGetBlock() {
auto ev = MakeHolder<TEvBlobStorage::TEvGetBlock>(Self.TabletID(), TInstant::Max());
auto proxyId = MakeBlobStorageProxyID(Self.Info()->GroupFor(0, Self.Executor()->Generation()));
TActivationContext::Schedule(TDuration::MilliSeconds(GetBlockBackoff.NextBackoffMs()), new IEventHandle(proxyId, Self.SelfId(), ev.Release()));
auto bsProxyEv = CreateEventForBSProxy(Self.SelfId(), Self.Info()->GroupFor(0, Self.Executor()->Generation()), ev.Release(), 0);
TActivationContext::Schedule(TDuration::MilliSeconds(GetBlockBackoff.NextBackoffMs()), bsProxyEv);
}

void TBlobStorageController::TConsoleInteraction::MakeRetrySession() {
Expand Down Expand Up @@ -238,11 +238,13 @@ namespace NKikimr::NBsController {
case NKikimrProto::OK:
if (generation <= blockedGeneration) {
Self.PassAway();
return;
}
if (generation == blockedGeneration + 1 && NeedRetrySession) {
MakeRetrySession();
return;
}
Y_VERIFY_DEBUG_S(generation == blockedGeneration + 1, "BlockedGeneration#" << blockedGeneration << " Tablet generation#" << generation);
break;
case NKikimrProto::BLOCKED:
Self.PassAway();
Expand Down

0 comments on commit 312885a

Please sign in to comment.