aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authorsnaury <snaury@ydb.tech>2023-07-20 10:41:05 +0300
committersnaury <snaury@ydb.tech>2023-07-20 10:41:05 +0300
commit8c15106b495be67e6a3f98a8c5cb7a697b1f1945 (patch)
tree5851d919598d1e3a165448543d0c70856f5189a6
parentf737fffda3c2bce1cfc5f6ec8d4d16f9e84ce1c3 (diff)
downloadydb-8c15106b495be67e6a3f98a8c5cb7a697b1f1945.tar.gz
Don't sync kill sys tablet on reboot in tests KIKIMR-18752
-rw-r--r--ydb/core/testlib/tablet_helpers.cpp4
-rw-r--r--ydb/core/tx/replication/controller/controller.cpp2
-rw-r--r--ydb/core/tx/schemeshard/ut_helpers/test_env.cpp6
3 files changed, 8 insertions, 4 deletions
diff --git a/ydb/core/testlib/tablet_helpers.cpp b/ydb/core/testlib/tablet_helpers.cpp
index f346ff3f73e..89872a7e0ef 100644
--- a/ydb/core/testlib/tablet_helpers.cpp
+++ b/ydb/core/testlib/tablet_helpers.cpp
@@ -333,8 +333,8 @@ namespace NKikimr {
if (ENABLE_REBOOT_DISPATCH_LOG)
Cerr << "!Reboot " << TabletId << " (actor " << targetActorId << ") on event " << eventType << " !\n";
- // Synchronously kill both system and user parts of the tablet
- runtime.Send(new IEventHandle(TabletSys.at(TabletId), TActorId(), new TEvents::TEvPoisonPill()));
+ // We synchronously kill user part of the tablet to stop user-level logic at current event
+ // However we don't kill the system part because tests historically expect pending commits to finish
runtime.Send(new IEventHandle(targetActorId, TActorId(), new TEvents::TEvPoisonPill()));
// Wait for the tablet to boot or to become deleted
TDispatchOptions rebootOptions;
diff --git a/ydb/core/tx/replication/controller/controller.cpp b/ydb/core/tx/replication/controller/controller.cpp
index 3add4984f33..be5ba9abc34 100644
--- a/ydb/core/tx/replication/controller/controller.cpp
+++ b/ydb/core/tx/replication/controller/controller.cpp
@@ -55,6 +55,8 @@ STFUNC(TController::StateWork) {
HFunc(TEvPrivate::TEvUpdateTenantNodes, Handle);
HFunc(TEvDiscovery::TEvDiscoveryData, Handle);
HFunc(TEvDiscovery::TEvError, Handle);
+ default:
+ HandleDefaultEvents(ev, SelfId());
}
}
diff --git a/ydb/core/tx/schemeshard/ut_helpers/test_env.cpp b/ydb/core/tx/schemeshard/ut_helpers/test_env.cpp
index b93fd8295dc..6770dfbb616 100644
--- a/ydb/core/tx/schemeshard/ut_helpers/test_env.cpp
+++ b/ydb/core/tx/schemeshard/ut_helpers/test_env.cpp
@@ -57,8 +57,9 @@ public:
STFUNC(StateWork) {
switch (ev->GetTypeRewrite()) {
- HFunc(TEvTablet::TEvTabletDead, HandleTabletDead);
HFunc(TEvBlockStore::TEvUpdateVolumeConfig, Handle);
+ default:
+ HandleDefaultEvents(ev, SelfId());
}
}
@@ -105,8 +106,9 @@ public:
STFUNC(StateWork) {
switch (ev->GetTypeRewrite()) {
- HFunc(TEvTablet::TEvTabletDead, HandleTabletDead);
HFunc(TEvFileStore::TEvUpdateConfig, Handle);
+ default:
+ HandleDefaultEvents(ev, SelfId());
}
}