Add const to the condition function (#8644)

Author: azevaykin

ydb/core/testlib/actors/block_events.h

@@ -14,7 +14,7 @@ namespace NActors {
     template<class TEvType>
     class TBlockEvents : public std::deque<typename TEvType::TPtr> {
     public:
-        TBlockEvents(TTestActorRuntime& runtime, std::function<bool(typename TEvType::TPtr&)> condition = {})
+        TBlockEvents(TTestActorRuntime& runtime, std::function<bool(const typename TEvType::TPtr&)> condition = {})
             : Runtime(runtime)
             , Condition(std::move(condition))
             , Holder(Runtime.AddObserver<TEvType>(

ydb/core/testlib/actors/test_runtime_ut.cpp

@@ -794,7 +794,7 @@ Y_UNIT_TEST_SUITE(TActorTest) {
         auto source = runtime.Register(new TSourceActor(target), /* nodeIdx */ 1);
         runtime.EnableScheduleForActor(source);
 
-        TBlockEvents<TEvTrigger> block(runtime, [&](TEvTrigger::TPtr& ev){ return ev->GetRecipientRewrite() == target; });
+        TBlockEvents<TEvTrigger> block(runtime, [&](const TEvTrigger::TPtr& ev){ return ev->GetRecipientRewrite() == target; });
         runtime.WaitFor("blocked 3 events", [&]{ return block.size() >= 3; });
         UNIT_ASSERT_VALUES_EQUAL(block.size(), 3u);
         UNIT_ASSERT_VALUES_EQUAL(values.size(), 0u);

ydb/core/tx/datashard/datashard_ut_build_index.cpp

@@ -167,7 +167,7 @@ Y_UNIT_TEST_SUITE(TTxDataShardBuildIndexScan) {
 
         CreateShardedTableForIndex(server, sender, "/Root", "table-2", 1, false);
 
-        TBlockEvents<TEvDataShard::TEvCompactBorrowed> block(runtime, [&](TEvDataShard::TEvCompactBorrowed::TPtr& event) {
+        TBlockEvents<TEvDataShard::TEvCompactBorrowed> block(runtime, [&](const TEvDataShard::TEvCompactBorrowed::TPtr& event) {
             return runtime.FindActorName(event->Sender) == "FLAT_SCHEMESHARD_ACTOR";
         });
 

ydb/core/tx/datashard/datashard_ut_stats.cpp

@@ -443,7 +443,7 @@ Y_UNIT_TEST_SUITE(DataShardStats) {
 
         UpsertRows(server, sender);
 
-        TBlockEvents<NSharedCache::TEvResult> block(runtime, [&](NSharedCache::TEvResult::TPtr& event) {
+        TBlockEvents<NSharedCache::TEvResult> block(runtime, [&](const NSharedCache::TEvResult::TPtr& event) {
             return runtime.FindActorName(event->GetRecipientRewrite()) == "DATASHARD_STATS_BUILDER";
         });
 

ydb/core/tx/mediator/mediator_ut.cpp

@@ -685,7 +685,7 @@ Y_UNIT_TEST_SUITE(MediatorTest) {
 
         // Block plan steps at tablet 1
         TBlockEvents<TEvTxProcessing::TEvPlanStep> blockedPlan1(runtime,
-            [&](TEvTxProcessing::TEvPlanStep::TPtr& ev) {
+            [&](const TEvTxProcessing::TEvPlanStep::TPtr& ev) {
                 return ev->Get()->Record.GetTabletID() == tablet1;
             });
 
@@ -943,12 +943,12 @@ Y_UNIT_TEST_SUITE(MediatorTest) {
         WatcherState->Updates.clear();
 
         TBlockEvents<TEvTxProcessing::TEvPlanStep> blockedPlan1(runtime,
-            [&](TEvTxProcessing::TEvPlanStep::TPtr& ev) {
+            [&](const TEvTxProcessing::TEvPlanStep::TPtr& ev) {
                 return ev->Get()->Record.GetTabletID() == tablet1;
             });
 
         TBlockEvents<TEvTxProcessing::TEvPlanStep> blockedPlan2(runtime,
-            [&](TEvTxProcessing::TEvPlanStep::TPtr& ev) {
+            [&](const TEvTxProcessing::TEvPlanStep::TPtr& ev) {
                 return ev->Get()->Record.GetTabletID() == tablet2;
             });
 

ydb/core/tx/time_cast/time_cast_ut.cpp

@@ -228,9 +228,9 @@ namespace NKikimr::NMediatorTimeCastTest {
 
             TBlockEvents<TEvTxProcessing::TEvPlanStepAck> blockAcks(runtime);
             TBlockEvents<TEvTxProcessing::TEvPlanStep> blockPlan1(runtime,
-                [&](auto& ev) { return ev->Get()->Record.GetTabletID() == tablet1; });
+                [&](const auto& ev) { return ev->Get()->Record.GetTabletID() == tablet1; });
             TBlockEvents<TEvTxProcessing::TEvPlanStep> blockPlan2(runtime,
-                [&](auto& ev) { return ev->Get()->Record.GetTabletID() == tablet2; });
+                [&](const auto& ev) { return ev->Get()->Record.GetTabletID() == tablet2; });
 
             ui64 stepTx1 = PlanTx(server, 1, { tablet1, tablet2 });
             Cerr << "... tx1 planned at step " << stepTx1 << Endl;