aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorcerevra <cerevra@yandex-team.ru>2022-02-10 16:45:58 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:58 +0300
commitbf41dd01f6c920583e9faae7cd55ed25e547e052 (patch)
treeec7c8c285ffa648a5c5efeff453787a15ab811ac /library/cpp/messagebus
parente2c3e3004f7cd68441cefcfa4aaccd3d8051c846 (diff)
downloadydb-bf41dd01f6c920583e9faae7cd55ed25e547e052.tar.gz
Restoring authorship annotation for <cerevra@yandex-team.ru>. Commit 1 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 57cb010bf2..00c5788299 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 b76ab55bfa..12f64ac208 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 ffa2dbfabc..36d9b5adf3 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 83e969e811..d4ce217aa4 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 92b1df9969..3fe1f2a6d0 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 20c7dfed19..91c555b920 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 23b02d1003..bc1354246e 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 0aed6b9984..3180743607 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 d34710dcf7..f71ca3279c 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 f1b14d35bb..ce1ad26518 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 cb553acc45..bcf3faa32a 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 8128d3154d..986f82c4e4 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 f589283188..b9e047de18 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 c54cd5ab71..f0929485a5 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 e62728b265..ec817ea626 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 e1878960b3..98273a5a5c 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 891c8f5bb2..d1446bdb95 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 e8ba2fdd31..94a0f3e8ac 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 9598651329..5bdfeff5b0 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 f915c8c574..af07a72ad0 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 f1798419db..ebca2497f1 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 24bd778799..f5f559c8b1 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 8d1c4a5d52..1f0f562136 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 7c38801d62..b6c266d17d 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 5e26e7e1e5..6d041edcb8 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 ca5eae74f0..e04a65f9e8 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 64ff240b51..e438d9f5b9 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 63415b3737..45bc9a1cce 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 57b4267ea5..92b5e286b8 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 61a33584a5..bf7124e871 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 f6dd7fceb6..b53fd59200 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 d4545e05aa..e25dfdf779 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 1a7a1f8674..a39d1c4317 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 2ae85a87b1..fdc551d333 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 ba5a5e41cf..122f057004 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 a098437d53..f9acf1e0f7 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 7d8778bcda..12b55d347c 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 d387de7574..094bee1506 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 05f7de1319..7762e7770d 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 c6fb5640d4..307ca2192d 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 5ef5ceeece..22deca3827 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 d4199c4c98..d16b1db304 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 1628114391..7a0d57e64c 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 51d75762f6..71e70d454e 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 33b565fa1c..727ebcbd61 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 ef13329df3..59f7b3b2f2 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 0a291cdea6..5439c0c9a3 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 1b3618558b..0ed2b6e8d0 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 5d4b13d664..bcc31eeb92 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 1334f05fe4..f22b496f19 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 7c11399f1b..fcd23c4961 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 defdac9a61..e5f7c016b1 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 9150be4d2f..8800c05f6d 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 aa9e4e6d81..a5dc1e9b6c 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 22edbd8c6b..14107a407b 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 7330a71700..04684be5d2 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 724f6b7530..91e09d353a 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 9f7a93417a..823b680749 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 8c7a6db3a8..2113e294a7 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 3bc421944f..89bffae8f8 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 22932569db..f9db43291c 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 4538947368..68783857d8 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 2c48b2a287..b87d532714 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 5db10e51ea..ca55fc91de 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 6abbf88a60..947a9dbfaf 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 a5ea641c10..f334b969d1 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 d0c23c94c4..d2a08c7c94 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 fb12ab7c22..d53daf8982 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 37df97e986..daf9442c38 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 90ef246ff8..a73b2921e5 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 89b5f2c9be..6e84556d70 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 a660a01698..05c3d6ca5f 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 a151aac468..8716869e30 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 4da16608fc..c4f09a5470 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 13e52d75f5..8bbf2a2605 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 8cdd97cb12..c5e96c9191 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 26b7475308..402b39e652 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 a0b295f613..6389224028 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 cc9fb274d8..1816198fe9 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 a314b10761..1cfbd18d70 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 1c4756e58c..edcfe6c312 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 97bd45f573..567b6ded15 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 8489319278..d09d745496 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 4a0cc08db3..fc958061b7 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 658f0141b3..0d1de3e973 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 24c2848ed5..929d4cf685 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 3fdd175d73..e282b457eb 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 040f9b7702..980d2adc6c 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 4083cf3b7b..23e7d41434 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 ebfe185cc6..0c2b78c27e 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 88fe1dd9b6..02e7e273a6 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 d5da72c0cb..192032e2f4 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 9c21227e2b..a9b7e848b5 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 dd4d3aaa5e..647f959d1e 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 400128193f..fc66955b1f 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 fe1b4961d6..99e40a0924 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 2c79741e88..dc78121752 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 27e77adefa..f8563102b1 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 62ec241d85..c86751f2a7 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 6cd652b477..0e624786e4 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 972390cea3..9057ece4d8 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 e13cf06dea..9dd5e77297 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 de21ad8521..810a0ec916 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>