diff options
author | and42 <and42@yandex-team.ru> | 2022-02-10 16:47:12 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:47:12 +0300 |
commit | 4fc9a1a64db469cc94894abfec740aa5c9e9789b (patch) | |
tree | 525f0b4c196e68c46ae8411cddc11211ef5670c1 /util/system/event_ut.cpp | |
parent | 287d7d8c4ffc811d1e51c756ecfb13b78f4ee62d (diff) | |
download | ydb-4fc9a1a64db469cc94894abfec740aa5c9e9789b.tar.gz |
Restoring authorship annotation for <and42@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'util/system/event_ut.cpp')
-rw-r--r-- | util/system/event_ut.cpp | 26 |
1 files changed, 13 insertions, 13 deletions
diff --git a/util/system/event_ut.cpp b/util/system/event_ut.cpp index 2506cb7a913..d6f14c04cba 100644 --- a/util/system/event_ut.cpp +++ b/util/system/event_ut.cpp @@ -96,22 +96,22 @@ Y_UNIT_TEST_SUITE(EventTest) { } Y_UNIT_TEST(ConcurrentSignalAndWaitTest) { - // test for problem detected by thread-sanitizer (signal/wait race) SEARCH-2113 - const size_t limit = 200; - TManualEvent event[limit]; + // test for problem detected by thread-sanitizer (signal/wait race) SEARCH-2113 + const size_t limit = 200; + TManualEvent event[limit]; TThreadPool queue; - queue.Start(limit); + queue.Start(limit); TVector<THolder<IObjectInQueue>> tasks; - for (size_t i = 0; i < limit; ++i) { + for (size_t i = 0; i < limit; ++i) { tasks.emplace_back(MakeHolder<TSignalTask>(event[i])); - UNIT_ASSERT(queue.Add(tasks.back().Get())); - } - for (size_t i = limit; i != 0; --i) { - UNIT_ASSERT(event[i - 1].WaitT(TDuration::Seconds(90))); - } - queue.Stop(); - } - + UNIT_ASSERT(queue.Add(tasks.back().Get())); + } + for (size_t i = limit; i != 0; --i) { + UNIT_ASSERT(event[i - 1].WaitT(TDuration::Seconds(90))); + } + queue.Stop(); + } + /** Test for a problem: http://nga.at.yandex-team.ru/5772 */ Y_UNIT_TEST(DestructorBeforeSignalFinishTest) { return; |