aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/actor
diff options
context:
space:
mode:
authorkikht <kikht@yandex-team.ru>2022-02-10 16:45:14 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:14 +0300
commit778e51ba091dc39e7b7fcab2b9cf4dbedfb6f2b5 (patch)
treebe835aa92c6248212e705f25388ebafcf84bc7a1 /library/cpp/messagebus/actor
parent194cae0e8855b11be2005e1eff12c660c3ee9774 (diff)
downloadydb-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.h6
-rw-r--r--library/cpp/messagebus/actor/actor_ut.cpp8
-rw-r--r--library/cpp/messagebus/actor/executor.cpp12
-rw-r--r--library/cpp/messagebus/actor/executor.h8
-rw-r--r--library/cpp/messagebus/actor/queue_in_actor.h4
-rw-r--r--library/cpp/messagebus/actor/ring_buffer.h8
-rw-r--r--library/cpp/messagebus/actor/ring_buffer_ut.cpp4
-rw-r--r--library/cpp/messagebus/actor/ring_buffer_with_spin_lock.h4
-rw-r--r--library/cpp/messagebus/actor/tasks.h2
-rw-r--r--library/cpp/messagebus/actor/temp_tls_vector.h6
-rw-r--r--library/cpp/messagebus/actor/thread_extra.cpp8
-rw-r--r--library/cpp/messagebus/actor/what_thread_does.cpp6
-rw-r--r--library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp4
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;