Restoring authorship annotation for <cerevra@yandex-team.ru>. Commit 1 of 2.

author: cerevra <cerevra@yandex-team.ru> 2022-02-10 16:45:58 +0300
committer: Daniil Cherednik <dcherednik@yandex-team.ru> 2022-02-10 16:45:58 +0300
commit: bf41dd01f6c920583e9faae7cd55ed25e547e052 (patch)
tree: ec7c8c285ffa648a5c5efeff453787a15ab811ac /library/cpp/messagebus
parent: e2c3e3004f7cd68441cefcfa4aaccd3d8051c846 (diff)
download: ydb-bf41dd01f6c920583e9faae7cd55ed25e547e052.tar.gz
103 files changed, 260 insertions, 260 deletions
diff --git a/library/cpp/messagebus/acceptor.h b/library/cpp/messagebus/acceptor.h
index 57cb010bf22..00c57882994 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 b76ab55bfa2..12f64ac2085 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 ffa2dbfabce..36d9b5adf3c 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 83e969e8117..d4ce217aa43 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 92b1df99698..3fe1f2a6d0f 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 20c7dfed198..91c555b920f 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 23b02d10033..bc1354246eb 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 0aed6b99849..3180743607a 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 d34710dcf73..f71ca3279c7 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 f1b14d35bb4..ce1ad265189 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 cb553acc454..bcf3faa32ae 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 8128d3154d0..986f82c4e43 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 f589283188f..b9e047de18a 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 c54cd5ab71c..f0929485a52 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 e62728b265c..ec817ea6266 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 e1878960b34..98273a5a5ca 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 891c8f5bb2b..d1446bdb95e 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 e8ba2fdd31d..94a0f3e8ac7 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 95986513296..5bdfeff5b03 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 f915c8c574b..af07a72ad07 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 f1798419db2..ebca2497f1a 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 24bd778799f..f5f559c8b11 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 8d1c4a5d52b..1f0f5621366 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 7c38801d626..b6c266d17df 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 5e26e7e1e56..6d041edcb8a 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 ca5eae74f09..e04a65f9e83 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 64ff240b519..e438d9f5b9d 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 63415b3737f..45bc9a1cce7 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 57b4267ea50..92b5e286b8b 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 61a33584a5f..bf7124e8710 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 f6dd7fceb62..b53fd59200b 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 d4545e05aa1..e25dfdf779d 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 1a7a1f86741..a39d1c43177 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 2ae85a87b18..fdc551d3331 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 ba5a5e41cf6..122f0570042 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 a098437d534..f9acf1e0f7f 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 7d8778bcda5..12b55d347cc 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 d387de75742..094bee15069 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 05f7de13195..7762e7770d3 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 c6fb5640d44..307ca2192d6 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 5ef5ceeece2..22deca38273 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 d4199c4c98d..d16b1db3047 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 16281143911..7a0d57e64c4 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 51d75762f68..71e70d454e3 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 33b565fa1c1..727ebcbd612 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 ef13329df3e..59f7b3b2f2d 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 0a291cdea69..5439c0c9a32 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 1b3618558b8..0ed2b6e8d0e 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 5d4b13d6647..bcc31eeb923 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 1334f05fe46..f22b496f190 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 7c11399f1be..fcd23c4961d 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 defdac9a614..e5f7c016b11 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 9150be4d2f3..8800c05f6dc 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 aa9e4e6d811..a5dc1e9b6c7 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 22edbd8c6ba..14107a407b5 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 7330a71700f..04684be5d27 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 724f6b7530f..91e09d353a5 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 9f7a93417a0..823b6807495 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 8c7a6db3a8c..2113e294a78 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 3bc421944f9..89bffae8f80 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 22932569dbd..f9db43291cb 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 45389473685..68783857d87 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 2c48b2a287c..b87d5327147 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 5db10e51eae..ca55fc91def 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 6abbf88a606..947a9dbfaf9 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 a5ea641c108..f334b969d16 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 d0c23c94c4e..d2a08c7c946 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 fb12ab7c229..d53daf89823 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 37df97e9864..daf9442c389 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 90ef246ff81..a73b2921e5a 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 89b5f2c9beb..6e84556d70f 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 a660a016982..05c3d6ca5fc 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 a151aac4689..8716869e308 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 4da16608fc6..c4f09a54708 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 13e52d75f58..8bbf2a26051 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 8cdd97cb129..c5e96c91917 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 26b74753088..402b39e6526 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 a0b295f6139..6389224028e 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 cc9fb274d8a..1816198fe97 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 a314b107617..1cfbd18d704 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 1c4756e58c1..edcfe6c312e 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 97bd45f5738..567b6ded157 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 84893192789..d09d7454963 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 4a0cc08db3f..fc958061b70 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 658f0141b3d..0d1de3e9731 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 24c2848ed52..929d4cf685e 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 3fdd175d736..e282b457eb0 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 040f9b77022..980d2adc6cf 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 4083cf3b7b7..23e7d41434d 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 ebfe185cc6d..0c2b78c27e5 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 88fe1dd9b6d..02e7e273a68 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 d5da72c0cbf..192032e2f4b 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 9c21227e2bd..a9b7e848b5a 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 dd4d3aaa5e3..647f959d1ea 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 400128193f9..fc66955b1f1 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 fe1b4961d69..99e40a0924d 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 2c79741e889..dc78121752a 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 27e77adefa7..f8563102b13 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 62ec241d852..c86751f2a73 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 6cd652b4774..0e624786e49 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 972390cea3f..9057ece4d8f 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 e13cf06deaf..9dd5e772974 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 de21ad85216..810a0ec9167 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>
author	cerevra <cerevra@yandex-team.ru>	2022-02-10 16:45:58 +0300
committer	Daniil Cherednik <dcherednik@yandex-team.ru>	2022-02-10 16:45:58 +0300
commit	bf41dd01f6c920583e9faae7cd55ed25e547e052 (patch)
tree	ec7c8c285ffa648a5c5efeff453787a15ab811ac /library/cpp/messagebus
parent	e2c3e3004f7cd68441cefcfa4aaccd3d8051c846 (diff)
download	ydb-bf41dd01f6c920583e9faae7cd55ed25e547e052.tar.gz