diff options
author | a-romanov <a-romanov@yandex-team.ru> | 2022-02-10 16:48:10 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:48:10 +0300 |
commit | aa2986a34bde73b2cdcea5080c4443b7cf2ba686 (patch) | |
tree | 410fbde59311309b774a0da147f79628c3429a2c /library/cpp/actors/testlib/test_runtime.cpp | |
parent | e77cfd118321c5b9c168fdee41b4e6c5706b8f68 (diff) | |
download | ydb-aa2986a34bde73b2cdcea5080c4443b7cf2ba686.tar.gz |
Restoring authorship annotation for <a-romanov@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/testlib/test_runtime.cpp')
-rw-r--r-- | library/cpp/actors/testlib/test_runtime.cpp | 40 |
1 files changed, 20 insertions, 20 deletions
diff --git a/library/cpp/actors/testlib/test_runtime.cpp b/library/cpp/actors/testlib/test_runtime.cpp index 6fa25b9965..8df586041e 100644 --- a/library/cpp/actors/testlib/test_runtime.cpp +++ b/library/cpp/actors/testlib/test_runtime.cpp @@ -62,9 +62,9 @@ namespace NActors { } void TTestActorRuntimeBase::TNodeDataBase::Stop() { - if (Poller) - Poller->Stop(); - + if (Poller) + Poller->Stop(); + if (MailboxTable) { for (ui32 round = 0; !MailboxTable->Cleanup(); ++round) Y_VERIFY(round < 10, "cyclic event/actor spawn while trying to shutdown actorsystem stub"); @@ -72,7 +72,7 @@ namespace NActors { if (ActorSystem) ActorSystem->Stop(); - + ActorSystem.Destroy(); Poller.Reset(); } @@ -684,37 +684,37 @@ namespace NActors { TTestActorRuntimeBase::TEventObserver TTestActorRuntimeBase::SetObserverFunc(TEventObserver observerFunc) { TGuard<TMutex> guard(Mutex); - auto result = ObserverFunc; - ObserverFunc = observerFunc; - return result; + auto result = ObserverFunc; + ObserverFunc = observerFunc; + return result; } TTestActorRuntimeBase::TScheduledEventsSelector TTestActorRuntimeBase::SetScheduledEventsSelectorFunc(TScheduledEventsSelector scheduledEventsSelectorFunc) { TGuard<TMutex> guard(Mutex); - auto result = ScheduledEventsSelectorFunc; - ScheduledEventsSelectorFunc = scheduledEventsSelectorFunc; - return result; + auto result = ScheduledEventsSelectorFunc; + ScheduledEventsSelectorFunc = scheduledEventsSelectorFunc; + return result; } TTestActorRuntimeBase::TEventFilter TTestActorRuntimeBase::SetEventFilter(TEventFilter filterFunc) { TGuard<TMutex> guard(Mutex); - auto result = EventFilterFunc; - EventFilterFunc = filterFunc; - return result; + auto result = EventFilterFunc; + EventFilterFunc = filterFunc; + return result; } TTestActorRuntimeBase::TScheduledEventFilter TTestActorRuntimeBase::SetScheduledEventFilter(TScheduledEventFilter filterFunc) { TGuard<TMutex> guard(Mutex); - auto result = ScheduledEventFilterFunc; - ScheduledEventFilterFunc = filterFunc; - return result; + auto result = ScheduledEventFilterFunc; + ScheduledEventFilterFunc = filterFunc; + return result; } TTestActorRuntimeBase::TRegistrationObserver TTestActorRuntimeBase::SetRegistrationObserverFunc(TRegistrationObserver observerFunc) { TGuard<TMutex> guard(Mutex); - auto result = RegistrationObserver; - RegistrationObserver = observerFunc; - return result; + auto result = RegistrationObserver; + RegistrationObserver = observerFunc; + return result; } bool TTestActorRuntimeBase::IsVerbose() { @@ -1641,7 +1641,7 @@ namespace NActors { } const auto& interconnectCounters = GetCountersForComponent(node->DynamicCounters, "interconnect"); - + setup->LocalServices = node->LocalServices; setup->Interconnect.ProxyActors.resize(FirstNodeId + NodeCount); const TActorId nameserviceId = GetNameserviceActorId(); |