diff options
| author | ddoarn <ddoarn@yandex-team.ru> | 2022-02-10 16:49:52 +0300 |
|---|---|---|
| committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:49:52 +0300 |
| commit | 0783fe3f48d91a3b741ce2ea32b11fbfc1637e7e (patch) | |
| tree | 6d6a79d83e5003eaf4d45cac346113c1137cb886 /library/cpp/actors/testlib/test_runtime.cpp | |
| parent | 9541fc30d6f0877db9ff199a16f7fc2505d46a5c (diff) | |
| download | ydb-0783fe3f48d91a3b741ce2ea32b11fbfc1637e7e.tar.gz | |
Restoring authorship annotation for <ddoarn@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 | 20 |
1 files changed, 10 insertions, 10 deletions
diff --git a/library/cpp/actors/testlib/test_runtime.cpp b/library/cpp/actors/testlib/test_runtime.cpp index 6fa25b9965..5f5fdb1536 100644 --- a/library/cpp/actors/testlib/test_runtime.cpp +++ b/library/cpp/actors/testlib/test_runtime.cpp @@ -65,11 +65,11 @@ namespace NActors { 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"); - } - + if (MailboxTable) { + for (ui32 round = 0; !MailboxTable->Cleanup(); ++round) + Y_VERIFY(round < 10, "cyclic event/actor spawn while trying to shutdown actorsystem stub"); + } + if (ActorSystem) ActorSystem->Stop(); @@ -427,10 +427,10 @@ namespace NActors { void Shutdown() override { } - bool Cleanup() override { - return true; - } - + bool Cleanup() override { + return true; + } + // generic TAffinity* Affinity() const override { Y_FAIL(); @@ -1574,7 +1574,7 @@ namespace NActors { node->ActorToActorId[recipientActor] = ev->GetRecipientRewrite(); TActorContext ctx(*mailbox, *node->ExecutorThread, GetCycleCountFast(), actorId); TActivationContext *prevTlsActivationContext = TlsActivationContext; - TlsActivationContext = &ctx; + TlsActivationContext = &ctx; CurrentRecipient = actorId; { TInverseGuard<TMutex> inverseGuard(Mutex); |