Skip to content

Commit

Permalink
fix tests
Browse files Browse the repository at this point in the history
  • Loading branch information
yegorskii committed Jan 26, 2024
1 parent 2dd31e0 commit 470a891
Showing 1 changed file with 8 additions and 8 deletions.
16 changes: 8 additions & 8 deletions cloud/blockstore/libs/storage/volume/volume_ut_stats.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -43,7 +43,7 @@ Y_UNIT_TEST_SUITE(TVolumeStatsTest)
ui64 bytesCount = 0;
ui32 partStatsSaved = 0;

auto obs = [&] (TAutoPtr<IEventHandle>& event) {
auto obs = [&] (auto& runtime, TAutoPtr<IEventHandle>& event) {
if (event->GetTypeRewrite() == TEvVolumePrivate::EvPartStatsSaved) {
++partStatsSaved;
} else if (event->Recipient == MakeStorageStatsServiceId()
Expand All @@ -54,7 +54,7 @@ Y_UNIT_TEST_SUITE(TVolumeStatsTest)
bytesCount = msg->DiskCounters->Simple.BytesCount.Value;
}

return TTestActorRuntime::DefaultObserverFunc(event);
return TTestActorRuntime::DefaultObserverFunc(runtime, event);
};

runtime->SetObserverFunc(obs);
Expand Down Expand Up @@ -199,7 +199,7 @@ Y_UNIT_TEST_SUITE(TVolumeStatsTest)
ui64 loadTime = 0;
ui64 startTime = 0;

auto obs = [&] (TAutoPtr<IEventHandle>& event) {
auto obs = [&] (auto& runtime, TAutoPtr<IEventHandle>& event) {
if (event->GetTypeRewrite() == TEvVolumePrivate::EvPartStatsSaved) {
++partStatsSaved;
} else if (event->Recipient == MakeStorageStatsServiceId()
Expand All @@ -222,7 +222,7 @@ Y_UNIT_TEST_SUITE(TVolumeStatsTest)
}


return TTestActorRuntime::DefaultObserverFunc(event);
return TTestActorRuntime::DefaultObserverFunc(runtime, event);
};

runtime->SetObserverFunc(obs);
Expand Down Expand Up @@ -333,7 +333,7 @@ Y_UNIT_TEST_SUITE(TVolumeStatsTest)
ui64 network = 0;
TDuration cpu;
ui64 nonEmptyReports = 0;
auto observer = [&](TAutoPtr<IEventHandle>& event)
auto observer = [&](auto& runtime, TAutoPtr<IEventHandle>& event)
{
if (event->GetTypeRewrite() ==
TEvVolume::EvDiskRegistryBasedPartitionCounters)
Expand All @@ -347,7 +347,7 @@ Y_UNIT_TEST_SUITE(TVolumeStatsTest)
}
}

return TTestActorRuntime::DefaultObserverFunc(event);
return TTestActorRuntime::DefaultObserverFunc(runtime, event);
};

runtime->SetObserverFunc(observer);
Expand Down Expand Up @@ -403,7 +403,7 @@ Y_UNIT_TEST_SUITE(TVolumeStatsTest)
volume.AddClient(clientInfo);

ui32 nonEmptyReports = 0;
auto observer = [&](TAutoPtr<IEventHandle>& event)
auto observer = [&](auto& runtime, TAutoPtr<IEventHandle>& event)
{
if (event->GetTypeRewrite() ==
TEvVolume::EvDiskRegistryBasedPartitionCounters)
Expand All @@ -416,7 +416,7 @@ Y_UNIT_TEST_SUITE(TVolumeStatsTest)
}
}

return TTestActorRuntime::DefaultObserverFunc(event);
return TTestActorRuntime::DefaultObserverFunc(runtime, event);
};

runtime->SetObserverFunc(observer);
Expand Down

0 comments on commit 470a891

Please sign in to comment.