diff options
author | kikht <kikht@yandex-team.ru> | 2022-02-10 16:45:14 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:14 +0300 |
commit | 778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (patch) | |
tree | be835aa92c6248212e705f25388ebafcf84bc7a1 /library/cpp/messagebus/actor | |
parent | 194cae0e8855b11be2005e1eff12c660c3ee9774 (diff) | |
download | ydb-778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5.tar.gz |
Restoring authorship annotation for <kikht@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/actor')
-rw-r--r-- | library/cpp/messagebus/actor/actor.h | 6 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/actor_ut.cpp | 8 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/executor.cpp | 12 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/executor.h | 8 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/queue_in_actor.h | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/ring_buffer.h | 8 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/ring_buffer_ut.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/tasks.h | 2 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/temp_tls_vector.h | 6 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/thread_extra.cpp | 8 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/what_thread_does.cpp | 6 | ||||
-rw-r--r-- | library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp | 4 |
13 files changed, 40 insertions, 40 deletions
diff --git a/library/cpp/messagebus/actor/actor.h b/library/cpp/messagebus/actor/actor.h index 6d6b394a51..9b8f20298a 100644 --- a/library/cpp/messagebus/actor/actor.h +++ b/library/cpp/messagebus/actor/actor.h @@ -1,11 +1,11 @@ #pragma once -#include "executor.h" +#include "executor.h" #include "tasks.h" #include "what_thread_does.h" -#include <util/system/yassert.h> - +#include <util/system/yassert.h> + namespace NActor { class IActor: protected IWorkItem { public: diff --git a/library/cpp/messagebus/actor/actor_ut.cpp b/library/cpp/messagebus/actor/actor_ut.cpp index 4329aabd77..b76ab55bfa 100644 --- a/library/cpp/messagebus/actor/actor_ut.cpp +++ b/library/cpp/messagebus/actor/actor_ut.cpp @@ -4,10 +4,10 @@ #include "queue_in_actor.h" #include <library/cpp/messagebus/misc/test_sync.h> - -#include <util/generic/object_counter.h> -#include <util/system/event.h> - + +#include <util/generic/object_counter.h> +#include <util/system/event.h> + using namespace NActor; template <typename TThis> diff --git a/library/cpp/messagebus/actor/executor.cpp b/library/cpp/messagebus/actor/executor.cpp index b6d33c7c0e..7a2227a458 100644 --- a/library/cpp/messagebus/actor/executor.cpp +++ b/library/cpp/messagebus/actor/executor.cpp @@ -1,14 +1,14 @@ -#include "executor.h" +#include "executor.h" #include "thread_extra.h" #include "what_thread_does.h" #include "what_thread_does_guard.h" -#include <util/generic/utility.h> -#include <util/random/random.h> -#include <util/stream/str.h> -#include <util/system/tls.h> -#include <util/system/yassert.h> +#include <util/generic/utility.h> +#include <util/random/random.h> +#include <util/stream/str.h> +#include <util/system/tls.h> +#include <util/system/yassert.h> #include <array> diff --git a/library/cpp/messagebus/actor/executor.h b/library/cpp/messagebus/actor/executor.h index 538b2196f0..7292d8be53 100644 --- a/library/cpp/messagebus/actor/executor.h +++ b/library/cpp/messagebus/actor/executor.h @@ -1,13 +1,13 @@ #pragma once -#include "ring_buffer_with_spin_lock.h" - +#include "ring_buffer_with_spin_lock.h" + #include <util/generic/array_ref.h> #include <util/generic/vector.h> #include <util/system/condvar.h> #include <util/system/event.h> -#include <util/system/mutex.h> -#include <util/system/thread.h> +#include <util/system/mutex.h> +#include <util/system/thread.h> #include <util/thread/lfqueue.h> namespace NActor { diff --git a/library/cpp/messagebus/actor/queue_in_actor.h b/library/cpp/messagebus/actor/queue_in_actor.h index df6b53557d..9865996532 100644 --- a/library/cpp/messagebus/actor/queue_in_actor.h +++ b/library/cpp/messagebus/actor/queue_in_actor.h @@ -3,8 +3,8 @@ #include "actor.h" #include "queue_for_actor.h" -#include <functional> - +#include <functional> + namespace NActor { template <typename TItem> class IQueueInActor { diff --git a/library/cpp/messagebus/actor/ring_buffer.h b/library/cpp/messagebus/actor/ring_buffer.h index 6346756d85..ec5706f7c7 100644 --- a/library/cpp/messagebus/actor/ring_buffer.h +++ b/library/cpp/messagebus/actor/ring_buffer.h @@ -1,9 +1,9 @@ #pragma once -#include <util/generic/array_ref.h> -#include <util/generic/maybe.h> -#include <util/generic/utility.h> -#include <util/generic/vector.h> +#include <util/generic/array_ref.h> +#include <util/generic/maybe.h> +#include <util/generic/utility.h> +#include <util/generic/vector.h> #include <util/system/yassert.h> template <typename T> diff --git a/library/cpp/messagebus/actor/ring_buffer_ut.cpp b/library/cpp/messagebus/actor/ring_buffer_ut.cpp index b0dd1bb933..bdb379b3a9 100644 --- a/library/cpp/messagebus/actor/ring_buffer_ut.cpp +++ b/library/cpp/messagebus/actor/ring_buffer_ut.cpp @@ -2,8 +2,8 @@ #include "ring_buffer.h" -#include <util/random/random.h> - +#include <util/random/random.h> + Y_UNIT_TEST_SUITE(RingBuffer) { struct TRingBufferTester { TRingBuffer<unsigned> RingBuffer; diff --git a/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h b/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h index 325d8bb397..f0b7cd90e4 100644 --- a/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h +++ b/library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h @@ -1,7 +1,7 @@ #pragma once -#include "ring_buffer.h" - +#include "ring_buffer.h" + #include <util/system/spinlock.h> template <typename T> diff --git a/library/cpp/messagebus/actor/tasks.h b/library/cpp/messagebus/actor/tasks.h index 9df0453931..31d35931d2 100644 --- a/library/cpp/messagebus/actor/tasks.h +++ b/library/cpp/messagebus/actor/tasks.h @@ -1,6 +1,6 @@ #pragma once -#include <util/system/atomic.h> +#include <util/system/atomic.h> #include <util/system/yassert.h> namespace NActor { diff --git a/library/cpp/messagebus/actor/temp_tls_vector.h b/library/cpp/messagebus/actor/temp_tls_vector.h index 1860f544ff..675d92f5b0 100644 --- a/library/cpp/messagebus/actor/temp_tls_vector.h +++ b/library/cpp/messagebus/actor/temp_tls_vector.h @@ -1,8 +1,8 @@ #pragma once -#include "thread_extra.h" - -#include <util/generic/vector.h> +#include "thread_extra.h" + +#include <util/generic/vector.h> #include <util/system/yassert.h> template <typename T, typename TTag = void, template <typename, class> class TVectorType = TVector> diff --git a/library/cpp/messagebus/actor/thread_extra.cpp b/library/cpp/messagebus/actor/thread_extra.cpp index bce931ff1d..048480f255 100644 --- a/library/cpp/messagebus/actor/thread_extra.cpp +++ b/library/cpp/messagebus/actor/thread_extra.cpp @@ -1,7 +1,7 @@ -#include "thread_extra.h" - -#include <util/stream/str.h> -#include <util/system/execpath.h> +#include "thread_extra.h" + +#include <util/stream/str.h> +#include <util/system/execpath.h> #include <util/system/platform.h> #include <util/system/thread.h> diff --git a/library/cpp/messagebus/actor/what_thread_does.cpp b/library/cpp/messagebus/actor/what_thread_does.cpp index bda58de407..bebb6a888c 100644 --- a/library/cpp/messagebus/actor/what_thread_does.cpp +++ b/library/cpp/messagebus/actor/what_thread_does.cpp @@ -1,9 +1,9 @@ -#include "what_thread_does.h" +#include "what_thread_does.h" #include "thread_extra.h" -#include <util/system/tls.h> - +#include <util/system/tls.h> + Y_POD_STATIC_THREAD(const char*) WhatThreadDoes; diff --git a/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp b/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp index 12efbfc89e..e4b218a7ca 100644 --- a/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp +++ b/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp @@ -2,8 +2,8 @@ #include "what_thread_does_guard.h" -#include <util/system/mutex.h> - +#include <util/system/mutex.h> + Y_UNIT_TEST_SUITE(WhatThreadDoesGuard) { Y_UNIT_TEST(Simple) { TMutex mutex; |