aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorcerevra <cerevra@yandex-team.ru>2022-02-10 16:45:59 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:59 +0300
commit4f292c7e2fd0a41da93fda51b2d440c979a330b7 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/messagebus
parentbf41dd01f6c920583e9faae7cd55ed25e547e052 (diff)
downloadydb-4f292c7e2fd0a41da93fda51b2d440c979a330b7.tar.gz
Restoring authorship annotation for <cerevra@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/acceptor.h2
-rw-r--r--library/cpp/messagebus/actor/actor_ut.cpp2
-rw-r--r--library/cpp/messagebus/all/ya.make12
-rw-r--r--library/cpp/messagebus/codegen.h2
-rw-r--r--library/cpp/messagebus/config/defs.h4
-rw-r--r--library/cpp/messagebus/config/ya.make2
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver.cpp4
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver_handler.h2
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver_proto.h2
-rw-r--r--library/cpp/messagebus/debug_receiver/ya.make4
-rw-r--r--library/cpp/messagebus/defs.h2
-rw-r--r--library/cpp/messagebus/lfqueue_batch.h2
-rw-r--r--library/cpp/messagebus/local_flags.h2
-rw-r--r--library/cpp/messagebus/mb_lwtrace.cpp2
-rw-r--r--library/cpp/messagebus/mb_lwtrace.h2
-rw-r--r--library/cpp/messagebus/message_status.h2
-rw-r--r--library/cpp/messagebus/message_status_counter.cpp2
-rw-r--r--library/cpp/messagebus/message_status_counter.h2
-rw-r--r--library/cpp/messagebus/message_status_counter_ut.cpp2
-rw-r--r--library/cpp/messagebus/netaddr.h2
-rw-r--r--library/cpp/messagebus/network_ut.cpp2
-rw-r--r--library/cpp/messagebus/oldmodule/module.cpp12
-rw-r--r--library/cpp/messagebus/oldmodule/module.h2
-rw-r--r--library/cpp/messagebus/oldmodule/startsession.cpp2
-rw-r--r--library/cpp/messagebus/oldmodule/startsession.h2
-rw-r--r--library/cpp/messagebus/oldmodule/ya.make4
-rw-r--r--library/cpp/messagebus/protobuf/ya.make4
-rw-r--r--library/cpp/messagebus/protobuf/ybusbuf.cpp2
-rw-r--r--library/cpp/messagebus/protobuf/ybusbuf.h2
-rw-r--r--library/cpp/messagebus/rain_check/core/coro_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/core/env.h2
-rw-r--r--library/cpp/messagebus/rain_check/core/simple_ut.cpp4
-rw-r--r--library/cpp/messagebus/rain_check/core/sleep.h2
-rw-r--r--library/cpp/messagebus/rain_check/core/sleep_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/core/spawn_ut.cpp6
-rw-r--r--library/cpp/messagebus/rain_check/core/task.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/core/task.h6
-rw-r--r--library/cpp/messagebus/rain_check/core/track.h6
-rw-r--r--library/cpp/messagebus/rain_check/core/track_ut.cpp4
-rw-r--r--library/cpp/messagebus/rain_check/core/ya.make10
-rw-r--r--library/cpp/messagebus/rain_check/http/client.cpp10
-rw-r--r--library/cpp/messagebus/rain_check/http/client.h4
-rw-r--r--library/cpp/messagebus/rain_check/http/client_ut.cpp8
-rw-r--r--library/cpp/messagebus/rain_check/http/http_code_extractor.cpp12
-rw-r--r--library/cpp/messagebus/rain_check/http/http_code_extractor.h10
-rw-r--r--library/cpp/messagebus/rain_check/http/ya.make8
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_client.h4
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp6
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_server.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_server.h6
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp4
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/ya.make4
-rw-r--r--library/cpp/messagebus/rain_check/test/helper/misc.h2
-rw-r--r--library/cpp/messagebus/rain_check/test/helper/ya.make2
-rw-r--r--library/cpp/messagebus/rain_check/test/perftest/perftest.cpp4
-rw-r--r--library/cpp/messagebus/rain_check/test/perftest/ya.make4
-rw-r--r--library/cpp/messagebus/rain_check/test/ut/test.h4
-rw-r--r--library/cpp/messagebus/rain_check/test/ut/ya.make8
-rw-r--r--library/cpp/messagebus/remote_client_connection.cpp4
-rw-r--r--library/cpp/messagebus/remote_client_session.cpp2
-rw-r--r--library/cpp/messagebus/remote_connection.cpp2
-rw-r--r--library/cpp/messagebus/remote_connection.h10
-rw-r--r--library/cpp/messagebus/remote_connection_status.cpp2
-rw-r--r--library/cpp/messagebus/remote_connection_status.h4
-rw-r--r--library/cpp/messagebus/remote_server_session.cpp2
-rw-r--r--library/cpp/messagebus/scheduler/scheduler_ut.cpp2
-rw-r--r--library/cpp/messagebus/scheduler_actor.h6
-rw-r--r--library/cpp/messagebus/session.h2
-rw-r--r--library/cpp/messagebus/session_config.h2
-rw-r--r--library/cpp/messagebus/session_impl.h6
-rw-r--r--library/cpp/messagebus/test/example/client/client.cpp2
-rw-r--r--library/cpp/messagebus/test/example/client/ya.make2
-rw-r--r--library/cpp/messagebus/test/example/common/proto.h6
-rw-r--r--library/cpp/messagebus/test/example/common/ya.make4
-rw-r--r--library/cpp/messagebus/test/example/server/server.cpp2
-rw-r--r--library/cpp/messagebus/test/example/server/ya.make2
-rw-r--r--library/cpp/messagebus/test/helper/example.h4
-rw-r--r--library/cpp/messagebus/test/helper/example_module.h2
-rw-r--r--library/cpp/messagebus/test/helper/hanging_server.h2
-rw-r--r--library/cpp/messagebus/test/helper/message_handler_error.h2
-rw-r--r--library/cpp/messagebus/test/helper/object_count_check.h14
-rw-r--r--library/cpp/messagebus/test/helper/ya.make2
-rw-r--r--library/cpp/messagebus/test/perftest/perftest.cpp22
-rw-r--r--library/cpp/messagebus/test/perftest/simple_proto.h2
-rw-r--r--library/cpp/messagebus/test/perftest/stackcollect.diff8
-rw-r--r--library/cpp/messagebus/test/perftest/ya.make16
-rw-r--r--library/cpp/messagebus/test/ut/locator_uniq_ut.cpp4
-rw-r--r--library/cpp/messagebus/test/ut/messagebus_ut.cpp12
-rw-r--r--library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp8
-rw-r--r--library/cpp/messagebus/test/ut/module_client_ut.cpp12
-rw-r--r--library/cpp/messagebus/test/ut/module_server_ut.cpp10
-rw-r--r--library/cpp/messagebus/test/ut/moduletest.h10
-rw-r--r--library/cpp/messagebus/test/ut/one_way_ut.cpp16
-rw-r--r--library/cpp/messagebus/test/ut/starter_ut.cpp6
-rw-r--r--library/cpp/messagebus/test/ut/sync_client_ut.cpp4
-rw-r--r--library/cpp/messagebus/test/ut/ya.make8
-rw-r--r--library/cpp/messagebus/thread_extra.h2
-rw-r--r--library/cpp/messagebus/www/html_output.h2
-rw-r--r--library/cpp/messagebus/www/www.cpp14
-rw-r--r--library/cpp/messagebus/www/www.h4
-rw-r--r--library/cpp/messagebus/www/ya.make16
-rw-r--r--library/cpp/messagebus/ya.make14
-rw-r--r--library/cpp/messagebus/ybus.h6
103 files changed, 260 insertions, 260 deletions
diff --git a/library/cpp/messagebus/acceptor.h b/library/cpp/messagebus/acceptor.h
index 00c5788299..57cb010bf2 100644
--- a/library/cpp/messagebus/acceptor.h
+++ b/library/cpp/messagebus/acceptor.h
@@ -7,7 +7,7 @@
#include "session_impl.h"
#include "shutdown_state.h"
-#include <library/cpp/messagebus/actor/actor.h>
+#include <library/cpp/messagebus/actor/actor.h>
#include <util/system/event.h>
diff --git a/library/cpp/messagebus/actor/actor_ut.cpp b/library/cpp/messagebus/actor/actor_ut.cpp
index 12f64ac208..b76ab55bfa 100644
--- a/library/cpp/messagebus/actor/actor_ut.cpp
+++ b/library/cpp/messagebus/actor/actor_ut.cpp
@@ -3,7 +3,7 @@
#include "actor.h"
#include "queue_in_actor.h"
-#include <library/cpp/messagebus/misc/test_sync.h>
+#include <library/cpp/messagebus/misc/test_sync.h>
#include <util/generic/object_counter.h>
#include <util/system/event.h>
diff --git a/library/cpp/messagebus/all/ya.make b/library/cpp/messagebus/all/ya.make
index 36d9b5adf3..ffa2dbfabc 100644
--- a/library/cpp/messagebus/all/ya.make
+++ b/library/cpp/messagebus/all/ya.make
@@ -1,10 +1,10 @@
OWNER(g:messagebus)
RECURSE_ROOT_RELATIVE(
- library/python/messagebus
- library/cpp/messagebus/debug_receiver
- library/cpp/messagebus/oldmodule
- library/cpp/messagebus/rain_check
- library/cpp/messagebus/test
- library/cpp/messagebus/www
+ library/python/messagebus
+ library/cpp/messagebus/debug_receiver
+ library/cpp/messagebus/oldmodule
+ library/cpp/messagebus/rain_check
+ library/cpp/messagebus/test
+ library/cpp/messagebus/www
)
diff --git a/library/cpp/messagebus/codegen.h b/library/cpp/messagebus/codegen.h
index d4ce217aa4..83e969e811 100644
--- a/library/cpp/messagebus/codegen.h
+++ b/library/cpp/messagebus/codegen.h
@@ -1,4 +1,4 @@
#pragma once
-#include <library/cpp/messagebus/config/codegen.h>
+#include <library/cpp/messagebus/config/codegen.h>
diff --git a/library/cpp/messagebus/config/defs.h b/library/cpp/messagebus/config/defs.h
index 3fe1f2a6d0..92b1df9969 100644
--- a/library/cpp/messagebus/config/defs.h
+++ b/library/cpp/messagebus/config/defs.h
@@ -1,11 +1,11 @@
#pragma once
-// unique tag to fix pragma once gcc glueing: ./library/cpp/messagebus/defs.h
+// unique tag to fix pragma once gcc glueing: ./library/cpp/messagebus/defs.h
#include "codegen.h"
#include "netaddr.h"
-#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
+#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
#include <util/generic/list.h>
diff --git a/library/cpp/messagebus/config/ya.make b/library/cpp/messagebus/config/ya.make
index 91c555b920..20c7dfed19 100644
--- a/library/cpp/messagebus/config/ya.make
+++ b/library/cpp/messagebus/config/ya.make
@@ -4,7 +4,7 @@ OWNER(g:messagebus)
PEERDIR(
library/cpp/getopt
- library/cpp/deprecated/enum_codegen
+ library/cpp/deprecated/enum_codegen
)
SRCS(
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver.cpp b/library/cpp/messagebus/debug_receiver/debug_receiver.cpp
index bc1354246e..23b02d1003 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver.cpp
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver.cpp
@@ -1,10 +1,10 @@
#include "debug_receiver_handler.h"
#include "debug_receiver_proto.h"
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
#include <library/cpp/getopt/last_getopt.h>
-#include <library/cpp/lwtrace/all.h>
+#include <library/cpp/lwtrace/all.h>
using namespace NBus;
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver_handler.h b/library/cpp/messagebus/debug_receiver/debug_receiver_handler.h
index 3180743607..0aed6b9984 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver_handler.h
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver_handler.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
struct TDebugReceiverHandler: public NBus::IBusServerHandler {
NBus::TBusServerSession* ServerSession;
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h
index f71ca3279c..d34710dcf7 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver_proto.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
struct TDebugReceiverMessage: public NBus::TBusMessage {
/// constructor to create messages on sending end
diff --git a/library/cpp/messagebus/debug_receiver/ya.make b/library/cpp/messagebus/debug_receiver/ya.make
index ce1ad26518..f1b14d35bb 100644
--- a/library/cpp/messagebus/debug_receiver/ya.make
+++ b/library/cpp/messagebus/debug_receiver/ya.make
@@ -10,8 +10,8 @@ SRCS(
PEERDIR(
library/cpp/getopt
- library/cpp/lwtrace
- library/cpp/messagebus
+ library/cpp/lwtrace
+ library/cpp/messagebus
)
END()
diff --git a/library/cpp/messagebus/defs.h b/library/cpp/messagebus/defs.h
index bcf3faa32a..cb553acc45 100644
--- a/library/cpp/messagebus/defs.h
+++ b/library/cpp/messagebus/defs.h
@@ -1,4 +1,4 @@
#pragma once
-#include <library/cpp/messagebus/config/defs.h>
+#include <library/cpp/messagebus/config/defs.h>
diff --git a/library/cpp/messagebus/lfqueue_batch.h b/library/cpp/messagebus/lfqueue_batch.h
index 986f82c4e4..8128d3154d 100644
--- a/library/cpp/messagebus/lfqueue_batch.h
+++ b/library/cpp/messagebus/lfqueue_batch.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/messagebus/actor/temp_tls_vector.h>
+#include <library/cpp/messagebus/actor/temp_tls_vector.h>
#include <util/generic/vector.h>
#include <util/thread/lfstack.h>
diff --git a/library/cpp/messagebus/local_flags.h b/library/cpp/messagebus/local_flags.h
index b9e047de18..f589283188 100644
--- a/library/cpp/messagebus/local_flags.h
+++ b/library/cpp/messagebus/local_flags.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
+#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
#include <util/generic/string.h>
#include <util/stream/output.h>
diff --git a/library/cpp/messagebus/mb_lwtrace.cpp b/library/cpp/messagebus/mb_lwtrace.cpp
index f0929485a5..c54cd5ab71 100644
--- a/library/cpp/messagebus/mb_lwtrace.cpp
+++ b/library/cpp/messagebus/mb_lwtrace.cpp
@@ -1,6 +1,6 @@
#include "mb_lwtrace.h"
-#include <library/cpp/lwtrace/all.h>
+#include <library/cpp/lwtrace/all.h>
#include <util/generic/singleton.h>
diff --git a/library/cpp/messagebus/mb_lwtrace.h b/library/cpp/messagebus/mb_lwtrace.h
index ec817ea626..e62728b265 100644
--- a/library/cpp/messagebus/mb_lwtrace.h
+++ b/library/cpp/messagebus/mb_lwtrace.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/lwtrace/all.h>
+#include <library/cpp/lwtrace/all.h>
#include <util/generic/string.h>
diff --git a/library/cpp/messagebus/message_status.h b/library/cpp/messagebus/message_status.h
index 98273a5a5c..e1878960b3 100644
--- a/library/cpp/messagebus/message_status.h
+++ b/library/cpp/messagebus/message_status.h
@@ -3,7 +3,7 @@
#include "codegen.h"
#include "defs.h"
-#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
+#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
namespace NBus {
////////////////////////////////////////////////////////////////
diff --git a/library/cpp/messagebus/message_status_counter.cpp b/library/cpp/messagebus/message_status_counter.cpp
index d1446bdb95..891c8f5bb2 100644
--- a/library/cpp/messagebus/message_status_counter.cpp
+++ b/library/cpp/messagebus/message_status_counter.cpp
@@ -3,7 +3,7 @@
#include "key_value_printer.h"
#include "text_utils.h"
-#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
+#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
#include <util/stream/str.h>
diff --git a/library/cpp/messagebus/message_status_counter.h b/library/cpp/messagebus/message_status_counter.h
index 94a0f3e8ac..e8ba2fdd31 100644
--- a/library/cpp/messagebus/message_status_counter.h
+++ b/library/cpp/messagebus/message_status_counter.h
@@ -2,7 +2,7 @@
#include "message_status.h"
-#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
+#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
#include <util/generic/string.h>
diff --git a/library/cpp/messagebus/message_status_counter_ut.cpp b/library/cpp/messagebus/message_status_counter_ut.cpp
index 5bdfeff5b0..9598651329 100644
--- a/library/cpp/messagebus/message_status_counter_ut.cpp
+++ b/library/cpp/messagebus/message_status_counter_ut.cpp
@@ -2,7 +2,7 @@
#include "message_status_counter.h"
-#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
+#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
using namespace NBus;
using namespace NBus::NPrivate;
diff --git a/library/cpp/messagebus/netaddr.h b/library/cpp/messagebus/netaddr.h
index af07a72ad0..f915c8c574 100644
--- a/library/cpp/messagebus/netaddr.h
+++ b/library/cpp/messagebus/netaddr.h
@@ -1,4 +1,4 @@
#pragma once
-#include <library/cpp/messagebus/config/netaddr.h>
+#include <library/cpp/messagebus/config/netaddr.h>
diff --git a/library/cpp/messagebus/network_ut.cpp b/library/cpp/messagebus/network_ut.cpp
index ebca2497f1..f1798419db 100644
--- a/library/cpp/messagebus/network_ut.cpp
+++ b/library/cpp/messagebus/network_ut.cpp
@@ -2,7 +2,7 @@
#include "network.h"
-#include <library/cpp/messagebus/test/helper/fixed_port.h>
+#include <library/cpp/messagebus/test/helper/fixed_port.h>
using namespace NBus;
using namespace NBus::NPrivate;
diff --git a/library/cpp/messagebus/oldmodule/module.cpp b/library/cpp/messagebus/oldmodule/module.cpp
index f5f559c8b1..24bd778799 100644
--- a/library/cpp/messagebus/oldmodule/module.cpp
+++ b/library/cpp/messagebus/oldmodule/module.cpp
@@ -1,11 +1,11 @@
#include "module.h"
-#include <library/cpp/messagebus/scheduler_actor.h>
-#include <library/cpp/messagebus/thread_extra.h>
-#include <library/cpp/messagebus/actor/actor.h>
-#include <library/cpp/messagebus/actor/queue_in_actor.h>
-#include <library/cpp/messagebus/actor/what_thread_does.h>
-#include <library/cpp/messagebus/actor/what_thread_does_guard.h>
+#include <library/cpp/messagebus/scheduler_actor.h>
+#include <library/cpp/messagebus/thread_extra.h>
+#include <library/cpp/messagebus/actor/actor.h>
+#include <library/cpp/messagebus/actor/queue_in_actor.h>
+#include <library/cpp/messagebus/actor/what_thread_does.h>
+#include <library/cpp/messagebus/actor/what_thread_does_guard.h>
#include <util/generic/singleton.h>
#include <util/string/printf.h>
diff --git a/library/cpp/messagebus/oldmodule/module.h b/library/cpp/messagebus/oldmodule/module.h
index 1f0f562136..8d1c4a5d52 100644
--- a/library/cpp/messagebus/oldmodule/module.h
+++ b/library/cpp/messagebus/oldmodule/module.h
@@ -41,7 +41,7 @@
#include "startsession.h"
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
#include <util/generic/noncopyable.h>
#include <util/generic/object_counter.h>
diff --git a/library/cpp/messagebus/oldmodule/startsession.cpp b/library/cpp/messagebus/oldmodule/startsession.cpp
index b6c266d17d..7c38801d62 100644
--- a/library/cpp/messagebus/oldmodule/startsession.cpp
+++ b/library/cpp/messagebus/oldmodule/startsession.cpp
@@ -16,7 +16,7 @@
#include "module.h"
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
namespace NBus {
void* TBusStarter::_starter(void* data) {
diff --git a/library/cpp/messagebus/oldmodule/startsession.h b/library/cpp/messagebus/oldmodule/startsession.h
index 6d041edcb8..5e26e7e1e5 100644
--- a/library/cpp/messagebus/oldmodule/startsession.h
+++ b/library/cpp/messagebus/oldmodule/startsession.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
#include <util/system/thread.h>
diff --git a/library/cpp/messagebus/oldmodule/ya.make b/library/cpp/messagebus/oldmodule/ya.make
index e04a65f9e8..ca5eae74f0 100644
--- a/library/cpp/messagebus/oldmodule/ya.make
+++ b/library/cpp/messagebus/oldmodule/ya.make
@@ -3,8 +3,8 @@ LIBRARY()
OWNER(g:messagebus)
PEERDIR(
- library/cpp/messagebus
- library/cpp/messagebus/actor
+ library/cpp/messagebus
+ library/cpp/messagebus/actor
)
SRCS(
diff --git a/library/cpp/messagebus/protobuf/ya.make b/library/cpp/messagebus/protobuf/ya.make
index e438d9f5b9..64ff240b51 100644
--- a/library/cpp/messagebus/protobuf/ya.make
+++ b/library/cpp/messagebus/protobuf/ya.make
@@ -8,8 +8,8 @@ SRCS(
PEERDIR(
contrib/libs/protobuf
- library/cpp/messagebus
- library/cpp/messagebus/actor
+ library/cpp/messagebus
+ library/cpp/messagebus/actor
)
END()
diff --git a/library/cpp/messagebus/protobuf/ybusbuf.cpp b/library/cpp/messagebus/protobuf/ybusbuf.cpp
index 45bc9a1cce..63415b3737 100644
--- a/library/cpp/messagebus/protobuf/ybusbuf.cpp
+++ b/library/cpp/messagebus/protobuf/ybusbuf.cpp
@@ -1,6 +1,6 @@
#include "ybusbuf.h"
-#include <library/cpp/messagebus/actor/what_thread_does.h>
+#include <library/cpp/messagebus/actor/what_thread_does.h>
#include <google/protobuf/io/coded_stream.h>
diff --git a/library/cpp/messagebus/protobuf/ybusbuf.h b/library/cpp/messagebus/protobuf/ybusbuf.h
index 92b5e286b8..57b4267ea5 100644
--- a/library/cpp/messagebus/protobuf/ybusbuf.h
+++ b/library/cpp/messagebus/protobuf/ybusbuf.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
#include <google/protobuf/descriptor.h>
#include <google/protobuf/message.h>
diff --git a/library/cpp/messagebus/rain_check/core/coro_ut.cpp b/library/cpp/messagebus/rain_check/core/coro_ut.cpp
index bf7124e871..61a33584a5 100644
--- a/library/cpp/messagebus/rain_check/core/coro_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/coro_ut.cpp
@@ -3,7 +3,7 @@
#include "coro.h"
#include "spawn.h"
-#include <library/cpp/messagebus/rain_check/test/ut/test.h>
+#include <library/cpp/messagebus/rain_check/test/ut/test.h>
using namespace NRainCheck;
diff --git a/library/cpp/messagebus/rain_check/core/env.h b/library/cpp/messagebus/rain_check/core/env.h
index b53fd59200..f6dd7fceb6 100644
--- a/library/cpp/messagebus/rain_check/core/env.h
+++ b/library/cpp/messagebus/rain_check/core/env.h
@@ -3,7 +3,7 @@
#include "sleep.h"
#include "spawn.h"
-#include <library/cpp/messagebus/actor/executor.h>
+#include <library/cpp/messagebus/actor/executor.h>
#include <util/generic/ptr.h>
diff --git a/library/cpp/messagebus/rain_check/core/simple_ut.cpp b/library/cpp/messagebus/rain_check/core/simple_ut.cpp
index e25dfdf779..d4545e05aa 100644
--- a/library/cpp/messagebus/rain_check/core/simple_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/simple_ut.cpp
@@ -1,8 +1,8 @@
#include <library/cpp/testing/unittest/registar.h>
-#include <library/cpp/messagebus/rain_check/test/ut/test.h>
+#include <library/cpp/messagebus/rain_check/test/ut/test.h>
-#include <library/cpp/messagebus/latch.h>
+#include <library/cpp/messagebus/latch.h>
#include <util/system/event.h>
diff --git a/library/cpp/messagebus/rain_check/core/sleep.h b/library/cpp/messagebus/rain_check/core/sleep.h
index a39d1c4317..1a7a1f8674 100644
--- a/library/cpp/messagebus/rain_check/core/sleep.h
+++ b/library/cpp/messagebus/rain_check/core/sleep.h
@@ -2,7 +2,7 @@
#include "fwd.h"
-#include <library/cpp/messagebus/scheduler/scheduler.h>
+#include <library/cpp/messagebus/scheduler/scheduler.h>
#include <util/datetime/base.h>
diff --git a/library/cpp/messagebus/rain_check/core/sleep_ut.cpp b/library/cpp/messagebus/rain_check/core/sleep_ut.cpp
index fdc551d333..2ae85a87b1 100644
--- a/library/cpp/messagebus/rain_check/core/sleep_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/sleep_ut.cpp
@@ -1,6 +1,6 @@
#include <library/cpp/testing/unittest/registar.h>
-#include <library/cpp/messagebus/rain_check/test/ut/test.h>
+#include <library/cpp/messagebus/rain_check/test/ut/test.h>
#include <util/system/event.h>
diff --git a/library/cpp/messagebus/rain_check/core/spawn_ut.cpp b/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
index 122f057004..ba5a5e41cf 100644
--- a/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
@@ -1,9 +1,9 @@
#include <library/cpp/testing/unittest/registar.h>
-#include <library/cpp/messagebus/rain_check/test/helper/misc.h>
-#include <library/cpp/messagebus/rain_check/test/ut/test.h>
+#include <library/cpp/messagebus/rain_check/test/helper/misc.h>
+#include <library/cpp/messagebus/rain_check/test/ut/test.h>
-#include <library/cpp/messagebus/latch.h>
+#include <library/cpp/messagebus/latch.h>
#include <util/system/event.h>
diff --git a/library/cpp/messagebus/rain_check/core/task.cpp b/library/cpp/messagebus/rain_check/core/task.cpp
index f9acf1e0f7..a098437d53 100644
--- a/library/cpp/messagebus/rain_check/core/task.cpp
+++ b/library/cpp/messagebus/rain_check/core/task.cpp
@@ -1,6 +1,6 @@
#include "rain_check.h"
-#include <library/cpp/messagebus/actor/temp_tls_vector.h>
+#include <library/cpp/messagebus/actor/temp_tls_vector.h>
#include <util/system/type_name.h>
#include <util/system/tls.h>
diff --git a/library/cpp/messagebus/rain_check/core/task.h b/library/cpp/messagebus/rain_check/core/task.h
index 12b55d347c..7d8778bcda 100644
--- a/library/cpp/messagebus/rain_check/core/task.h
+++ b/library/cpp/messagebus/rain_check/core/task.h
@@ -2,10 +2,10 @@
#include "fwd.h"
-#include <library/cpp/messagebus/actor/actor.h>
-#include <library/cpp/messagebus/misc/atomic_box.h>
+#include <library/cpp/messagebus/actor/actor.h>
+#include <library/cpp/messagebus/misc/atomic_box.h>
-#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
+#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
#include <util/generic/noncopyable.h>
#include <util/generic/ptr.h>
diff --git a/library/cpp/messagebus/rain_check/core/track.h b/library/cpp/messagebus/rain_check/core/track.h
index 094bee1506..d387de7574 100644
--- a/library/cpp/messagebus/rain_check/core/track.h
+++ b/library/cpp/messagebus/rain_check/core/track.h
@@ -3,9 +3,9 @@
#include "spawn.h"
#include "task.h"
-#include <library/cpp/messagebus/async_result.h>
-#include <library/cpp/messagebus/actor/queue_in_actor.h>
-#include <library/cpp/messagebus/misc/atomic_box.h>
+#include <library/cpp/messagebus/async_result.h>
+#include <library/cpp/messagebus/actor/queue_in_actor.h>
+#include <library/cpp/messagebus/misc/atomic_box.h>
#include <util/generic/intrlist.h>
#include <util/system/event.h>
diff --git a/library/cpp/messagebus/rain_check/core/track_ut.cpp b/library/cpp/messagebus/rain_check/core/track_ut.cpp
index 7762e7770d..05f7de1319 100644
--- a/library/cpp/messagebus/rain_check/core/track_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/track_ut.cpp
@@ -2,8 +2,8 @@
#include "track.h"
-#include <library/cpp/messagebus/rain_check/test/helper/misc.h>
-#include <library/cpp/messagebus/rain_check/test/ut/test.h>
+#include <library/cpp/messagebus/rain_check/test/helper/misc.h>
+#include <library/cpp/messagebus/rain_check/test/ut/test.h>
using namespace NRainCheck;
diff --git a/library/cpp/messagebus/rain_check/core/ya.make b/library/cpp/messagebus/rain_check/core/ya.make
index 307ca2192d..c6fb5640d4 100644
--- a/library/cpp/messagebus/rain_check/core/ya.make
+++ b/library/cpp/messagebus/rain_check/core/ya.make
@@ -3,11 +3,11 @@ LIBRARY()
OWNER(g:messagebus)
PEERDIR(
- library/cpp/coroutine/engine
- library/cpp/deprecated/enum_codegen
- library/cpp/messagebus
- library/cpp/messagebus/actor
- library/cpp/messagebus/scheduler
+ library/cpp/coroutine/engine
+ library/cpp/deprecated/enum_codegen
+ library/cpp/messagebus
+ library/cpp/messagebus/actor
+ library/cpp/messagebus/scheduler
)
SRCS(
diff --git a/library/cpp/messagebus/rain_check/http/client.cpp b/library/cpp/messagebus/rain_check/http/client.cpp
index 22deca3827..5ef5ceeece 100644
--- a/library/cpp/messagebus/rain_check/http/client.cpp
+++ b/library/cpp/messagebus/rain_check/http/client.cpp
@@ -2,11 +2,11 @@
#include "http_code_extractor.h"
-#include <library/cpp/http/io/stream.h>
-#include <library/cpp/neh/factory.h>
-#include <library/cpp/neh/http_common.h>
-#include <library/cpp/neh/location.h>
-#include <library/cpp/neh/neh.h>
+#include <library/cpp/http/io/stream.h>
+#include <library/cpp/neh/factory.h>
+#include <library/cpp/neh/http_common.h>
+#include <library/cpp/neh/location.h>
+#include <library/cpp/neh/neh.h>
#include <util/generic/ptr.h>
#include <util/generic/strbuf.h>
diff --git a/library/cpp/messagebus/rain_check/http/client.h b/library/cpp/messagebus/rain_check/http/client.h
index d16b1db304..d4199c4c98 100644
--- a/library/cpp/messagebus/rain_check/http/client.h
+++ b/library/cpp/messagebus/rain_check/http/client.h
@@ -1,8 +1,8 @@
#pragma once
-#include <library/cpp/messagebus/rain_check/core/task.h>
+#include <library/cpp/messagebus/rain_check/core/task.h>
-#include <library/cpp/http/misc/httpcodes.h>
+#include <library/cpp/http/misc/httpcodes.h>
#include <util/generic/maybe.h>
#include <util/generic/ptr.h>
diff --git a/library/cpp/messagebus/rain_check/http/client_ut.cpp b/library/cpp/messagebus/rain_check/http/client_ut.cpp
index 7a0d57e64c..1628114391 100644
--- a/library/cpp/messagebus/rain_check/http/client_ut.cpp
+++ b/library/cpp/messagebus/rain_check/http/client_ut.cpp
@@ -3,12 +3,12 @@
#include "client.h"
#include "http_code_extractor.h"
-#include <library/cpp/messagebus/rain_check/test/ut/test.h>
+#include <library/cpp/messagebus/rain_check/test/ut/test.h>
-#include <library/cpp/messagebus/test/helper/fixed_port.h>
+#include <library/cpp/messagebus/test/helper/fixed_port.h>
-#include <library/cpp/http/io/stream.h>
-#include <library/cpp/neh/rpc.h>
+#include <library/cpp/http/io/stream.h>
+#include <library/cpp/neh/rpc.h>
#include <util/generic/cast.h>
#include <util/generic/ptr.h>
diff --git a/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp b/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp
index 71e70d454e..51d75762f6 100644
--- a/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp
+++ b/library/cpp/messagebus/rain_check/http/http_code_extractor.cpp
@@ -1,7 +1,7 @@
#include "http_code_extractor.h"
-#include <library/cpp/http/io/stream.h>
-#include <library/cpp/http/misc/httpcodes.h>
+#include <library/cpp/http/io/stream.h>
+#include <library/cpp/http/misc/httpcodes.h>
#include <util/generic/maybe.h>
#include <util/generic/strbuf.h>
@@ -9,10 +9,10 @@
namespace NRainCheck {
TMaybe<HttpCodes> TryGetHttpCodeFromErrorDescription(const TStringBuf& errorMessage) {
- // Try to get HttpCode from library/cpp/neh response.
- // If response has HttpCode and it is not 200 OK, library/cpp/neh will send a message
- // "library/cpp/neh/http.cpp:<LINE>: request failed(<FIRST-HTTP-RESPONSE-LINE>)"
- // (see library/cpp/neh/http.cpp:625). So, we will try to parse this message and
+ // Try to get HttpCode from library/cpp/neh response.
+ // If response has HttpCode and it is not 200 OK, library/cpp/neh will send a message
+ // "library/cpp/neh/http.cpp:<LINE>: request failed(<FIRST-HTTP-RESPONSE-LINE>)"
+ // (see library/cpp/neh/http.cpp:625). So, we will try to parse this message and
// find out HttpCode in it. It is bad temporary solution, but we have no choice.
const TStringBuf SUBSTR = "request failed(";
const size_t SUBSTR_LEN = SUBSTR.size();
diff --git a/library/cpp/messagebus/rain_check/http/http_code_extractor.h b/library/cpp/messagebus/rain_check/http/http_code_extractor.h
index 727ebcbd61..33b565fa1c 100644
--- a/library/cpp/messagebus/rain_check/http/http_code_extractor.h
+++ b/library/cpp/messagebus/rain_check/http/http_code_extractor.h
@@ -1,15 +1,15 @@
#pragma once
-#include <library/cpp/http/misc/httpcodes.h>
+#include <library/cpp/http/misc/httpcodes.h>
#include <util/generic/maybe.h>
#include <util/generic/strbuf.h>
namespace NRainCheck {
- // Try to get HttpCode from library/cpp/neh response.
- // If response has HttpCode and it is not 200 OK, library/cpp/neh will send a message
- // "library/cpp/neh/http.cpp:<LINE>: request failed(<FIRST-HTTP-RESPONSE-LINE>)"
- // (see library/cpp/neh/http.cpp:625). So, we will try to parse this message and
+ // Try to get HttpCode from library/cpp/neh response.
+ // If response has HttpCode and it is not 200 OK, library/cpp/neh will send a message
+ // "library/cpp/neh/http.cpp:<LINE>: request failed(<FIRST-HTTP-RESPONSE-LINE>)"
+ // (see library/cpp/neh/http.cpp:625). So, we will try to parse this message and
// find out HttpCode in it. It is bad temporary solution, but we have no choice.
TMaybe<HttpCodes> TryGetHttpCodeFromErrorDescription(const TStringBuf& errorMessage);
diff --git a/library/cpp/messagebus/rain_check/http/ya.make b/library/cpp/messagebus/rain_check/http/ya.make
index 59f7b3b2f2..ef13329df3 100644
--- a/library/cpp/messagebus/rain_check/http/ya.make
+++ b/library/cpp/messagebus/rain_check/http/ya.make
@@ -8,10 +8,10 @@ SRCS(
)
PEERDIR(
- library/cpp/messagebus/rain_check/core
- library/cpp/neh
- library/cpp/http/misc
- library/cpp/http/io
+ library/cpp/messagebus/rain_check/core
+ library/cpp/neh
+ library/cpp/http/misc
+ library/cpp/http/io
)
END()
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h
index 5439c0c9a3..0a291cdea6 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.h
@@ -1,8 +1,8 @@
#pragma once
-#include <library/cpp/messagebus/rain_check/core/task.h>
+#include <library/cpp/messagebus/rain_check/core/task.h>
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
namespace NRainCheck {
class TBusFuture: public TSubtaskCompletion {
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp
index 0ed2b6e8d0..1b3618558b 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp
@@ -2,10 +2,10 @@
#include "messagebus_client.h"
-#include <library/cpp/messagebus/rain_check/test/ut/test.h>
+#include <library/cpp/messagebus/rain_check/test/ut/test.h>
-#include <library/cpp/messagebus/test/helper/example.h>
-#include <library/cpp/messagebus/test/helper/object_count_check.h>
+#include <library/cpp/messagebus/test/helper/example.h>
+#include <library/cpp/messagebus/test/helper/object_count_check.h>
#include <util/generic/cast.h>
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_server.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_server.cpp
index bcc31eeb92..5d4b13d664 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_server.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_server.cpp
@@ -1,6 +1,6 @@
#include "messagebus_server.h"
-#include <library/cpp/messagebus/rain_check/core/spawn.h>
+#include <library/cpp/messagebus/rain_check/core/spawn.h>
using namespace NRainCheck;
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_server.h b/library/cpp/messagebus/rain_check/messagebus/messagebus_server.h
index f22b496f19..1334f05fe4 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_server.h
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_server.h
@@ -1,9 +1,9 @@
#pragma once
-#include <library/cpp/messagebus/rain_check/core/spawn.h>
-#include <library/cpp/messagebus/rain_check/core/task.h>
+#include <library/cpp/messagebus/rain_check/core/spawn.h>
+#include <library/cpp/messagebus/rain_check/core/task.h>
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
#include <util/system/yassert.h>
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp
index fcd23c4961..7c11399f1b 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp
@@ -2,9 +2,9 @@
#include "messagebus_server.h"
-#include <library/cpp/messagebus/rain_check/test/ut/test.h>
+#include <library/cpp/messagebus/rain_check/test/ut/test.h>
-#include <library/cpp/messagebus/test/helper/example.h>
+#include <library/cpp/messagebus/test/helper/example.h>
using namespace NBus;
using namespace NBus::NTest;
diff --git a/library/cpp/messagebus/rain_check/messagebus/ya.make b/library/cpp/messagebus/rain_check/messagebus/ya.make
index e5f7c016b1..defdac9a61 100644
--- a/library/cpp/messagebus/rain_check/messagebus/ya.make
+++ b/library/cpp/messagebus/rain_check/messagebus/ya.make
@@ -3,8 +3,8 @@ LIBRARY()
OWNER(g:messagebus)
PEERDIR(
- library/cpp/messagebus
- library/cpp/messagebus/rain_check/core
+ library/cpp/messagebus
+ library/cpp/messagebus/rain_check/core
)
SRCS(
diff --git a/library/cpp/messagebus/rain_check/test/helper/misc.h b/library/cpp/messagebus/rain_check/test/helper/misc.h
index 8800c05f6d..9150be4d2f 100644
--- a/library/cpp/messagebus/rain_check/test/helper/misc.h
+++ b/library/cpp/messagebus/rain_check/test/helper/misc.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/messagebus/rain_check/core/rain_check.h>
+#include <library/cpp/messagebus/rain_check/core/rain_check.h>
#include <array>
diff --git a/library/cpp/messagebus/rain_check/test/helper/ya.make b/library/cpp/messagebus/rain_check/test/helper/ya.make
index a5dc1e9b6c..aa9e4e6d81 100644
--- a/library/cpp/messagebus/rain_check/test/helper/ya.make
+++ b/library/cpp/messagebus/rain_check/test/helper/ya.make
@@ -3,7 +3,7 @@ LIBRARY(messagebus-rain_check-test-helper)
OWNER(g:messagebus)
PEERDIR(
- library/cpp/messagebus/rain_check/core
+ library/cpp/messagebus/rain_check/core
)
SRCS(
diff --git a/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp b/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp
index 14107a407b..22edbd8c6b 100644
--- a/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/rain_check/test/perftest/perftest.cpp
@@ -1,6 +1,6 @@
-#include <library/cpp/messagebus/rain_check/test/helper/misc.h>
+#include <library/cpp/messagebus/rain_check/test/helper/misc.h>
-#include <library/cpp/messagebus/rain_check/core/rain_check.h>
+#include <library/cpp/messagebus/rain_check/core/rain_check.h>
#include <util/datetime/base.h>
diff --git a/library/cpp/messagebus/rain_check/test/perftest/ya.make b/library/cpp/messagebus/rain_check/test/perftest/ya.make
index 04684be5d2..7330a71700 100644
--- a/library/cpp/messagebus/rain_check/test/perftest/ya.make
+++ b/library/cpp/messagebus/rain_check/test/perftest/ya.make
@@ -3,8 +3,8 @@ PROGRAM(messagebus_rain_check_perftest)
OWNER(g:messagebus)
PEERDIR(
- library/cpp/messagebus/rain_check/core
- library/cpp/messagebus/rain_check/test/helper
+ library/cpp/messagebus/rain_check/core
+ library/cpp/messagebus/rain_check/test/helper
)
SRCS(
diff --git a/library/cpp/messagebus/rain_check/test/ut/test.h b/library/cpp/messagebus/rain_check/test/ut/test.h
index 91e09d353a..724f6b7530 100644
--- a/library/cpp/messagebus/rain_check/test/ut/test.h
+++ b/library/cpp/messagebus/rain_check/test/ut/test.h
@@ -1,8 +1,8 @@
#pragma once
-#include <library/cpp/messagebus/rain_check/core/rain_check.h>
+#include <library/cpp/messagebus/rain_check/core/rain_check.h>
-#include <library/cpp/messagebus/misc/test_sync.h>
+#include <library/cpp/messagebus/misc/test_sync.h>
template <typename TSelf>
struct TTestEnvTemplate: public NRainCheck::TSimpleEnvTemplate<TSelf> {
diff --git a/library/cpp/messagebus/rain_check/test/ut/ya.make b/library/cpp/messagebus/rain_check/test/ut/ya.make
index 823b680749..9f7a93417a 100644
--- a/library/cpp/messagebus/rain_check/test/ut/ya.make
+++ b/library/cpp/messagebus/rain_check/test/ut/ya.make
@@ -4,10 +4,10 @@ OWNER(g:messagebus)
PEERDIR(
library/cpp/testing/unittest_main
- library/cpp/messagebus/rain_check/core
- library/cpp/messagebus/rain_check/http
- library/cpp/messagebus/rain_check/messagebus
- library/cpp/messagebus/test/helper
+ library/cpp/messagebus/rain_check/core
+ library/cpp/messagebus/rain_check/http
+ library/cpp/messagebus/rain_check/messagebus
+ library/cpp/messagebus/test/helper
)
SRCS(
diff --git a/library/cpp/messagebus/remote_client_connection.cpp b/library/cpp/messagebus/remote_client_connection.cpp
index 2113e294a7..8c7a6db3a8 100644
--- a/library/cpp/messagebus/remote_client_connection.cpp
+++ b/library/cpp/messagebus/remote_client_connection.cpp
@@ -4,8 +4,8 @@
#include "network.h"
#include "remote_client_session.h"
-#include <library/cpp/messagebus/actor/executor.h>
-#include <library/cpp/messagebus/actor/temp_tls_vector.h>
+#include <library/cpp/messagebus/actor/executor.h>
+#include <library/cpp/messagebus/actor/temp_tls_vector.h>
#include <util/generic/cast.h>
#include <util/thread/singleton.h>
diff --git a/library/cpp/messagebus/remote_client_session.cpp b/library/cpp/messagebus/remote_client_session.cpp
index 89bffae8f8..3bc421944f 100644
--- a/library/cpp/messagebus/remote_client_session.cpp
+++ b/library/cpp/messagebus/remote_client_session.cpp
@@ -3,7 +3,7 @@
#include "mb_lwtrace.h"
#include "remote_client_connection.h"
-#include <library/cpp/messagebus/scheduler/scheduler.h>
+#include <library/cpp/messagebus/scheduler/scheduler.h>
#include <util/generic/cast.h>
#include <util/system/defaults.h>
diff --git a/library/cpp/messagebus/remote_connection.cpp b/library/cpp/messagebus/remote_connection.cpp
index f9db43291c..22932569db 100644
--- a/library/cpp/messagebus/remote_connection.cpp
+++ b/library/cpp/messagebus/remote_connection.cpp
@@ -8,7 +8,7 @@
#include "remote_server_session.h"
#include "session_impl.h"
-#include <library/cpp/messagebus/actor/what_thread_does.h>
+#include <library/cpp/messagebus/actor/what_thread_does.h>
#include <util/generic/cast.h>
#include <util/network/init.h>
diff --git a/library/cpp/messagebus/remote_connection.h b/library/cpp/messagebus/remote_connection.h
index 68783857d8..4538947368 100644
--- a/library/cpp/messagebus/remote_connection.h
+++ b/library/cpp/messagebus/remote_connection.h
@@ -16,11 +16,11 @@
#include "misc/granup.h"
#include "misc/tokenquota.h"
-#include <library/cpp/messagebus/actor/actor.h>
-#include <library/cpp/messagebus/actor/executor.h>
-#include <library/cpp/messagebus/actor/queue_for_actor.h>
-#include <library/cpp/messagebus/actor/queue_in_actor.h>
-#include <library/cpp/messagebus/scheduler/scheduler.h>
+#include <library/cpp/messagebus/actor/actor.h>
+#include <library/cpp/messagebus/actor/executor.h>
+#include <library/cpp/messagebus/actor/queue_for_actor.h>
+#include <library/cpp/messagebus/actor/queue_in_actor.h>
+#include <library/cpp/messagebus/scheduler/scheduler.h>
#include <util/system/atomic.h>
#include <util/system/event.h>
diff --git a/library/cpp/messagebus/remote_connection_status.cpp b/library/cpp/messagebus/remote_connection_status.cpp
index b87d532714..2c48b2a287 100644
--- a/library/cpp/messagebus/remote_connection_status.cpp
+++ b/library/cpp/messagebus/remote_connection_status.cpp
@@ -2,7 +2,7 @@
#include "key_value_printer.h"
-#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
+#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
#include <util/stream/format.h>
#include <util/stream/output.h>
diff --git a/library/cpp/messagebus/remote_connection_status.h b/library/cpp/messagebus/remote_connection_status.h
index ca55fc91de..5db10e51ea 100644
--- a/library/cpp/messagebus/remote_connection_status.h
+++ b/library/cpp/messagebus/remote_connection_status.h
@@ -7,9 +7,9 @@
#include "queue_config.h"
#include "session_config.h"
-#include <library/cpp/messagebus/actor/executor.h>
+#include <library/cpp/messagebus/actor/executor.h>
-#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
+#include <library/cpp/deprecated/enum_codegen/enum_codegen.h>
namespace NBus {
class TConnectionStatusMonRecord;
diff --git a/library/cpp/messagebus/remote_server_session.cpp b/library/cpp/messagebus/remote_server_session.cpp
index 947a9dbfaf..6abbf88a60 100644
--- a/library/cpp/messagebus/remote_server_session.cpp
+++ b/library/cpp/messagebus/remote_server_session.cpp
@@ -3,7 +3,7 @@
#include "remote_connection.h"
#include "remote_server_connection.h"
-#include <library/cpp/messagebus/actor/temp_tls_vector.h>
+#include <library/cpp/messagebus/actor/temp_tls_vector.h>
#include <util/generic/cast.h>
#include <util/stream/output.h>
diff --git a/library/cpp/messagebus/scheduler/scheduler_ut.cpp b/library/cpp/messagebus/scheduler/scheduler_ut.cpp
index f334b969d1..a5ea641c10 100644
--- a/library/cpp/messagebus/scheduler/scheduler_ut.cpp
+++ b/library/cpp/messagebus/scheduler/scheduler_ut.cpp
@@ -2,7 +2,7 @@
#include "scheduler.h"
-#include <library/cpp/messagebus/misc/test_sync.h>
+#include <library/cpp/messagebus/misc/test_sync.h>
using namespace NBus;
using namespace NBus::NPrivate;
diff --git a/library/cpp/messagebus/scheduler_actor.h b/library/cpp/messagebus/scheduler_actor.h
index d2a08c7c94..d0c23c94c4 100644
--- a/library/cpp/messagebus/scheduler_actor.h
+++ b/library/cpp/messagebus/scheduler_actor.h
@@ -2,9 +2,9 @@
#include "local_tasks.h"
-#include <library/cpp/messagebus/actor/actor.h>
-#include <library/cpp/messagebus/actor/what_thread_does_guard.h>
-#include <library/cpp/messagebus/scheduler/scheduler.h>
+#include <library/cpp/messagebus/actor/actor.h>
+#include <library/cpp/messagebus/actor/what_thread_does_guard.h>
+#include <library/cpp/messagebus/scheduler/scheduler.h>
#include <util/system/mutex.h>
diff --git a/library/cpp/messagebus/session.h b/library/cpp/messagebus/session.h
index d53daf8982..fb12ab7c22 100644
--- a/library/cpp/messagebus/session.h
+++ b/library/cpp/messagebus/session.h
@@ -9,7 +9,7 @@
#include "session_config.h"
#include "misc/weak_ptr.h"
-#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
+#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
#include <util/generic/array_ref.h>
#include <util/generic/ptr.h>
diff --git a/library/cpp/messagebus/session_config.h b/library/cpp/messagebus/session_config.h
index daf9442c38..37df97e986 100644
--- a/library/cpp/messagebus/session_config.h
+++ b/library/cpp/messagebus/session_config.h
@@ -1,4 +1,4 @@
#pragma once
-#include <library/cpp/messagebus/config/session_config.h>
+#include <library/cpp/messagebus/config/session_config.h>
diff --git a/library/cpp/messagebus/session_impl.h b/library/cpp/messagebus/session_impl.h
index a73b2921e5..90ef246ff8 100644
--- a/library/cpp/messagebus/session_impl.h
+++ b/library/cpp/messagebus/session_impl.h
@@ -10,9 +10,9 @@
#include "shutdown_state.h"
#include "ybus.h"
-#include <library/cpp/messagebus/actor/actor.h>
-#include <library/cpp/messagebus/actor/queue_in_actor.h>
-#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
+#include <library/cpp/messagebus/actor/actor.h>
+#include <library/cpp/messagebus/actor/queue_in_actor.h>
+#include <library/cpp/messagebus/monitoring/mon_proto.pb.h>
#include <library/cpp/threading/future/legacy_future.h>
diff --git a/library/cpp/messagebus/test/example/client/client.cpp b/library/cpp/messagebus/test/example/client/client.cpp
index 6e84556d70..89b5f2c9be 100644
--- a/library/cpp/messagebus/test/example/client/client.cpp
+++ b/library/cpp/messagebus/test/example/client/client.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/messagebus/test/example/common/proto.h>
+#include <library/cpp/messagebus/test/example/common/proto.h>
#include <util/random/random.h>
diff --git a/library/cpp/messagebus/test/example/client/ya.make b/library/cpp/messagebus/test/example/client/ya.make
index 05c3d6ca5f..a660a01698 100644
--- a/library/cpp/messagebus/test/example/client/ya.make
+++ b/library/cpp/messagebus/test/example/client/ya.make
@@ -3,7 +3,7 @@ PROGRAM(messagebus_example_client)
OWNER(g:messagebus)
PEERDIR(
- library/cpp/messagebus/test/example/common
+ library/cpp/messagebus/test/example/common
)
SRCS(
diff --git a/library/cpp/messagebus/test/example/common/proto.h b/library/cpp/messagebus/test/example/common/proto.h
index 8716869e30..a151aac468 100644
--- a/library/cpp/messagebus/test/example/common/proto.h
+++ b/library/cpp/messagebus/test/example/common/proto.h
@@ -1,9 +1,9 @@
#pragma once
-#include <library/cpp/messagebus/test/example/common/messages.pb.h>
+#include <library/cpp/messagebus/test/example/common/messages.pb.h>
-#include <library/cpp/messagebus/ybus.h>
-#include <library/cpp/messagebus/protobuf/ybusbuf.h>
+#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/protobuf/ybusbuf.h>
namespace NCalculator {
typedef ::NBus::TBusBufferMessage<TRequestSumRecord, 1> TRequestSum;
diff --git a/library/cpp/messagebus/test/example/common/ya.make b/library/cpp/messagebus/test/example/common/ya.make
index c4f09a5470..4da16608fc 100644
--- a/library/cpp/messagebus/test/example/common/ya.make
+++ b/library/cpp/messagebus/test/example/common/ya.make
@@ -3,8 +3,8 @@ LIBRARY(messagebus_test_example_common)
OWNER(g:messagebus)
PEERDIR(
- library/cpp/messagebus
- library/cpp/messagebus/protobuf
+ library/cpp/messagebus
+ library/cpp/messagebus/protobuf
)
SRCS(
diff --git a/library/cpp/messagebus/test/example/server/server.cpp b/library/cpp/messagebus/test/example/server/server.cpp
index 8bbf2a2605..13e52d75f5 100644
--- a/library/cpp/messagebus/test/example/server/server.cpp
+++ b/library/cpp/messagebus/test/example/server/server.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/messagebus/test/example/common/proto.h>
+#include <library/cpp/messagebus/test/example/common/proto.h>
using namespace NBus;
using namespace NCalculator;
diff --git a/library/cpp/messagebus/test/example/server/ya.make b/library/cpp/messagebus/test/example/server/ya.make
index c5e96c9191..8cdd97cb12 100644
--- a/library/cpp/messagebus/test/example/server/ya.make
+++ b/library/cpp/messagebus/test/example/server/ya.make
@@ -3,7 +3,7 @@ PROGRAM(messagebus_example_server)
OWNER(g:messagebus)
PEERDIR(
- library/cpp/messagebus/test/example/common
+ library/cpp/messagebus/test/example/common
)
SRCS(
diff --git a/library/cpp/messagebus/test/helper/example.h b/library/cpp/messagebus/test/helper/example.h
index 402b39e652..26b7475308 100644
--- a/library/cpp/messagebus/test/helper/example.h
+++ b/library/cpp/messagebus/test/helper/example.h
@@ -5,8 +5,8 @@
#include "alloc_counter.h"
#include "message_handler_error.h"
-#include <library/cpp/messagebus/ybus.h>
-#include <library/cpp/messagebus/misc/test_sync.h>
+#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/misc/test_sync.h>
#include <util/system/event.h>
diff --git a/library/cpp/messagebus/test/helper/example_module.h b/library/cpp/messagebus/test/helper/example_module.h
index 6389224028..a0b295f613 100644
--- a/library/cpp/messagebus/test/helper/example_module.h
+++ b/library/cpp/messagebus/test/helper/example_module.h
@@ -2,7 +2,7 @@
#include "example.h"
-#include <library/cpp/messagebus/oldmodule/module.h>
+#include <library/cpp/messagebus/oldmodule/module.h>
namespace NBus {
namespace NTest {
diff --git a/library/cpp/messagebus/test/helper/hanging_server.h b/library/cpp/messagebus/test/helper/hanging_server.h
index 1816198fe9..cc9fb274d8 100644
--- a/library/cpp/messagebus/test/helper/hanging_server.h
+++ b/library/cpp/messagebus/test/helper/hanging_server.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/messagebus/network.h>
+#include <library/cpp/messagebus/network.h>
#include <util/network/sock.h>
diff --git a/library/cpp/messagebus/test/helper/message_handler_error.h b/library/cpp/messagebus/test/helper/message_handler_error.h
index 1cfbd18d70..a314b10761 100644
--- a/library/cpp/messagebus/test/helper/message_handler_error.h
+++ b/library/cpp/messagebus/test/helper/message_handler_error.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
namespace NBus {
namespace NTest {
diff --git a/library/cpp/messagebus/test/helper/object_count_check.h b/library/cpp/messagebus/test/helper/object_count_check.h
index edcfe6c312..1c4756e58c 100644
--- a/library/cpp/messagebus/test/helper/object_count_check.h
+++ b/library/cpp/messagebus/test/helper/object_count_check.h
@@ -2,13 +2,13 @@
#include <library/cpp/testing/unittest/registar.h>
-#include <library/cpp/messagebus/remote_client_connection.h>
-#include <library/cpp/messagebus/remote_client_session.h>
-#include <library/cpp/messagebus/remote_server_connection.h>
-#include <library/cpp/messagebus/remote_server_session.h>
-#include <library/cpp/messagebus/ybus.h>
-#include <library/cpp/messagebus/oldmodule/module.h>
-#include <library/cpp/messagebus/scheduler/scheduler.h>
+#include <library/cpp/messagebus/remote_client_connection.h>
+#include <library/cpp/messagebus/remote_client_session.h>
+#include <library/cpp/messagebus/remote_server_connection.h>
+#include <library/cpp/messagebus/remote_server_session.h>
+#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/oldmodule/module.h>
+#include <library/cpp/messagebus/scheduler/scheduler.h>
#include <util/generic/object_counter.h>
#include <util/system/type_name.h>
diff --git a/library/cpp/messagebus/test/helper/ya.make b/library/cpp/messagebus/test/helper/ya.make
index 567b6ded15..97bd45f573 100644
--- a/library/cpp/messagebus/test/helper/ya.make
+++ b/library/cpp/messagebus/test/helper/ya.make
@@ -11,7 +11,7 @@ SRCS(
)
PEERDIR(
- library/cpp/messagebus/oldmodule
+ library/cpp/messagebus/oldmodule
)
END()
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index d09d745496..8489319278 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/test/perftest/perftest.cpp
@@ -1,19 +1,19 @@
#include "simple_proto.h"
-#include <library/cpp/messagebus/test/perftest/messages.pb.h>
+#include <library/cpp/messagebus/test/perftest/messages.pb.h>
-#include <library/cpp/messagebus/text_utils.h>
-#include <library/cpp/messagebus/thread_extra.h>
-#include <library/cpp/messagebus/ybus.h>
-#include <library/cpp/messagebus/oldmodule/module.h>
-#include <library/cpp/messagebus/protobuf/ybusbuf.h>
-#include <library/cpp/messagebus/www/www.h>
+#include <library/cpp/messagebus/text_utils.h>
+#include <library/cpp/messagebus/thread_extra.h>
+#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/oldmodule/module.h>
+#include <library/cpp/messagebus/protobuf/ybusbuf.h>
+#include <library/cpp/messagebus/www/www.h>
-#include <library/cpp/deprecated/threadable/threadable.h>
-#include <library/cpp/execprofile/profile.h>
+#include <library/cpp/deprecated/threadable/threadable.h>
+#include <library/cpp/execprofile/profile.h>
#include <library/cpp/getopt/opt.h>
-#include <library/cpp/lwtrace/start.h>
-#include <library/cpp/sighandler/async_signals_handler.h>
+#include <library/cpp/lwtrace/start.h>
+#include <library/cpp/sighandler/async_signals_handler.h>
#include <library/cpp/threading/future/legacy_future.h>
#include <util/generic/ptr.h>
diff --git a/library/cpp/messagebus/test/perftest/simple_proto.h b/library/cpp/messagebus/test/perftest/simple_proto.h
index fc958061b7..4a0cc08db3 100644
--- a/library/cpp/messagebus/test/perftest/simple_proto.h
+++ b/library/cpp/messagebus/test/perftest/simple_proto.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/ybus.h>
struct TSimpleMessage: public NBus::TBusMessage {
ui32 Payload;
diff --git a/library/cpp/messagebus/test/perftest/stackcollect.diff b/library/cpp/messagebus/test/perftest/stackcollect.diff
index 0d1de3e973..658f0141b3 100644
--- a/library/cpp/messagebus/test/perftest/stackcollect.diff
+++ b/library/cpp/messagebus/test/perftest/stackcollect.diff
@@ -6,8 +6,8 @@ Index: test/perftest/CMakeLists.txt
OWNER(nga)
PEERDIR(
-- library/cpp/execprofile
+- library/cpp/execprofile
+ junk/davenger/stackcollect
- library/cpp/messagebus
- library/cpp/messagebus/protobuf
- library/cpp/sighandler
+ library/cpp/messagebus
+ library/cpp/messagebus/protobuf
+ library/cpp/sighandler
diff --git a/library/cpp/messagebus/test/perftest/ya.make b/library/cpp/messagebus/test/perftest/ya.make
index 929d4cf685..24c2848ed5 100644
--- a/library/cpp/messagebus/test/perftest/ya.make
+++ b/library/cpp/messagebus/test/perftest/ya.make
@@ -3,15 +3,15 @@ PROGRAM(messagebus_perftest)
OWNER(g:messagebus)
PEERDIR(
- library/cpp/deprecated/threadable
- library/cpp/execprofile
+ library/cpp/deprecated/threadable
+ library/cpp/execprofile
library/cpp/getopt
- library/cpp/lwtrace
- library/cpp/messagebus
- library/cpp/messagebus/oldmodule
- library/cpp/messagebus/protobuf
- library/cpp/messagebus/www
- library/cpp/sighandler
+ library/cpp/lwtrace
+ library/cpp/messagebus
+ library/cpp/messagebus/oldmodule
+ library/cpp/messagebus/protobuf
+ library/cpp/messagebus/www
+ library/cpp/sighandler
library/cpp/threading/future
)
diff --git a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
index e282b457eb..3fdd175d73 100644
--- a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
+++ b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
@@ -1,7 +1,7 @@
#include <library/cpp/testing/unittest/registar.h>
-#include <library/cpp/messagebus/test_utils.h>
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/test_utils.h>
+#include <library/cpp/messagebus/ybus.h>
class TLocatorRegisterUniqTest: public TTestBase {
UNIT_TEST_SUITE(TLocatorRegisterUniqTest);
diff --git a/library/cpp/messagebus/test/ut/messagebus_ut.cpp b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
index 980d2adc6c..040f9b7702 100644
--- a/library/cpp/messagebus/test/ut/messagebus_ut.cpp
+++ b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
@@ -1,12 +1,12 @@
#include <library/cpp/testing/unittest/registar.h>
-#include <library/cpp/messagebus/test/helper/example.h>
-#include <library/cpp/messagebus/test/helper/fixed_port.h>
-#include <library/cpp/messagebus/test/helper/hanging_server.h>
-#include <library/cpp/messagebus/test/helper/object_count_check.h>
-#include <library/cpp/messagebus/test/helper/wait_for.h>
+#include <library/cpp/messagebus/test/helper/example.h>
+#include <library/cpp/messagebus/test/helper/fixed_port.h>
+#include <library/cpp/messagebus/test/helper/hanging_server.h>
+#include <library/cpp/messagebus/test/helper/object_count_check.h>
+#include <library/cpp/messagebus/test/helper/wait_for.h>
-#include <library/cpp/messagebus/misc/test_sync.h>
+#include <library/cpp/messagebus/misc/test_sync.h>
#include <util/network/sock.h>
diff --git a/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp b/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp
index 23e7d41434..4083cf3b7b 100644
--- a/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp
+++ b/library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp
@@ -1,10 +1,10 @@
#include <library/cpp/testing/unittest/registar.h>
-#include <library/cpp/messagebus/test/helper/example.h>
-#include <library/cpp/messagebus/test/helper/message_handler_error.h>
+#include <library/cpp/messagebus/test/helper/example.h>
+#include <library/cpp/messagebus/test/helper/message_handler_error.h>
-#include <library/cpp/messagebus/misc/test_sync.h>
-#include <library/cpp/messagebus/oldmodule/module.h>
+#include <library/cpp/messagebus/misc/test_sync.h>
+#include <library/cpp/messagebus/oldmodule/module.h>
using namespace NBus;
using namespace NBus::NTest;
diff --git a/library/cpp/messagebus/test/ut/module_client_ut.cpp b/library/cpp/messagebus/test/ut/module_client_ut.cpp
index 0c2b78c27e..ebfe185cc6 100644
--- a/library/cpp/messagebus/test/ut/module_client_ut.cpp
+++ b/library/cpp/messagebus/test/ut/module_client_ut.cpp
@@ -3,13 +3,13 @@
#include "count_down_latch.h"
#include "moduletest.h"
-#include <library/cpp/messagebus/test/helper/example.h>
-#include <library/cpp/messagebus/test/helper/example_module.h>
-#include <library/cpp/messagebus/test/helper/object_count_check.h>
-#include <library/cpp/messagebus/test/helper/wait_for.h>
+#include <library/cpp/messagebus/test/helper/example.h>
+#include <library/cpp/messagebus/test/helper/example_module.h>
+#include <library/cpp/messagebus/test/helper/object_count_check.h>
+#include <library/cpp/messagebus/test/helper/wait_for.h>
-#include <library/cpp/messagebus/misc/test_sync.h>
-#include <library/cpp/messagebus/oldmodule/module.h>
+#include <library/cpp/messagebus/misc/test_sync.h>
+#include <library/cpp/messagebus/oldmodule/module.h>
#include <util/generic/cast.h>
#include <util/system/event.h>
diff --git a/library/cpp/messagebus/test/ut/module_server_ut.cpp b/library/cpp/messagebus/test/ut/module_server_ut.cpp
index 02e7e273a6..88fe1dd9b6 100644
--- a/library/cpp/messagebus/test/ut/module_server_ut.cpp
+++ b/library/cpp/messagebus/test/ut/module_server_ut.cpp
@@ -3,12 +3,12 @@
#include "count_down_latch.h"
#include "moduletest.h"
-#include <library/cpp/messagebus/test/helper/example.h>
-#include <library/cpp/messagebus/test/helper/example_module.h>
-#include <library/cpp/messagebus/test/helper/object_count_check.h>
-#include <library/cpp/messagebus/test/helper/wait_for.h>
+#include <library/cpp/messagebus/test/helper/example.h>
+#include <library/cpp/messagebus/test/helper/example_module.h>
+#include <library/cpp/messagebus/test/helper/object_count_check.h>
+#include <library/cpp/messagebus/test/helper/wait_for.h>
-#include <library/cpp/messagebus/oldmodule/module.h>
+#include <library/cpp/messagebus/oldmodule/module.h>
#include <util/generic/cast.h>
diff --git a/library/cpp/messagebus/test/ut/moduletest.h b/library/cpp/messagebus/test/ut/moduletest.h
index 192032e2f4..d5da72c0cb 100644
--- a/library/cpp/messagebus/test/ut/moduletest.h
+++ b/library/cpp/messagebus/test/ut/moduletest.h
@@ -4,12 +4,12 @@
/// \file
/// \brief Example of using local session for communication.
-#include <library/cpp/messagebus/test/helper/alloc_counter.h>
-#include <library/cpp/messagebus/test/helper/example.h>
-#include <library/cpp/messagebus/test/helper/message_handler_error.h>
+#include <library/cpp/messagebus/test/helper/alloc_counter.h>
+#include <library/cpp/messagebus/test/helper/example.h>
+#include <library/cpp/messagebus/test/helper/message_handler_error.h>
-#include <library/cpp/messagebus/ybus.h>
-#include <library/cpp/messagebus/oldmodule/module.h>
+#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/oldmodule/module.h>
namespace NBus {
namespace NTest {
diff --git a/library/cpp/messagebus/test/ut/one_way_ut.cpp b/library/cpp/messagebus/test/ut/one_way_ut.cpp
index a9b7e848b5..9c21227e2b 100644
--- a/library/cpp/messagebus/test/ut/one_way_ut.cpp
+++ b/library/cpp/messagebus/test/ut/one_way_ut.cpp
@@ -24,14 +24,14 @@
/// See example in NBus::NullServer::OnMessage().
/// Discard identity for reply message.
-#include <library/cpp/messagebus/test/helper/alloc_counter.h>
-#include <library/cpp/messagebus/test/helper/example.h>
-#include <library/cpp/messagebus/test/helper/hanging_server.h>
-#include <library/cpp/messagebus/test/helper/message_handler_error.h>
-#include <library/cpp/messagebus/test/helper/object_count_check.h>
-#include <library/cpp/messagebus/test/helper/wait_for.h>
-
-#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/test/helper/alloc_counter.h>
+#include <library/cpp/messagebus/test/helper/example.h>
+#include <library/cpp/messagebus/test/helper/hanging_server.h>
+#include <library/cpp/messagebus/test/helper/message_handler_error.h>
+#include <library/cpp/messagebus/test/helper/object_count_check.h>
+#include <library/cpp/messagebus/test/helper/wait_for.h>
+
+#include <library/cpp/messagebus/ybus.h>
using namespace std;
using namespace NBus;
diff --git a/library/cpp/messagebus/test/ut/starter_ut.cpp b/library/cpp/messagebus/test/ut/starter_ut.cpp
index 647f959d1e..dd4d3aaa5e 100644
--- a/library/cpp/messagebus/test/ut/starter_ut.cpp
+++ b/library/cpp/messagebus/test/ut/starter_ut.cpp
@@ -1,8 +1,8 @@
#include <library/cpp/testing/unittest/registar.h>
-#include <library/cpp/messagebus/test/helper/example_module.h>
-#include <library/cpp/messagebus/test/helper/object_count_check.h>
-#include <library/cpp/messagebus/test/helper/wait_for.h>
+#include <library/cpp/messagebus/test/helper/example_module.h>
+#include <library/cpp/messagebus/test/helper/object_count_check.h>
+#include <library/cpp/messagebus/test/helper/wait_for.h>
using namespace NBus;
using namespace NBus::NTest;
diff --git a/library/cpp/messagebus/test/ut/sync_client_ut.cpp b/library/cpp/messagebus/test/ut/sync_client_ut.cpp
index fc66955b1f..400128193f 100644
--- a/library/cpp/messagebus/test/ut/sync_client_ut.cpp
+++ b/library/cpp/messagebus/test/ut/sync_client_ut.cpp
@@ -1,5 +1,5 @@
-#include <library/cpp/messagebus/test/helper/example.h>
-#include <library/cpp/messagebus/test/helper/object_count_check.h>
+#include <library/cpp/messagebus/test/helper/example.h>
+#include <library/cpp/messagebus/test/helper/object_count_check.h>
namespace NBus {
namespace NTest {
diff --git a/library/cpp/messagebus/test/ut/ya.make b/library/cpp/messagebus/test/ut/ya.make
index 99e40a0924..fe1b4961d6 100644
--- a/library/cpp/messagebus/test/ut/ya.make
+++ b/library/cpp/messagebus/test/ut/ya.make
@@ -1,6 +1,6 @@
OWNER(g:messagebus)
-UNITTEST_FOR(library/cpp/messagebus)
+UNITTEST_FOR(library/cpp/messagebus)
TIMEOUT(1200)
@@ -15,9 +15,9 @@ FORK_SUBTESTS()
PEERDIR(
library/cpp/testing/unittest_main
- library/cpp/messagebus
- library/cpp/messagebus/test/helper
- library/cpp/messagebus/www
+ library/cpp/messagebus
+ library/cpp/messagebus/test/helper
+ library/cpp/messagebus/www
)
SRCS(
diff --git a/library/cpp/messagebus/thread_extra.h b/library/cpp/messagebus/thread_extra.h
index dc78121752..2c79741e88 100644
--- a/library/cpp/messagebus/thread_extra.h
+++ b/library/cpp/messagebus/thread_extra.h
@@ -1,3 +1,3 @@
#pragma once
-#include <library/cpp/messagebus/actor/thread_extra.h>
+#include <library/cpp/messagebus/actor/thread_extra.h>
diff --git a/library/cpp/messagebus/www/html_output.h b/library/cpp/messagebus/www/html_output.h
index f8563102b1..27e77adefa 100644
--- a/library/cpp/messagebus/www/html_output.h
+++ b/library/cpp/messagebus/www/html_output.h
@@ -4,7 +4,7 @@
#include <util/generic/string.h>
#include <util/stream/output.h>
-#include <library/cpp/html/pcdata/pcdata.h>
+#include <library/cpp/html/pcdata/pcdata.h>
#include <util/system/tls.h>
extern Y_POD_THREAD(IOutputStream*) HtmlOutputStreamPtr;
diff --git a/library/cpp/messagebus/www/www.cpp b/library/cpp/messagebus/www/www.cpp
index c86751f2a7..62ec241d85 100644
--- a/library/cpp/messagebus/www/www.cpp
+++ b/library/cpp/messagebus/www/www.cpp
@@ -3,15 +3,15 @@
#include "concat_strings.h"
#include "html_output.h"
-#include <library/cpp/messagebus/remote_connection_status.h>
+#include <library/cpp/messagebus/remote_connection_status.h>
#include <library/cpp/monlib/deprecated/json/writer.h>
-#include <library/cpp/archive/yarchive.h>
-#include <library/cpp/http/fetch/httpfsm.h>
-#include <library/cpp/http/fetch/httpheader.h>
-#include <library/cpp/http/server/http.h>
-#include <library/cpp/json/writer/json.h>
-#include <library/cpp/uri/http_url.h>
+#include <library/cpp/archive/yarchive.h>
+#include <library/cpp/http/fetch/httpfsm.h>
+#include <library/cpp/http/fetch/httpheader.h>
+#include <library/cpp/http/server/http.h>
+#include <library/cpp/json/writer/json.h>
+#include <library/cpp/uri/http_url.h>
#include <util/string/cast.h>
#include <util/string/printf.h>
diff --git a/library/cpp/messagebus/www/www.h b/library/cpp/messagebus/www/www.h
index 0e624786e4..6cd652b477 100644
--- a/library/cpp/messagebus/www/www.h
+++ b/library/cpp/messagebus/www/www.h
@@ -1,7 +1,7 @@
#pragma once
-#include <library/cpp/messagebus/ybus.h>
-#include <library/cpp/messagebus/oldmodule/module.h>
+#include <library/cpp/messagebus/ybus.h>
+#include <library/cpp/messagebus/oldmodule/module.h>
#include <util/generic/ptr.h>
#include <util/generic/string.h>
diff --git a/library/cpp/messagebus/www/ya.make b/library/cpp/messagebus/www/ya.make
index 9057ece4d8..972390cea3 100644
--- a/library/cpp/messagebus/www/ya.make
+++ b/library/cpp/messagebus/www/ya.make
@@ -14,16 +14,16 @@ ARCHIVE(
)
PEERDIR(
- library/cpp/archive
+ library/cpp/archive
library/cpp/cgiparam
- library/cpp/html/pcdata
- library/cpp/http/fetch
- library/cpp/http/server
- library/cpp/json/writer
- library/cpp/messagebus
- library/cpp/messagebus/oldmodule
+ library/cpp/html/pcdata
+ library/cpp/http/fetch
+ library/cpp/http/server
+ library/cpp/json/writer
+ library/cpp/messagebus
+ library/cpp/messagebus/oldmodule
library/cpp/monlib/deprecated/json
- library/cpp/uri
+ library/cpp/uri
)
END()
diff --git a/library/cpp/messagebus/ya.make b/library/cpp/messagebus/ya.make
index 9dd5e77297..e13cf06dea 100644
--- a/library/cpp/messagebus/ya.make
+++ b/library/cpp/messagebus/ya.make
@@ -53,14 +53,14 @@ SRCS(
PEERDIR(
contrib/libs/sparsehash
- library/cpp/codecs
- library/cpp/deprecated/enum_codegen
+ library/cpp/codecs
+ library/cpp/deprecated/enum_codegen
library/cpp/getopt/small
- library/cpp/lwtrace
- library/cpp/messagebus/actor
- library/cpp/messagebus/config
- library/cpp/messagebus/monitoring
- library/cpp/messagebus/scheduler
+ library/cpp/lwtrace
+ library/cpp/messagebus/actor
+ library/cpp/messagebus/config
+ library/cpp/messagebus/monitoring
+ library/cpp/messagebus/scheduler
library/cpp/string_utils/indent_text
library/cpp/threading/future
)
diff --git a/library/cpp/messagebus/ybus.h b/library/cpp/messagebus/ybus.h
index 810a0ec916..de21ad8521 100644
--- a/library/cpp/messagebus/ybus.h
+++ b/library/cpp/messagebus/ybus.h
@@ -18,10 +18,10 @@
#include "session_config.h"
#include "socket_addr.h"
-#include <library/cpp/messagebus/actor/executor.h>
-#include <library/cpp/messagebus/scheduler/scheduler.h>
+#include <library/cpp/messagebus/actor/executor.h>
+#include <library/cpp/messagebus/scheduler/scheduler.h>
-#include <library/cpp/codecs/codecs.h>
+#include <library/cpp/codecs/codecs.h>
#include <util/generic/array_ref.h>
#include <util/generic/buffer.h>