diff options
| author | robot-piglet <robot-piglet@yandex-team.com> | 2024-08-05 06:23:29 +0300 |
|---|---|---|
| committer | robot-piglet <robot-piglet@yandex-team.com> | 2024-08-05 06:34:14 +0300 |
| commit | fc76ff4fa792ce08e58389b7ad3fe44560a3bddd (patch) | |
| tree | ed20d22b40893cfd5b3e58f4440e7eb321a46050 | |
| parent | 32ee8358ba1b662b03bea6e6df488580dc1460ef (diff) | |
| download | ydb-fc76ff4fa792ce08e58389b7ad3fe44560a3bddd.tar.gz | |
Intermediate changes
| -rw-r--r-- | yt/yt/core/concurrency/unittests/async_looper_ut.cpp | 13 |
1 files changed, 13 insertions, 0 deletions
diff --git a/yt/yt/core/concurrency/unittests/async_looper_ut.cpp b/yt/yt/core/concurrency/unittests/async_looper_ut.cpp index ca9d9fe2d1..c9598dc4ab 100644 --- a/yt/yt/core/concurrency/unittests/async_looper_ut.cpp +++ b/yt/yt/core/concurrency/unittests/async_looper_ut.cpp @@ -56,6 +56,7 @@ TEST(TAsyncLooperTest, JustWorks) } looper->Stop(); + queue->Shutdown(); } TEST(TAsyncLooperTest, Restart) @@ -101,6 +102,7 @@ TEST(TAsyncLooperTest, Restart) EXPECT_EQ(cleanStarts->load(), 2); looper->Stop(); + queue->Shutdown(); } TEST(TAsyncLooperTest, CancelAsyncStep) @@ -133,6 +135,8 @@ TEST(TAsyncLooperTest, CancelAsyncStep) looper->Stop(); EXPECT_TRUE(promise.IsCanceled()); + + queue->Shutdown(); } TEST(TAsyncLooperTest, CancelSyncStep) @@ -165,6 +169,8 @@ TEST(TAsyncLooperTest, CancelSyncStep) looper->Stop(); EXPECT_TRUE(promise.IsCanceled()); + + queue->Shutdown(); } TEST(TAsyncLooperTest, StopDuringAsyncStep) @@ -297,6 +303,7 @@ TEST(TAsyncLooperTest, RestartDuringAsyncStep) } looper->Stop(); + queue->Shutdown(); } TEST(TAsyncLooperTest, RestartDuringAsyncStepWaitFor) @@ -341,6 +348,7 @@ TEST(TAsyncLooperTest, RestartDuringAsyncStepWaitFor) } looper->Stop(); + queue->Shutdown(); } TEST(TAsyncLooperTest, StopDuringAsyncStepPreparation) @@ -435,6 +443,7 @@ TEST(TAsyncLooperTest, RestartDuringAsyncStepPreparation1) } looper->Stop(); + queue->Shutdown(); } TEST(TAsyncLooperTest, RestartDuringAsyncStepPreparation2) @@ -495,6 +504,7 @@ TEST(TAsyncLooperTest, RestartDuringAsyncStepPreparation2) EXPECT_EQ(syncCleanStarts->load(), 2); looper->Stop(); + queue->Shutdown(); } TEST(TAsyncLooperTest, StopDuringSyncStep) @@ -629,6 +639,7 @@ TEST(TAsyncLooperTest, RestartDuringSyncStep) } looper->Stop(); + queue->Shutdown(); } TEST(TAsyncLooperTest, RestartDuringSyncStepWaitFor) @@ -673,6 +684,7 @@ TEST(TAsyncLooperTest, RestartDuringSyncStepWaitFor) } looper->Stop(); + queue->Shutdown(); } TEST(TAsyncLooperTest, NullFuture) @@ -716,6 +728,7 @@ TEST(TAsyncLooperTest, NullFuture) } looper->Stop(); + queue->Shutdown(); } //////////////////////////////////////////////////////////////////////////////// |