aboutsummaryrefslogtreecommitdiffstats
path: root/util/system/event_ut.cpp
diff options
context:
space:
mode:
authoreeight <eeight@yandex-team.ru>2022-02-10 16:46:19 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:19 +0300
commitbd085aee9b4f7a0bee302ce687964ffb7098f986 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /util/system/event_ut.cpp
parent475c0a46f28166e83fd263badc7546377cddcabe (diff)
downloadydb-bd085aee9b4f7a0bee302ce687964ffb7098f986.tar.gz
Restoring authorship annotation for <eeight@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'util/system/event_ut.cpp')
-rw-r--r--util/system/event_ut.cpp8
1 files changed, 4 insertions, 4 deletions
diff --git a/util/system/event_ut.cpp b/util/system/event_ut.cpp
index 5e94a0890f..2506cb7a91 100644
--- a/util/system/event_ut.cpp
+++ b/util/system/event_ut.cpp
@@ -3,7 +3,7 @@
#include <library/cpp/testing/unittest/registar.h>
-#include <util/thread/pool.h>
+#include <util/thread/pool.h>
namespace {
struct TSharedData {
@@ -85,7 +85,7 @@ namespace {
Y_UNIT_TEST_SUITE(EventTest) {
Y_UNIT_TEST(WaitAndSignalTest) {
TSharedData data;
- TThreadPool queue;
+ TThreadPool queue;
queue.Start(5);
for (size_t i = 0; i < 5; ++i) {
UNIT_ASSERT(queue.Add(new TThreadTask(data, i)));
@@ -99,7 +99,7 @@ Y_UNIT_TEST_SUITE(EventTest) {
// test for problem detected by thread-sanitizer (signal/wait race) SEARCH-2113
const size_t limit = 200;
TManualEvent event[limit];
- TThreadPool queue;
+ TThreadPool queue;
queue.Start(limit);
TVector<THolder<IObjectInQueue>> tasks;
for (size_t i = 0; i < limit; ++i) {
@@ -122,7 +122,7 @@ Y_UNIT_TEST_SUITE(EventTest) {
tasks.emplace_back(std::move(owner));
}
- TThreadPool queue;
+ TThreadPool queue;
queue.Start(4);
for (auto& task : tasks) {
UNIT_ASSERT(queue.Add(task.Get()));