Merge branch 'stable-25-3' into backport-27430-to-stable-25-3

Author: orange13

.github/config/muted_ya.txt

@@ -1,84 +1,96 @@
+ydb/core/blobstorage/dsproxy/ut TDSProxyPutTest.TestBlock42PutStatusErrorWith_1_2_VdiskErrors
+ydb/core/blobstorage/dsproxy/ut TDSProxyPutTest.TestBlock42PutStatusOkWith_1_1_VdiskErrors
+ydb/core/blobstorage/dsproxy/ut TDSProxyPutTest.TestBlock42PutStatusOkWith_2_0_VdiskErrors
 ydb/core/blobstorage/ut_blobstorage BlobPatching.PatchBlock42
-ydb/core/blobstorage/ut_blobstorage Decommit3dc.Test
+ydb/core/blobstorage/ut_blobstorage Defragmentation.DefragCompactionRace
+ydb/core/blobstorage/ut_blobstorage GroupLayoutSanitizer.StressMirror3of4
 ydb/core/blobstorage/ut_blobstorage GroupReconfiguration.BsControllerDoesNotDisableGroup
 ydb/core/blobstorage/ut_blobstorage GroupReconfiguration.BsControllerDoesNotDisableGroupNoRequestsToNodesWVDisks
-ydb/core/blobstorage/ut_blobstorage NodeDisconnected.BsQueueRetries
 ydb/core/blobstorage/ut_blobstorage unittest.[*/*] chunk
 ydb/core/blobstorage/ut_blobstorage/ut_huge HugeBlobOnlineSizeChange.Compaction
 ydb/core/blobstorage/ut_blobstorage/ut_huge unittest.[*/*] chunk
 ydb/core/blobstorage/ut_blobstorage/ut_statestorage TStateStorageRingGroupState.TestProxyConfigMismatch
-ydb/core/blobstorage/ut_vdisk unittest.[*/*] chunk
 ydb/core/cms/ut_sentinel_unstable TSentinelUnstableTests.BSControllerCantChangeStatus
+ydb/core/fq/libs/checkpoint_storage/ut NFq.(anonymous namespace).TStorageServiceTest<false>.ShouldGetState
 ydb/core/keyvalue/ut_trace TKeyValueTracingTest.ReadHuge
 ydb/core/keyvalue/ut_trace TKeyValueTracingTest.ReadSmall
 ydb/core/keyvalue/ut_trace TKeyValueTracingTest.WriteHuge
 ydb/core/keyvalue/ut_trace TKeyValueTracingTest.WriteSmall
+ydb/core/kqp/ut/arrow KqpResultSetFormats.ArrowFormat_Stress
+ydb/core/kqp/ut/federated_query/datastreams KqpStreamingQueriesSysView.ReadSysViewWithMetadataSizeBackPressure
 ydb/core/kqp/ut/indexes KqpMultishardIndex.WriteIntoRenamingAsyncIndex
-ydb/core/kqp/ut/olap KqpOlapJson.BloomNGrammIndexesVariants[true,false,0,0,0,0]
-ydb/core/kqp/ut/olap KqpOlapJson.DoubleFilterReduceScopeVariants[2,false,0,10,0,0]
-ydb/core/kqp/ut/olap KqpOlapJson.RestoreJsonArrayVariants[10,true,1024,1000,1000000,0]
+ydb/core/kqp/ut/olap KqpOlapJson.BloomMixIndexesVariants[false,false,0,0,1000,0.5,BLOOM_FILTER]
+ydb/core/kqp/ut/olap KqpOlapJson.BloomNGrammIndexesVariants[false,true,1024,10,0,0.5]
+ydb/core/kqp/ut/olap KqpOlapJson.BrokenJsonWriting[10,false,0,10,1000000,0]
+ydb/core/kqp/ut/olap KqpOlapJson.BrokenJsonWriting[10,false,1024,10,0,0]
+ydb/core/kqp/ut/olap KqpOlapJson.BrokenJsonWriting[2,false,0,10,0,0.5]
+ydb/core/kqp/ut/olap KqpOlapJson.FilterVariants[2,true,1024,0,0,0.5]
+ydb/core/kqp/ut/olap KqpOlapJson.QuotedFilterVariants[10,true,0,10,0,0]
+ydb/core/kqp/ut/olap KqpOlapJson.QuotedFilterVariants[2,true,1024,1000,1000000,0]
+ydb/core/kqp/ut/olap KqpOlapJson.RestoreFirstLevelVariants[10,true,1,10,100,0.5]
 ydb/core/kqp/ut/olap KqpOlapSysView.StatsSysViewColumns
 ydb/core/kqp/ut/olap KqpOlapSysView.StatsSysViewTable
-ydb/core/kqp/ut/opt KqpExtractPredicateLookup.SqlInJoin
-ydb/core/kqp/ut/opt KqpKv.ReadRows_TimeoutCancelsReads
 ydb/core/kqp/ut/query KqpAnalyze.AnalyzeTable+ColumnStore
-ydb/core/kqp/ut/query KqpStats.DeferredEffects+UseSink
-ydb/core/kqp/ut/scheme KqpAcl.AclRevoke+UseSink+IsOlap
+ydb/core/kqp/ut/query KqpLimits.StreamWrite+Allowed
 ydb/core/kqp/ut/scheme KqpOlapScheme.AddPgColumnWithStore
-ydb/core/kqp/ut/service KqpQueryService.LargeUpsert-UseSink
 ydb/core/persqueue/ut/ut_with_sdk TopicTimestamp.TimestampRead_40MB_Topic_offset+middle_WithRestart
+ydb/core/persqueue/ut/ut_with_sdk TopicTimestamp.TimestampRead_6MB_Topic_offset+middle
 ydb/core/statistics/aggregator/ut AnalyzeColumnshard.AnalyzeRebootColumnShard
-ydb/core/tx/schemeshard/ut_export_reboots_s3 unittest.[*/*] chunk
-ydb/core/tx/schemeshard/ut_restore TImportWithRebootsTests.ShouldSucceedOnIndexedTable
-ydb/core/tx/schemeshard/ut_restore TImportWithRebootsTests.ShouldSucceedOnSingleTableWithUniqueIndex
-ydb/core/tx/schemeshard/ut_restore unittest.[*/*] chunk
+ydb/core/tx/schemeshard/ut_export_reboots_s3 TExportToS3WithRebootsTests.ShouldSucceedOnMultiShardTable
+ydb/core/tx/schemeshard/ut_export_reboots_s3 TExportToS3WithRebootsTests.ShouldSucceedOnSingleShardTableWithChangefeed
+ydb/core/tx/schemeshard/ut_index TAsyncIndexTests.CdcAndMergeWithReboots[TabletReboots]
+ydb/core/tx/schemeshard/ut_index_build_reboots IndexBuildTestReboots.IndexPartitioningUniq
 ydb/core/tx/schemeshard/ut_vector_index_build_reboots VectorIndexBuildTestReboots.BaseCase+Prefixed[TabletReboots]
 ydb/core/tx/schemeshard/ut_vector_index_build_reboots unittest.[*/*] chunk
-ydb/core/tx/tx_proxy/ut_ext_tenant TExtSubDomainTest.CreateTableInsideAndAlterDomainAndTable-AlterDatabaseCreateHiveFirst-false
-ydb/core/tx/tx_proxy/ut_ext_tenant TExtSubDomainTest.CreateTableInsideAndAlterDomainAndTable-AlterDatabaseCreateHiveFirst-true
 ydb/core/viewer/tests test.py.test_topic_data
 ydb/core/viewer/tests test.py.test_topic_data_cdc
-ydb/core/viewer/ut Viewer.TabletMergingPacked
 ydb/library/yql/dq/actors/compute/ut TAsyncComputeActorTest.InputTransformMultichannel
+ydb/public/sdk/cpp/src/client/topic/ut TxUsage.Sinks_Oltp_WriteToTopics_4_Query
+ydb/public/sdk/cpp/src/client/topic/ut unittest.[*/*] chunk
+ydb/public/sdk/cpp/src/client/topic/ut/with_direct_read_ut BasicUsage.ReadWithRestarts
+ydb/public/sdk/cpp/src/client/topic/ut/with_direct_read_ut TxUsage.Write_50k_100times_50tx
+ydb/public/sdk/cpp/src/client/topic/ut/with_direct_read_ut TxUsage.Write_And_Read_Big_Messages_1
+ydb/public/sdk/cpp/src/client/topic/ut/with_direct_read_ut TxUsage.Write_And_Read_Big_Messages_2
+ydb/public/sdk/cpp/src/client/topic/ut/with_direct_read_ut TxUsage.Write_And_Read_Gigant_Messages_2
+ydb/public/sdk/cpp/src/client/topic/ut/with_direct_read_ut TxUsage.Write_And_Read_Small_Messages_2
 ydb/public/sdk/cpp/src/client/topic/ut/with_direct_read_ut TxUsage.Write_Only_Big_Messages_In_Wide_Transactions_Query
 ydb/public/sdk/cpp/src/client/topic/ut/with_direct_read_ut unittest.[*/*] chunk
 ydb/public/sdk/cpp/tests/integration/sessions_pool YdbSdkSessionsPool.StressTestSync/0
 ydb/public/sdk/cpp/tests/integration/sessions_pool YdbSdkSessionsPool.StressTestSync/1
 ydb/services/persqueue_v1/ut TPersQueueTest.Cache
-ydb/services/ydb/ut TGRpcAuthentication.NoDescribeRights
 ydb/services/ydb/ut YdbLogStore.AlterLogTable
 ydb/tests/fq/mem_alloc test_scheduling.py.TestSchedule.test_skip_busy[kikimr0]
+ydb/tests/fq/multi_plane py3test.[test_retry.py] chunk
+ydb/tests/fq/multi_plane test_retry.py.TestRetry.test_low_rate[kikimr0]
 ydb/tests/fq/s3 test_bindings_0.py.TestBindings.test_modify_connection_with_a_lot_of_bindings[v2-kikimr_settings0-client0]
 ydb/tests/fq/yds test_2_selects_limit.py.TestSelectLimit.test_select_same[v1]
 ydb/tests/fq/yds test_2_selects_limit.py.TestSelectLimit.test_select_sequence[v1]
-ydb/tests/fq/yds test_delete_read_rules_after_abort_by_system.py.TestDeleteReadRulesAfterAbortBySystem.test_delete_read_rules_after_abort_by_system
 ydb/tests/fq/yds test_mem_alloc.py.TestMemAlloc.test_hop_alloc[v1]
 ydb/tests/fq/yds test_mem_alloc.py.TestMemAlloc.test_join_alloc[v1]
 ydb/tests/fq/yds test_recovery.py.TestRecovery.test_ic_disconnection
 ydb/tests/fq/yds test_select_limit_db_id.py.TestSelectLimitWithDbId.test_select_same_with_id[v1-mvp_external_ydb_endpoint0]
 ydb/tests/fq/yds test_yds_bindings.py.TestBindings.test_yds_insert[v1]
-ydb/tests/fq/yds test_yq_streaming.py.TestYqStreaming.test_early_finish_case1[v1]
-ydb/tests/functional/api test_discovery.py.TestDiscoveryExtEndpoint.test_scenario
-ydb/tests/functional/api test_read_table.py.TestReadTableTruncatedResults.test_truncated_results[async_read_table]
-ydb/tests/functional/cms test_cms_restart.py.TestCmsStateStorageRestartsMirrorKeep.test_restart_as_much_as_can
 ydb/tests/functional/hive test_drain.py.TestHive.test_drain_on_stop
-ydb/tests/functional/restarts test_restarts.py.TestRestartClusterBlock42.test_when_create_many_tablets_and_restart_cluster_then_every_thing_is_ok
+ydb/tests/functional/serializable test.py.test_local
 ydb/tests/functional/serverless test_serverless.py.test_database_with_disk_quotas[enable_alter_database_create_hive_first--false]
 ydb/tests/functional/serverless test_serverless.py.test_database_with_disk_quotas[enable_alter_database_create_hive_first--true]
+ydb/tests/functional/sqs/cloud test_yandex_cloud_mode.py.TestSqsYandexCloudMode.test_dlq_mechanics_in_cloud[tables_format_v0-tables_format_v1-std]
 ydb/tests/functional/tenants test_dynamic_tenants.py.test_create_and_drop_tenants[enable_alter_database_create_hive_first--false]
 ydb/tests/functional/tenants test_dynamic_tenants.py.test_create_and_drop_tenants[enable_alter_database_create_hive_first--true]
 ydb/tests/functional/tenants test_tenants.py.TestTenants.test_create_drop_create_table3[enable_alter_database_create_hive_first--false]
 ydb/tests/functional/tenants test_tenants.py.TestTenants.test_create_drop_create_table3[enable_alter_database_create_hive_first--true]
 ydb/tests/functional/tenants test_tenants.py.TestTenants.test_stop_start[enable_alter_database_create_hive_first--false]
 ydb/tests/functional/tenants test_tenants.py.TestTenants.test_stop_start[enable_alter_database_create_hive_first--true]
-ydb/tests/functional/ydb_cli test_ydb_backup.py.TestDatabaseBackup.test_database_backup
 ydb/tests/functional/ydb_cli test_ydb_backup.py.TestDatabaseBackupRestore.test_database_backup_restore
+ydb/tests/functional/ydb_cli test_ydb_scripting.py.TestExecuteScriptWithParamsFromStdin.test_batching_full_json[scripting]
+ydb/tests/functional/ydb_cli test_ydb_scripting.py.TestExecuteScriptWithParamsFromStdin.test_batching_full_json[stream]
+ydb/tests/functional/ydb_cli test_ydb_scripting.py.TestExecuteScriptWithParamsFromStdin.test_batching_full_raw[scripting]
 ydb/tests/olap py3test.[*/*] chunk
+ydb/tests/olap tablets_movement.py.TestTabletsMovement.test[COLUMN]
 ydb/tests/olap test_cs_many_updates.py.TestCSManyUpdates.test_many_updates[bulk_upsert]
 ydb/tests/olap upgrade_to_internal_path_id.py.TestUpgradeToInternalPathId.test
 ydb/tests/olap zip_bomb.py.TestZipBomb.test
 ydb/tests/olap/scenario test_alter_tiering.py.TestAlterTiering.test[many_tables]
-ydb/tests/olap/scenario test_insert.py.TestInsert.test_multi[read_data_during_bulk_upsert]
 ydb/tests/stress/olap_workload/tests py3test.sole chunk
 ydb/tests/stress/olap_workload/tests test_workload.py.TestYdbWorkload.test
 ydb/tests/stress/reconfig_state_storage_workload/tests test_board_workload.py.TestReconfigStateStorageBoardWorkload.test_state_storage_board

ydb/core/blobstorage/dsproxy/dsproxy_get_block.cpp

@@ -14,7 +14,6 @@ class TBlobStorageGroupGetBlockRequest : public TBlobStorageGroupRequestActor {
     ui64 Generation = 0;
     const TInstant Deadline;
     ui64 Requests = 0;
-    ui64 Responses = 0;
     TGroupQuorumTracker QuorumTracker;
 
     void Handle(TEvBlobStorage::TEvVGetBlockResult::TPtr &ev) {
@@ -36,13 +35,10 @@ class TBlobStorageGroupGetBlockRequest : public TBlobStorageGroupRequestActor {
         if (status == NKikimrProto::NODATA) {
             status = NKikimrProto::OK;  // assume OK for quorum tracker
         }
-        ++Responses;
 
         switch (const NKikimrProto::EReplyStatus overallStatus = QuorumTracker.ProcessReply(vdisk, status)) {
             case NKikimrProto::OK:
-                if (Responses == Requests) {
-                    ReplyAndDie(NKikimrProto::OK);
-                }
+                ReplyAndDie(NKikimrProto::OK);
                 break;
 
             case NKikimrProto::ERROR:

ydb/core/blobstorage/dsproxy/ut/dsproxy_get_block_ut.cpp

@@ -0,0 +1,216 @@
+#include "defs.h"
+#include "dsproxy_env_mock_ut.h"
+#include "dsproxy_test_state_ut.h"
+
+#include <ydb/core/blobstorage/dsproxy/dsproxy_quorum_tracker.h>
+#include <ydb/core/blobstorage/vdisk/common/vdisk_events.h>
+
+#include <ydb/core/testlib/basics/runtime.h>
+#include <ydb/core/testlib/actor_helpers.h>
+
+#include <library/cpp/testing/unittest/registar.h>
+
+using namespace NKikimr;
+
+namespace {
+
+void TestQuorumResponse(TBlobStorageGroupType::EErasureSpecies erasure) {
+    TTestBasicRuntime runtime(1, false);
+    runtime.SetDispatchTimeout(TDuration::Seconds(1));
+    SetupRuntime(runtime);
+
+    TDSProxyEnv env;
+    env.Configure(runtime, TBlobStorageGroupType(erasure), 0, 0);
+    TTestState testState(runtime, env.Info);
+
+    const ui64 tabletId = 123456;
+
+    auto ev = std::make_unique<TEvBlobStorage::TEvGetBlock>(tabletId, TInstant::Max());
+    runtime.Send(new IEventHandle(env.RealProxyActorId, testState.EdgeActor, ev.release()), 0);
+
+    TVector<TEvBlobStorage::TEvVGetBlock::TPtr> requests;
+    for (ui32 i = 0; i < env.Info->GetTotalVDisksNum(); ++i) {
+        TEvBlobStorage::TEvVGetBlock::TPtr vgetBlock = testState.GrabEventPtr<TEvBlobStorage::TEvVGetBlock>();
+        UNIT_ASSERT(vgetBlock);
+        requests.push_back(vgetBlock);
+    }
+
+    TGroupQuorumTracker tracker(env.Info.Get());
+    ui32 responsesNeeded = 0;
+
+    for (auto& req : requests) {
+        ++responsesNeeded;
+        const TVDiskID vdisk = VDiskIDFromVDiskID(req->Get()->Record.GetVDiskID());
+
+        auto response = testState.CreateEventResultPtr(req, NKikimrProto::OK, tabletId);
+        runtime.Send(response.Release(), 0);
+
+        NKikimrProto::EReplyStatus status = tracker.ProcessReply(vdisk, NKikimrProto::OK);
+
+        if (status == NKikimrProto::OK) {
+            TAutoPtr<IEventHandle> resultHandle;
+            auto result = runtime.GrabEdgeEventRethrow<TEvBlobStorage::TEvGetBlockResult>(resultHandle);
+            UNIT_ASSERT(result);
+            UNIT_ASSERT_VALUES_EQUAL(result->Status, NKikimrProto::OK);
+            UNIT_ASSERT_VALUES_EQUAL(result->TabletId, tabletId);
+
+            UNIT_ASSERT_C(responsesNeeded < requests.size(),
+                "Expected to respond after " << responsesNeeded << " responses, but got " << requests.size() << " disks");
+            return;
+        }
+    }
+
+    UNIT_FAIL("Failed to reach quorum");
+}
+
+void TestFailModelViolation(TBlobStorageGroupType::EErasureSpecies erasure) {
+    TTestBasicRuntime runtime(1, false);
+    runtime.SetDispatchTimeout(TDuration::Seconds(1));
+    SetupRuntime(runtime);
+
+    TDSProxyEnv env;
+    env.Configure(runtime, TBlobStorageGroupType(erasure), 0, 0);
+    TTestState testState(runtime, env.Info);
+
+    const ui64 tabletId = 123456;
+
+    auto ev = std::make_unique<TEvBlobStorage::TEvGetBlock>(tabletId, TInstant::Max());
+    runtime.Send(new IEventHandle(env.RealProxyActorId, testState.EdgeActor, ev.release()), 0);
+
+    TVector<TEvBlobStorage::TEvVGetBlock::TPtr> requests;
+    for (ui32 i = 0; i < env.Info->GetTotalVDisksNum(); ++i) {
+        TEvBlobStorage::TEvVGetBlock::TPtr vgetBlock = testState.GrabEventPtr<TEvBlobStorage::TEvVGetBlock>();
+        UNIT_ASSERT(vgetBlock);
+        requests.push_back(vgetBlock);
+    }
+
+    TGroupQuorumTracker tracker(env.Info.Get());
+    bool gotError = false;
+
+    bool isMirror3dc = (erasure == TBlobStorageGroupType::ErasureMirror3dc);
+
+    for (ui32 i = 0; i < requests.size(); ++i) {
+        const TVDiskID vdisk = VDiskIDFromVDiskID(requests[i]->Get()->Record.GetVDiskID());
+
+        NKikimrProto::EReplyStatus diskStatus;
+        if (isMirror3dc) {
+            diskStatus = (vdisk.FailDomain == 1) ? NKikimrProto::ERROR : NKikimrProto::OK;
+        } else {
+            ui32 maxFailures = env.Info->Type.TotalPartCount() - env.Info->Type.MinimalRestorablePartCount();
+            diskStatus = (i < maxFailures + 1) ? NKikimrProto::ERROR : NKikimrProto::OK;
+        }
+
+        auto response = testState.CreateEventResultPtr(requests[i], diskStatus, tabletId);
+        runtime.Send(response.Release(), 0);
+
+        NKikimrProto::EReplyStatus status = tracker.ProcessReply(vdisk, diskStatus);
+
+        if (status == NKikimrProto::ERROR) {
+            TAutoPtr<IEventHandle> resultHandle;
+            auto result = runtime.GrabEdgeEventRethrow<TEvBlobStorage::TEvGetBlockResult>(resultHandle);
+            UNIT_ASSERT(result);
+            UNIT_ASSERT_VALUES_EQUAL(result->Status, NKikimrProto::ERROR);
+            gotError = true;
+            break;
+        }
+    }
+
+    UNIT_ASSERT_C(gotError, "Expected ERROR when fail model is violated");
+}
+
+void TestMaxAllowedFailures(TBlobStorageGroupType::EErasureSpecies erasure) {
+    TTestBasicRuntime runtime(1, false);
+    runtime.SetDispatchTimeout(TDuration::Seconds(1));
+    SetupRuntime(runtime);
+
+    TDSProxyEnv env;
+    env.Configure(runtime, TBlobStorageGroupType(erasure), 0, 0);
+    TTestState testState(runtime, env.Info);
+
+    const ui64 tabletId = 123456;
+
+    auto ev = std::make_unique<TEvBlobStorage::TEvGetBlock>(tabletId, TInstant::Max());
+    runtime.Send(new IEventHandle(env.RealProxyActorId, testState.EdgeActor, ev.release()), 0);
+
+    TVector<TEvBlobStorage::TEvVGetBlock::TPtr> requests;
+    for (ui32 i = 0; i < env.Info->GetTotalVDisksNum(); ++i) {
+        TEvBlobStorage::TEvVGetBlock::TPtr vgetBlock = testState.GrabEventPtr<TEvBlobStorage::TEvVGetBlock>();
+        UNIT_ASSERT(vgetBlock);
+        requests.push_back(vgetBlock);
+    }
+
+    ui32 maxFailures = env.Info->Type.TotalPartCount() - env.Info->Type.MinimalRestorablePartCount();
+    TGroupQuorumTracker tracker(env.Info.Get());
+
+    bool isMirror3dc = (erasure == TBlobStorageGroupType::ErasureMirror3dc);
+
+    for (ui32 i = 0; i < requests.size(); ++i) {
+        const TVDiskID vdisk = VDiskIDFromVDiskID(requests[i]->Get()->Record.GetVDiskID());
+
+        NKikimrProto::EReplyStatus diskStatus;
+        if (isMirror3dc) {
+            diskStatus = ((vdisk.FailRealm == 0 && vdisk.FailDomain >= 1) ||
+                         (vdisk.FailRealm == 1 && vdisk.FailDomain == 1))
+                ? NKikimrProto::ERROR : NKikimrProto::OK;
+        } else {
+            diskStatus = (i < maxFailures) ? NKikimrProto::ERROR : NKikimrProto::OK;
+        }
+
+        auto response = testState.CreateEventResultPtr(requests[i], diskStatus, tabletId);
+        runtime.Send(response.Release(), 0);
+
+        NKikimrProto::EReplyStatus status = tracker.ProcessReply(vdisk, diskStatus);
+
+        if (status == NKikimrProto::OK) {
+            TAutoPtr<IEventHandle> resultHandle;
+            auto result = runtime.GrabEdgeEventRethrow<TEvBlobStorage::TEvGetBlockResult>(resultHandle);
+            UNIT_ASSERT(result);
+            UNIT_ASSERT_VALUES_EQUAL(result->Status, NKikimrProto::OK);
+            return;
+        }
+    }
+
+    UNIT_FAIL("Failed to get OK response with max allowed failures");
+}
+
+} // namespace
+
+Y_UNIT_TEST_SUITE(TDSProxyGetBlockQuorumTest) {
+
+#define UNIT_TEST_QUORUM_RESPONSE(ERASURE) \
+    Y_UNIT_TEST(QuorumResponse##ERASURE) { \
+        TestQuorumResponse(TBlobStorageGroupType::ERASURE); \
+    }
+
+UNIT_TEST_QUORUM_RESPONSE(Erasure3Plus1Block)
+UNIT_TEST_QUORUM_RESPONSE(Erasure4Plus2Block)
+UNIT_TEST_QUORUM_RESPONSE(Erasure3Plus2Block)
+UNIT_TEST_QUORUM_RESPONSE(ErasureMirror3dc)
+
+#undef UNIT_TEST_QUORUM_RESPONSE
+
+#define UNIT_TEST_FAIL_MODEL(ERASURE) \
+    Y_UNIT_TEST(FailModelViolation##ERASURE) { \
+        TestFailModelViolation(TBlobStorageGroupType::ERASURE); \
+    }
+
+UNIT_TEST_FAIL_MODEL(Erasure3Plus1Block)
+UNIT_TEST_FAIL_MODEL(Erasure4Plus2Block)
+UNIT_TEST_FAIL_MODEL(Erasure3Plus2Block)
+UNIT_TEST_FAIL_MODEL(ErasureMirror3dc)
+
+#undef UNIT_TEST_FAIL_MODEL
+
+#define UNIT_TEST_MAX_FAILURES(ERASURE) \
+    Y_UNIT_TEST(MaxAllowedFailures##ERASURE) { \
+        TestMaxAllowedFailures(TBlobStorageGroupType::ERASURE); \
+    }
+
+UNIT_TEST_MAX_FAILURES(Erasure3Plus1Block)
+UNIT_TEST_MAX_FAILURES(Erasure4Plus2Block)
+UNIT_TEST_MAX_FAILURES(Erasure3Plus2Block)
+UNIT_TEST_MAX_FAILURES(ErasureMirror3dc)
+
+#undef UNIT_TEST_MAX_FAILURES
+
+}