aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading
diff options
context:
space:
mode:
authorIlnur Khuziev <ilnur.khuziev@yandex.ru>2022-02-10 16:46:13 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:13 +0300
commit736dcd8ca259457a136f2f9f9168c44643914323 (patch)
treeddd46a036d68bfa83aa11b892f31243ea6b068a1 /library/cpp/threading
parent9bf2fa2b060c9881d3135c2208c624a1dd546ecc (diff)
downloadydb-736dcd8ca259457a136f2f9f9168c44643914323.tar.gz
Restoring authorship annotation for Ilnur Khuziev <ilnur.khuziev@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/threading')
-rw-r--r--library/cpp/threading/atomic/bool_ut.cpp2
-rw-r--r--library/cpp/threading/atomic/ut/ya.make2
-rw-r--r--library/cpp/threading/chunk_queue/queue.h2
-rw-r--r--library/cpp/threading/chunk_queue/queue_ut.cpp2
-rw-r--r--library/cpp/threading/chunk_queue/ut/ya.make2
-rw-r--r--library/cpp/threading/equeue/equeue.cpp2
-rw-r--r--library/cpp/threading/equeue/equeue_ut.cpp2
-rw-r--r--library/cpp/threading/equeue/ut/ya.make4
-rw-r--r--library/cpp/threading/future/async_ut.cpp2
-rw-r--r--library/cpp/threading/future/core/future-inl.h2
-rw-r--r--library/cpp/threading/future/core/future.h14
-rw-r--r--library/cpp/threading/future/future_ut.cpp72
-rw-r--r--library/cpp/threading/future/legacy_future_ut.cpp2
-rw-r--r--library/cpp/threading/future/perf/main.cpp4
-rw-r--r--library/cpp/threading/future/perf/ya.make2
-rw-r--r--library/cpp/threading/future/subscription/subscription_ut.cpp2
-rw-r--r--library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp2
-rw-r--r--library/cpp/threading/future/subscription/wait_all_ut.cpp2
-rw-r--r--library/cpp/threading/future/subscription/wait_any_ut.cpp2
-rw-r--r--library/cpp/threading/future/subscription/wait_ut_common.h2
-rw-r--r--library/cpp/threading/future/ut/ya.make2
-rw-r--r--library/cpp/threading/light_rw_lock/bench/lightrwlock_test.cpp2
-rw-r--r--library/cpp/threading/light_rw_lock/bench/ya.make2
-rw-r--r--library/cpp/threading/light_rw_lock/ut/rwlock_ut.cpp4
-rw-r--r--library/cpp/threading/light_rw_lock/ut/ya.make2
-rw-r--r--library/cpp/threading/local_executor/local_executor.cpp2
-rw-r--r--library/cpp/threading/local_executor/local_executor.h2
-rw-r--r--library/cpp/threading/local_executor/ut/local_executor_ut.cpp6
-rw-r--r--library/cpp/threading/local_executor/ut/ya.make2
-rw-r--r--library/cpp/threading/poor_man_openmp/thread_helper_ut.cpp2
-rw-r--r--library/cpp/threading/poor_man_openmp/ut/ya.make2
-rw-r--r--library/cpp/threading/queue/basic_ut.cpp2
-rw-r--r--library/cpp/threading/queue/queue_ut.cpp2
-rw-r--r--library/cpp/threading/queue/tune_ut.cpp2
-rw-r--r--library/cpp/threading/queue/unordered_ut.cpp2
-rw-r--r--library/cpp/threading/queue/ut/ya.make2
-rw-r--r--library/cpp/threading/skip_list/perf/main.cpp4
-rw-r--r--library/cpp/threading/skip_list/perf/ya.make4
-rw-r--r--library/cpp/threading/skip_list/skiplist_ut.cpp2
-rw-r--r--library/cpp/threading/skip_list/ut/ya.make2
-rw-r--r--library/cpp/threading/task_scheduler/task_scheduler_ut.cpp2
-rw-r--r--library/cpp/threading/task_scheduler/ut/ya.make2
-rw-r--r--library/cpp/threading/ya.make120
43 files changed, 150 insertions, 150 deletions
diff --git a/library/cpp/threading/atomic/bool_ut.cpp b/library/cpp/threading/atomic/bool_ut.cpp
index 9481f41d8d..08286d20a4 100644
--- a/library/cpp/threading/atomic/bool_ut.cpp
+++ b/library/cpp/threading/atomic/bool_ut.cpp
@@ -1,6 +1,6 @@
#include "bool.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
Y_UNIT_TEST_SUITE(AtomicBool) {
Y_UNIT_TEST(ReadWrite) {
diff --git a/library/cpp/threading/atomic/ut/ya.make b/library/cpp/threading/atomic/ut/ya.make
index 3c555685df..65a9a3fb8c 100644
--- a/library/cpp/threading/atomic/ut/ya.make
+++ b/library/cpp/threading/atomic/ut/ya.make
@@ -1,4 +1,4 @@
-UNITTEST_FOR(library/cpp/threading/atomic)
+UNITTEST_FOR(library/cpp/threading/atomic)
OWNER(vmordovin)
diff --git a/library/cpp/threading/chunk_queue/queue.h b/library/cpp/threading/chunk_queue/queue.h
index 55859601a1..3e0a401b5f 100644
--- a/library/cpp/threading/chunk_queue/queue.h
+++ b/library/cpp/threading/chunk_queue/queue.h
@@ -534,7 +534,7 @@ namespace NThreading {
void Enqueue(TAutoPtr<T> value) {
Impl.Enqueue(value.Get());
- Y_UNUSED(value.Release());
+ Y_UNUSED(value.Release());
}
bool Dequeue(TAutoPtr<T>& value) {
diff --git a/library/cpp/threading/chunk_queue/queue_ut.cpp b/library/cpp/threading/chunk_queue/queue_ut.cpp
index 8cb36d8dd1..a0ed159b89 100644
--- a/library/cpp/threading/chunk_queue/queue_ut.cpp
+++ b/library/cpp/threading/chunk_queue/queue_ut.cpp
@@ -1,6 +1,6 @@
#include "queue.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/generic/set.h>
diff --git a/library/cpp/threading/chunk_queue/ut/ya.make b/library/cpp/threading/chunk_queue/ut/ya.make
index a35ed6bc4b..7c6ffa5ef9 100644
--- a/library/cpp/threading/chunk_queue/ut/ya.make
+++ b/library/cpp/threading/chunk_queue/ut/ya.make
@@ -1,4 +1,4 @@
-UNITTEST_FOR(library/cpp/threading/chunk_queue)
+UNITTEST_FOR(library/cpp/threading/chunk_queue)
OWNER(g:rtmr)
diff --git a/library/cpp/threading/equeue/equeue.cpp b/library/cpp/threading/equeue/equeue.cpp
index 54a848e912..7bdc1d0dda 100644
--- a/library/cpp/threading/equeue/equeue.cpp
+++ b/library/cpp/threading/equeue/equeue.cpp
@@ -59,7 +59,7 @@ bool TElasticQueue::Add(IObjectInQueue* obj) {
}
if (SlaveQueue_->Add(wrapper.Get())) {
- Y_UNUSED(wrapper.Release());
+ Y_UNUSED(wrapper.Release());
return true;
} else {
return false;
diff --git a/library/cpp/threading/equeue/equeue_ut.cpp b/library/cpp/threading/equeue/equeue_ut.cpp
index 9cf2aced44..abedda6497 100644
--- a/library/cpp/threading/equeue/equeue_ut.cpp
+++ b/library/cpp/threading/equeue/equeue_ut.cpp
@@ -1,6 +1,6 @@
#include "equeue.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/system/event.h>
#include <util/datetime/base.h>
diff --git a/library/cpp/threading/equeue/ut/ya.make b/library/cpp/threading/equeue/ut/ya.make
index 2f6293d47d..d0cfaeae92 100644
--- a/library/cpp/threading/equeue/ut/ya.make
+++ b/library/cpp/threading/equeue/ut/ya.make
@@ -6,10 +6,10 @@ OWNER(
)
PEERDIR(
- ADDINCL library/cpp/threading/equeue
+ ADDINCL library/cpp/threading/equeue
)
-SRCDIR(library/cpp/threading/equeue)
+SRCDIR(library/cpp/threading/equeue)
SRCS(
equeue_ut.cpp
diff --git a/library/cpp/threading/future/async_ut.cpp b/library/cpp/threading/future/async_ut.cpp
index a3699744e4..855fab8d0f 100644
--- a/library/cpp/threading/future/async_ut.cpp
+++ b/library/cpp/threading/future/async_ut.cpp
@@ -1,6 +1,6 @@
#include "async.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/generic/ptr.h>
#include <util/generic/vector.h>
diff --git a/library/cpp/threading/future/core/future-inl.h b/library/cpp/threading/future/core/future-inl.h
index 5fd4296a93..6703645ca9 100644
--- a/library/cpp/threading/future/core/future-inl.h
+++ b/library/cpp/threading/future/core/future-inl.h
@@ -691,7 +691,7 @@ namespace NThreading {
EnsureInitialized();
return State->Wait();
}
-
+
inline bool TFuture<void>::Wait(TDuration timeout) const {
EnsureInitialized();
return State->Wait(timeout);
diff --git a/library/cpp/threading/future/core/future.h b/library/cpp/threading/future/core/future.h
index 2e82bb953e..18f55aba69 100644
--- a/library/cpp/threading/future/core/future.h
+++ b/library/cpp/threading/future/core/future.h
@@ -74,8 +74,8 @@ namespace NThreading {
TIntrusivePtr<TFutureState> State;
public:
- using value_type = T;
-
+ using value_type = T;
+
TFuture() noexcept = default;
TFuture(const TFuture<T>& other) noexcept = default;
TFuture(TFuture<T>&& other) noexcept = default;
@@ -131,8 +131,8 @@ namespace NThreading {
TIntrusivePtr<TFutureState> State = nullptr;
public:
- using value_type = void;
-
+ using value_type = void;
+
TFuture() noexcept = default;
TFuture(const TFuture<void>& other) noexcept = default;
TFuture(TFuture<void>&& other) noexcept = default;
@@ -169,9 +169,9 @@ namespace NThreading {
template <typename R>
TFuture<R> Return(const R& value) const;
- TFuture<void> IgnoreResult() const {
- return *this;
- }
+ TFuture<void> IgnoreResult() const {
+ return *this;
+ }
//! If the future is initialized returns the future state identifier. Otherwise returns an empty optional
/** The state identifier is guaranteed to be unique during the future state lifetime and could be reused after its death
diff --git a/library/cpp/threading/future/future_ut.cpp b/library/cpp/threading/future/future_ut.cpp
index 05950a568d..2068337f4e 100644
--- a/library/cpp/threading/future/future_ut.cpp
+++ b/library/cpp/threading/future/future_ut.cpp
@@ -1,6 +1,6 @@
#include "future.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <list>
#include <type_traits>
@@ -293,23 +293,23 @@ namespace {
}
Y_UNIT_TEST(ShouldWaitExceptionOrAllVectorWithValueType) {
- TPromise<int> promise1 = NewPromise<int>();
- TPromise<int> promise2 = NewPromise<int>();
-
- TVector<TFuture<int>> promises;
- promises.push_back(promise1);
- promises.push_back(promise2);
-
+ TPromise<int> promise1 = NewPromise<int>();
+ TPromise<int> promise2 = NewPromise<int>();
+
+ TVector<TFuture<int>> promises;
+ promises.push_back(promise1);
+ promises.push_back(promise2);
+
TFuture<void> future = WaitExceptionOrAll(promises);
- UNIT_ASSERT(!future.HasValue());
-
- promise1.SetValue(0);
- UNIT_ASSERT(!future.HasValue());
-
- promise2.SetValue(0);
- UNIT_ASSERT(future.HasValue());
- }
-
+ UNIT_ASSERT(!future.HasValue());
+
+ promise1.SetValue(0);
+ UNIT_ASSERT(!future.HasValue());
+
+ promise2.SetValue(0);
+ UNIT_ASSERT(future.HasValue());
+ }
+
Y_UNIT_TEST(ShouldWaitExceptionOrAllList) {
TPromise<void> promise1 = NewPromise();
TPromise<void> promise2 = NewPromise();
@@ -353,25 +353,25 @@ namespace {
UNIT_ASSERT(future.HasValue());
}
-
- Y_UNIT_TEST(ShouldWaitAnyVectorWithValueType) {
- TPromise<int> promise1 = NewPromise<int>();
- TPromise<int> promise2 = NewPromise<int>();
-
- TVector<TFuture<int>> promises;
- promises.push_back(promise1);
- promises.push_back(promise2);
-
- TFuture<void> future = WaitAny(promises);
- UNIT_ASSERT(!future.HasValue());
-
- promise1.SetValue(0);
- UNIT_ASSERT(future.HasValue());
-
- promise2.SetValue(0);
- UNIT_ASSERT(future.HasValue());
- }
-
+
+ Y_UNIT_TEST(ShouldWaitAnyVectorWithValueType) {
+ TPromise<int> promise1 = NewPromise<int>();
+ TPromise<int> promise2 = NewPromise<int>();
+
+ TVector<TFuture<int>> promises;
+ promises.push_back(promise1);
+ promises.push_back(promise2);
+
+ TFuture<void> future = WaitAny(promises);
+ UNIT_ASSERT(!future.HasValue());
+
+ promise1.SetValue(0);
+ UNIT_ASSERT(future.HasValue());
+
+ promise2.SetValue(0);
+ UNIT_ASSERT(future.HasValue());
+ }
+
Y_UNIT_TEST(ShouldWaitAnyList) {
TPromise<void> promise1 = NewPromise();
TPromise<void> promise2 = NewPromise();
diff --git a/library/cpp/threading/future/legacy_future_ut.cpp b/library/cpp/threading/future/legacy_future_ut.cpp
index ff63db1725..3bf8257387 100644
--- a/library/cpp/threading/future/legacy_future_ut.cpp
+++ b/library/cpp/threading/future/legacy_future_ut.cpp
@@ -1,6 +1,6 @@
#include "legacy_future.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
namespace NThreading {
Y_UNIT_TEST_SUITE(TLegacyFutureTest) {
diff --git a/library/cpp/threading/future/perf/main.cpp b/library/cpp/threading/future/perf/main.cpp
index 5a0690af47..3d362cd322 100644
--- a/library/cpp/threading/future/perf/main.cpp
+++ b/library/cpp/threading/future/perf/main.cpp
@@ -1,5 +1,5 @@
-#include <library/cpp/testing/benchmark/bench.h>
-#include <library/cpp/threading/future/future.h>
+#include <library/cpp/testing/benchmark/bench.h>
+#include <library/cpp/threading/future/future.h>
#include <util/generic/string.h>
#include <util/generic/xrange.h>
diff --git a/library/cpp/threading/future/perf/ya.make b/library/cpp/threading/future/perf/ya.make
index 943d585d4b..286a8a97bb 100644
--- a/library/cpp/threading/future/perf/ya.make
+++ b/library/cpp/threading/future/perf/ya.make
@@ -10,7 +10,7 @@ SRCS(
)
PEERDIR(
- library/cpp/threading/future
+ library/cpp/threading/future
)
END()
diff --git a/library/cpp/threading/future/subscription/subscription_ut.cpp b/library/cpp/threading/future/subscription/subscription_ut.cpp
index d018ea15cc..a33f54adf2 100644
--- a/library/cpp/threading/future/subscription/subscription_ut.cpp
+++ b/library/cpp/threading/future/subscription/subscription_ut.cpp
@@ -1,6 +1,6 @@
#include "subscription.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
using namespace NThreading;
diff --git a/library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp b/library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp
index 34ae9edb4e..5d4794cd3c 100644
--- a/library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp
+++ b/library/cpp/threading/future/subscription/wait_all_or_exception_ut.cpp
@@ -1,7 +1,7 @@
#include "wait_all_or_exception.h"
#include "wait_ut_common.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/generic/strbuf.h>
#include <atomic>
diff --git a/library/cpp/threading/future/subscription/wait_all_ut.cpp b/library/cpp/threading/future/subscription/wait_all_ut.cpp
index 3bc9762671..aee11c315e 100644
--- a/library/cpp/threading/future/subscription/wait_all_ut.cpp
+++ b/library/cpp/threading/future/subscription/wait_all_ut.cpp
@@ -1,7 +1,7 @@
#include "wait_all.h"
#include "wait_ut_common.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/generic/strbuf.h>
#include <atomic>
diff --git a/library/cpp/threading/future/subscription/wait_any_ut.cpp b/library/cpp/threading/future/subscription/wait_any_ut.cpp
index 262080e8d1..42902832ed 100644
--- a/library/cpp/threading/future/subscription/wait_any_ut.cpp
+++ b/library/cpp/threading/future/subscription/wait_any_ut.cpp
@@ -1,7 +1,7 @@
#include "wait_any.h"
#include "wait_ut_common.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/generic/strbuf.h>
#include <exception>
diff --git a/library/cpp/threading/future/subscription/wait_ut_common.h b/library/cpp/threading/future/subscription/wait_ut_common.h
index 99530dd1f6..693a153924 100644
--- a/library/cpp/threading/future/subscription/wait_ut_common.h
+++ b/library/cpp/threading/future/subscription/wait_ut_common.h
@@ -1,7 +1,7 @@
#pragma once
#include <library/cpp/threading/future/future.h>
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/generic/vector.h>
diff --git a/library/cpp/threading/future/ut/ya.make b/library/cpp/threading/future/ut/ya.make
index 566b622370..704c0c5eb1 100644
--- a/library/cpp/threading/future/ut/ya.make
+++ b/library/cpp/threading/future/ut/ya.make
@@ -1,4 +1,4 @@
-UNITTEST_FOR(library/cpp/threading/future)
+UNITTEST_FOR(library/cpp/threading/future)
OWNER(
g:rtmr
diff --git a/library/cpp/threading/light_rw_lock/bench/lightrwlock_test.cpp b/library/cpp/threading/light_rw_lock/bench/lightrwlock_test.cpp
index c3027ea544..bec9b65d82 100644
--- a/library/cpp/threading/light_rw_lock/bench/lightrwlock_test.cpp
+++ b/library/cpp/threading/light_rw_lock/bench/lightrwlock_test.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/threading/light_rw_lock/lightrwlock.h>
+#include <library/cpp/threading/light_rw_lock/lightrwlock.h>
#include <util/random/random.h>
#ifdef _linux_
diff --git a/library/cpp/threading/light_rw_lock/bench/ya.make b/library/cpp/threading/light_rw_lock/bench/ya.make
index 7969b52a50..708d20e998 100644
--- a/library/cpp/threading/light_rw_lock/bench/ya.make
+++ b/library/cpp/threading/light_rw_lock/bench/ya.make
@@ -7,7 +7,7 @@ SRCS(
)
PEERDIR(
- library/cpp/threading/light_rw_lock
+ library/cpp/threading/light_rw_lock
)
END()
diff --git a/library/cpp/threading/light_rw_lock/ut/rwlock_ut.cpp b/library/cpp/threading/light_rw_lock/ut/rwlock_ut.cpp
index e82063d959..87916f77e2 100644
--- a/library/cpp/threading/light_rw_lock/ut/rwlock_ut.cpp
+++ b/library/cpp/threading/light_rw_lock/ut/rwlock_ut.cpp
@@ -1,5 +1,5 @@
-#include <library/cpp/threading/light_rw_lock/lightrwlock.h>
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/threading/light_rw_lock/lightrwlock.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/random/random.h>
#include <util/system/atomic.h>
#include <util/thread/pool.h>
diff --git a/library/cpp/threading/light_rw_lock/ut/ya.make b/library/cpp/threading/light_rw_lock/ut/ya.make
index 92928b837c..ce783f6616 100644
--- a/library/cpp/threading/light_rw_lock/ut/ya.make
+++ b/library/cpp/threading/light_rw_lock/ut/ya.make
@@ -1,4 +1,4 @@
-UNITTEST_FOR(library/cpp/threading/light_rw_lock)
+UNITTEST_FOR(library/cpp/threading/light_rw_lock)
OWNER(agri)
diff --git a/library/cpp/threading/local_executor/local_executor.cpp b/library/cpp/threading/local_executor/local_executor.cpp
index 1d3fbb4bf4..cda9aaaa4f 100644
--- a/library/cpp/threading/local_executor/local_executor.cpp
+++ b/library/cpp/threading/local_executor/local_executor.cpp
@@ -1,6 +1,6 @@
#include "local_executor.h"
-#include <library/cpp/threading/future/future.h>
+#include <library/cpp/threading/future/future.h>
#include <util/generic/utility.h>
#include <util/system/atomic.h>
diff --git a/library/cpp/threading/local_executor/local_executor.h b/library/cpp/threading/local_executor/local_executor.h
index c1c824f67c..d0c622f4ef 100644
--- a/library/cpp/threading/local_executor/local_executor.h
+++ b/library/cpp/threading/local_executor/local_executor.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/threading/future/future.h>
+#include <library/cpp/threading/future/future.h>
#include <util/generic/cast.h>
#include <util/generic/fwd.h>
diff --git a/library/cpp/threading/local_executor/ut/local_executor_ut.cpp b/library/cpp/threading/local_executor/ut/local_executor_ut.cpp
index ac5737717c..81f37d80ba 100644
--- a/library/cpp/threading/local_executor/ut/local_executor_ut.cpp
+++ b/library/cpp/threading/local_executor/ut/local_executor_ut.cpp
@@ -1,7 +1,7 @@
-#include <library/cpp/threading/local_executor/local_executor.h>
-#include <library/cpp/threading/future/future.h>
+#include <library/cpp/threading/local_executor/local_executor.h>
+#include <library/cpp/threading/future/future.h>
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/system/mutex.h>
#include <util/system/rwlock.h>
#include <util/generic/algorithm.h>
diff --git a/library/cpp/threading/local_executor/ut/ya.make b/library/cpp/threading/local_executor/ut/ya.make
index be579a5ca0..8490246645 100644
--- a/library/cpp/threading/local_executor/ut/ya.make
+++ b/library/cpp/threading/local_executor/ut/ya.make
@@ -3,7 +3,7 @@ OWNER(
gulin
)
-UNITTEST_FOR(library/cpp/threading/local_executor)
+UNITTEST_FOR(library/cpp/threading/local_executor)
SRCS(
local_executor_ut.cpp
diff --git a/library/cpp/threading/poor_man_openmp/thread_helper_ut.cpp b/library/cpp/threading/poor_man_openmp/thread_helper_ut.cpp
index 7417636864..8346c26894 100644
--- a/library/cpp/threading/poor_man_openmp/thread_helper_ut.cpp
+++ b/library/cpp/threading/poor_man_openmp/thread_helper_ut.cpp
@@ -1,6 +1,6 @@
#include "thread_helper.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/generic/string.h>
#include <util/generic/yexception.h>
diff --git a/library/cpp/threading/poor_man_openmp/ut/ya.make b/library/cpp/threading/poor_man_openmp/ut/ya.make
index 6d7aa123ed..ef333ab91e 100644
--- a/library/cpp/threading/poor_man_openmp/ut/ya.make
+++ b/library/cpp/threading/poor_man_openmp/ut/ya.make
@@ -1,4 +1,4 @@
-UNITTEST_FOR(library/cpp/threading/poor_man_openmp)
+UNITTEST_FOR(library/cpp/threading/poor_man_openmp)
OWNER(
pg
diff --git a/library/cpp/threading/queue/basic_ut.cpp b/library/cpp/threading/queue/basic_ut.cpp
index 5f56f8583e..e2a240920b 100644
--- a/library/cpp/threading/queue/basic_ut.cpp
+++ b/library/cpp/threading/queue/basic_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/generic/vector.h>
#include <util/system/thread.h>
diff --git a/library/cpp/threading/queue/queue_ut.cpp b/library/cpp/threading/queue/queue_ut.cpp
index 80eca147da..1a48e1ca00 100644
--- a/library/cpp/threading/queue/queue_ut.cpp
+++ b/library/cpp/threading/queue/queue_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/system/thread.h>
#include "ut_helpers.h"
diff --git a/library/cpp/threading/queue/tune_ut.cpp b/library/cpp/threading/queue/tune_ut.cpp
index 7e980d3e27..84e81006aa 100644
--- a/library/cpp/threading/queue/tune_ut.cpp
+++ b/library/cpp/threading/queue/tune_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "tune.h"
struct TDefaultStructA {
diff --git a/library/cpp/threading/queue/unordered_ut.cpp b/library/cpp/threading/queue/unordered_ut.cpp
index a43b7f520e..fd5108a01a 100644
--- a/library/cpp/threading/queue/unordered_ut.cpp
+++ b/library/cpp/threading/queue/unordered_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/system/thread.h>
#include <algorithm>
#include <util/generic/vector.h>
diff --git a/library/cpp/threading/queue/ut/ya.make b/library/cpp/threading/queue/ut/ya.make
index 8883d9bf69..647ebc0551 100644
--- a/library/cpp/threading/queue/ut/ya.make
+++ b/library/cpp/threading/queue/ut/ya.make
@@ -1,4 +1,4 @@
-UNITTEST_FOR(library/cpp/threading/queue)
+UNITTEST_FOR(library/cpp/threading/queue)
OWNER(agri)
diff --git a/library/cpp/threading/skip_list/perf/main.cpp b/library/cpp/threading/skip_list/perf/main.cpp
index 4ad52049e7..a74ffe2a04 100644
--- a/library/cpp/threading/skip_list/perf/main.cpp
+++ b/library/cpp/threading/skip_list/perf/main.cpp
@@ -1,6 +1,6 @@
-#include <library/cpp/threading/skip_list/skiplist.h>
+#include <library/cpp/threading/skip_list/skiplist.h>
-#include <library/cpp/getopt/small/last_getopt.h>
+#include <library/cpp/getopt/small/last_getopt.h>
#include <library/cpp/charset/ci_string.h>
#include <util/datetime/base.h>
diff --git a/library/cpp/threading/skip_list/perf/ya.make b/library/cpp/threading/skip_list/perf/ya.make
index 01bfafa404..b0df32d076 100644
--- a/library/cpp/threading/skip_list/perf/ya.make
+++ b/library/cpp/threading/skip_list/perf/ya.make
@@ -4,8 +4,8 @@ OWNER(g:rtmr)
PEERDIR(
library/cpp/charset
- library/cpp/getopt/small
- library/cpp/threading/skip_list
+ library/cpp/getopt/small
+ library/cpp/threading/skip_list
)
SRCS(
diff --git a/library/cpp/threading/skip_list/skiplist_ut.cpp b/library/cpp/threading/skip_list/skiplist_ut.cpp
index 52fcffda66..eff3d92663 100644
--- a/library/cpp/threading/skip_list/skiplist_ut.cpp
+++ b/library/cpp/threading/skip_list/skiplist_ut.cpp
@@ -1,6 +1,6 @@
#include "skiplist.h"
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
namespace NThreading {
namespace {
diff --git a/library/cpp/threading/skip_list/ut/ya.make b/library/cpp/threading/skip_list/ut/ya.make
index 704a31e9a2..afe88a54ca 100644
--- a/library/cpp/threading/skip_list/ut/ya.make
+++ b/library/cpp/threading/skip_list/ut/ya.make
@@ -1,4 +1,4 @@
-UNITTEST_FOR(library/cpp/threading/skip_list)
+UNITTEST_FOR(library/cpp/threading/skip_list)
OWNER(g:rtmr)
diff --git a/library/cpp/threading/task_scheduler/task_scheduler_ut.cpp b/library/cpp/threading/task_scheduler/task_scheduler_ut.cpp
index 3b5203194a..6a5d72aa8c 100644
--- a/library/cpp/threading/task_scheduler/task_scheduler_ut.cpp
+++ b/library/cpp/threading/task_scheduler/task_scheduler_ut.cpp
@@ -1,5 +1,5 @@
#include <algorithm>
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <util/stream/output.h>
#include <util/system/atomic.h>
diff --git a/library/cpp/threading/task_scheduler/ut/ya.make b/library/cpp/threading/task_scheduler/ut/ya.make
index 07ee8b0877..35e32d25cd 100644
--- a/library/cpp/threading/task_scheduler/ut/ya.make
+++ b/library/cpp/threading/task_scheduler/ut/ya.make
@@ -1,4 +1,4 @@
-UNITTEST_FOR(library/cpp/threading/task_scheduler)
+UNITTEST_FOR(library/cpp/threading/task_scheduler)
OWNER(g:middle)
diff --git a/library/cpp/threading/ya.make b/library/cpp/threading/ya.make
index f4d850ee17..77ac7e4273 100644
--- a/library/cpp/threading/ya.make
+++ b/library/cpp/threading/ya.make
@@ -1,64 +1,64 @@
RECURSE(
- algorithm
- async_task_batch
- async_task_batch/ut
- atomic
- atomic/ut
- atomic_shared_ptr
- atomic_shared_ptr/ut
- blocking_counter
- blocking_counter/ut
- blocking_queue
+ algorithm
+ async_task_batch
+ async_task_batch/ut
+ atomic
+ atomic/ut
+ atomic_shared_ptr
+ atomic_shared_ptr/ut
+ blocking_counter
+ blocking_counter/ut
+ blocking_queue
cancellation
- chunk_queue
- chunk_queue/ut
- cron
- cron/example
- equeue
- equeue/ut
- fair_lock
- fair_lock/ut
- future
- future/perf
+ chunk_queue
+ chunk_queue/ut
+ cron
+ cron/example
+ equeue
+ equeue/ut
+ fair_lock
+ fair_lock/ut
+ future
+ future/perf
future/subscription
- future/ut
- hot_swap
- hot_swap/ut
- light_rw_lock
- light_rw_lock/bench
- light_rw_lock/ut
- local_executor
- local_executor/ut
- mtp_tasks
- mtp_tasks/ut
- mux_event
- mux_event/ut
- named_lock
- named_lock/ut
- name_guard
- name_guard/ut
- periodically_updated
- poor_man_openmp
- poor_man_openmp/ut
- queue
- queue/ut
- rcu
- rcu/ut
- serial_postprocess_queue
- skip_list
- skip_list/perf
- skip_list/ut
- synchronized
- synchronized/ut
- task_scheduler
- task_scheduler/ut
- thread_local
- thread_local/benchmark
- thread_local/ut
- thread_namer
- thread_namer/ut
- ticket_lock
- ticket_lock/ut
- work_stealing
- work_stealing/ut
+ future/ut
+ hot_swap
+ hot_swap/ut
+ light_rw_lock
+ light_rw_lock/bench
+ light_rw_lock/ut
+ local_executor
+ local_executor/ut
+ mtp_tasks
+ mtp_tasks/ut
+ mux_event
+ mux_event/ut
+ named_lock
+ named_lock/ut
+ name_guard
+ name_guard/ut
+ periodically_updated
+ poor_man_openmp
+ poor_man_openmp/ut
+ queue
+ queue/ut
+ rcu
+ rcu/ut
+ serial_postprocess_queue
+ skip_list
+ skip_list/perf
+ skip_list/ut
+ synchronized
+ synchronized/ut
+ task_scheduler
+ task_scheduler/ut
+ thread_local
+ thread_local/benchmark
+ thread_local/ut
+ thread_namer
+ thread_namer/ut
+ ticket_lock
+ ticket_lock/ut
+ work_stealing
+ work_stealing/ut
)