aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/threading
diff options
context:
space:
mode:
authorIlnur Khuziev <ilnur.khuziev@yandex.ru>2022-02-10 16:46:14 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:14 +0300
commit60040c91ffe701a84689b2c6310ff845e65cff42 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/threading
parent736dcd8ca259457a136f2f9f9168c44643914323 (diff)
downloadydb-60040c91ffe701a84689b2c6310ff845e65cff42.tar.gz
Restoring authorship annotation for Ilnur Khuziev <ilnur.khuziev@yandex.ru>. Commit 2 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 08286d20a4..9481f41d8d 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 65a9a3fb8c..3c555685df 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 3e0a401b5f..55859601a1 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 a0ed159b89..8cb36d8dd1 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 7c6ffa5ef9..a35ed6bc4b 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 7bdc1d0dda..54a848e912 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 abedda6497..9cf2aced44 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 d0cfaeae92..2f6293d47d 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 855fab8d0f..a3699744e4 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 6703645ca9..5fd4296a93 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 18f55aba69..2e82bb953e 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 2068337f4e..05950a568d 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 3bf8257387..ff63db1725 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 3d362cd322..5a0690af47 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 286a8a97bb..943d585d4b 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 a33f54adf2..d018ea15cc 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 5d4794cd3c..34ae9edb4e 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 aee11c315e..3bc9762671 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 42902832ed..262080e8d1 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 693a153924..99530dd1f6 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 704c0c5eb1..566b622370 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 bec9b65d82..c3027ea544 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 708d20e998..7969b52a50 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 87916f77e2..e82063d959 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 ce783f6616..92928b837c 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 cda9aaaa4f..1d3fbb4bf4 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 d0c622f4ef..c1c824f67c 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 81f37d80ba..ac5737717c 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 8490246645..be579a5ca0 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 8346c26894..7417636864 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 ef333ab91e..6d7aa123ed 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 e2a240920b..5f56f8583e 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 1a48e1ca00..80eca147da 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 84e81006aa..7e980d3e27 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 fd5108a01a..a43b7f520e 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 647ebc0551..8883d9bf69 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 a74ffe2a04..4ad52049e7 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 b0df32d076..01bfafa404 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 eff3d92663..52fcffda66 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 afe88a54ca..704a31e9a2 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 6a5d72aa8c..3b5203194a 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 35e32d25cd..07ee8b0877 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 77ac7e4273..f4d850ee17 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
)