aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorneksard <neksard@yandex-team.ru>2022-02-10 16:45:33 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:33 +0300
commit1d9c550e7c38e051d7961f576013a482003a70d9 (patch)
treeb2cc84ee7850122e7ccf51d0ea21e4fa7e7a5685 /library/cpp/messagebus
parent8f7cf138264e0caa318144bf8a2c950e0b0a8593 (diff)
downloadydb-1d9c550e7c38e051d7961f576013a482003a70d9.tar.gz
Restoring authorship annotation for <neksard@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/actor/thread_extra.cpp4
-rw-r--r--library/cpp/messagebus/all/ya.make2
-rw-r--r--library/cpp/messagebus/config/netaddr.cpp4
-rw-r--r--library/cpp/messagebus/config/session_config.h2
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver.cpp6
-rw-r--r--library/cpp/messagebus/protobuf/ya.make2
-rw-r--r--library/cpp/messagebus/rain_check/core/coro.h12
-rw-r--r--library/cpp/messagebus/rain_check/core/coro_stack.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/test/helper/ya.make6
-rw-r--r--library/cpp/messagebus/rain_check/test/ya.make4
-rw-r--r--library/cpp/messagebus/rain_check/ya.make8
-rw-r--r--library/cpp/messagebus/scheduler/ya.make6
-rw-r--r--library/cpp/messagebus/test/example/ya.make6
-rw-r--r--library/cpp/messagebus/test/perftest/perftest.cpp28
-rw-r--r--library/cpp/messagebus/test/ya.make6
-rw-r--r--library/cpp/messagebus/ya.make68
16 files changed, 83 insertions, 83 deletions
diff --git a/library/cpp/messagebus/actor/thread_extra.cpp b/library/cpp/messagebus/actor/thread_extra.cpp
index 010a89a11e..048480f255 100644
--- a/library/cpp/messagebus/actor/thread_extra.cpp
+++ b/library/cpp/messagebus/actor/thread_extra.cpp
@@ -6,7 +6,7 @@
#include <util/system/thread.h>
namespace {
-#ifdef _linux_
+#ifdef _linux_
TString GetExecName() {
TString execPath = GetExecPath();
size_t lastSlash = execPath.find_last_of('/');
@@ -16,7 +16,7 @@ namespace {
return execPath.substr(lastSlash + 1);
}
}
-#endif
+#endif
}
void SetCurrentThreadName(const char* name) {
diff --git a/library/cpp/messagebus/all/ya.make b/library/cpp/messagebus/all/ya.make
index 2ea3513439..ffa2dbfabc 100644
--- a/library/cpp/messagebus/all/ya.make
+++ b/library/cpp/messagebus/all/ya.make
@@ -1,6 +1,6 @@
OWNER(g:messagebus)
-RECURSE_ROOT_RELATIVE(
+RECURSE_ROOT_RELATIVE(
library/python/messagebus
library/cpp/messagebus/debug_receiver
library/cpp/messagebus/oldmodule
diff --git a/library/cpp/messagebus/config/netaddr.cpp b/library/cpp/messagebus/config/netaddr.cpp
index 15273007b4..962ac538e2 100644
--- a/library/cpp/messagebus/config/netaddr.cpp
+++ b/library/cpp/messagebus/config/netaddr.cpp
@@ -2,8 +2,8 @@
#include <util/network/address.h>
-#include <cstdlib>
-
+#include <cstdlib>
+
namespace NBus {
const char* ToCString(EIpVersion ipVersion) {
switch (ipVersion) {
diff --git a/library/cpp/messagebus/config/session_config.h b/library/cpp/messagebus/config/session_config.h
index 9ae0864bb9..84753350a9 100644
--- a/library/cpp/messagebus/config/session_config.h
+++ b/library/cpp/messagebus/config/session_config.h
@@ -1,6 +1,6 @@
#pragma once
-#include "codegen.h"
+#include "codegen.h"
#include "defs.h"
#include <library/cpp/getopt/last_getopt.h>
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver.cpp b/library/cpp/messagebus/debug_receiver/debug_receiver.cpp
index 819af76202..23b02d1003 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver.cpp
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver.cpp
@@ -1,8 +1,8 @@
-#include "debug_receiver_handler.h"
-#include "debug_receiver_proto.h"
+#include "debug_receiver_handler.h"
+#include "debug_receiver_proto.h"
#include <library/cpp/messagebus/ybus.h>
-
+
#include <library/cpp/getopt/last_getopt.h>
#include <library/cpp/lwtrace/all.h>
diff --git a/library/cpp/messagebus/protobuf/ya.make b/library/cpp/messagebus/protobuf/ya.make
index 276280182d..64ff240b51 100644
--- a/library/cpp/messagebus/protobuf/ya.make
+++ b/library/cpp/messagebus/protobuf/ya.make
@@ -7,7 +7,7 @@ SRCS(
)
PEERDIR(
- contrib/libs/protobuf
+ contrib/libs/protobuf
library/cpp/messagebus
library/cpp/messagebus/actor
)
diff --git a/library/cpp/messagebus/rain_check/core/coro.h b/library/cpp/messagebus/rain_check/core/coro.h
index fe48e90cba..95e2a30f9b 100644
--- a/library/cpp/messagebus/rain_check/core/coro.h
+++ b/library/cpp/messagebus/rain_check/core/coro.h
@@ -1,13 +1,13 @@
#pragma once
-#include "coro_stack.h"
-#include "task.h"
-
-#include <util/generic/ptr.h>
+#include "coro_stack.h"
+#include "task.h"
+
+#include <util/generic/ptr.h>
#include <util/memory/alloc.h>
#include <util/system/align.h>
-#include <util/system/context.h>
-#include <util/system/valgrind.h>
+#include <util/system/context.h>
+#include <util/system/valgrind.h>
namespace NRainCheck {
class ICoroTask;
diff --git a/library/cpp/messagebus/rain_check/core/coro_stack.cpp b/library/cpp/messagebus/rain_check/core/coro_stack.cpp
index df8f03e368..83b984ca6e 100644
--- a/library/cpp/messagebus/rain_check/core/coro_stack.cpp
+++ b/library/cpp/messagebus/rain_check/core/coro_stack.cpp
@@ -3,7 +3,7 @@
#include <util/generic/singleton.h>
#include <util/system/valgrind.h>
-#include <cstdlib>
+#include <cstdlib>
#include <stdio.h>
using namespace NRainCheck;
diff --git a/library/cpp/messagebus/rain_check/test/helper/ya.make b/library/cpp/messagebus/rain_check/test/helper/ya.make
index 9f8f377e29..aa9e4e6d81 100644
--- a/library/cpp/messagebus/rain_check/test/helper/ya.make
+++ b/library/cpp/messagebus/rain_check/test/helper/ya.make
@@ -2,10 +2,10 @@ LIBRARY(messagebus-rain_check-test-helper)
OWNER(g:messagebus)
-PEERDIR(
+PEERDIR(
library/cpp/messagebus/rain_check/core
-)
-
+)
+
SRCS(
misc.cpp
)
diff --git a/library/cpp/messagebus/rain_check/test/ya.make b/library/cpp/messagebus/rain_check/test/ya.make
index 9435237855..4c1d6f8161 100644
--- a/library/cpp/messagebus/rain_check/test/ya.make
+++ b/library/cpp/messagebus/rain_check/test/ya.make
@@ -1,6 +1,6 @@
OWNER(g:messagebus)
RECURSE(
- perftest
- ut
+ perftest
+ ut
)
diff --git a/library/cpp/messagebus/rain_check/ya.make b/library/cpp/messagebus/rain_check/ya.make
index 10cffa885b..966d54c232 100644
--- a/library/cpp/messagebus/rain_check/ya.make
+++ b/library/cpp/messagebus/rain_check/ya.make
@@ -1,8 +1,8 @@
OWNER(g:messagebus)
RECURSE(
- core
- http
- messagebus
- test
+ core
+ http
+ messagebus
+ test
)
diff --git a/library/cpp/messagebus/scheduler/ya.make b/library/cpp/messagebus/scheduler/ya.make
index eeeb170526..dcb7408a20 100644
--- a/library/cpp/messagebus/scheduler/ya.make
+++ b/library/cpp/messagebus/scheduler/ya.make
@@ -2,10 +2,10 @@ LIBRARY()
OWNER(g:messagebus)
-PEERDIR(
+PEERDIR(
library/cpp/threading/future
-)
-
+)
+
SRCS(
scheduler.cpp
)
diff --git a/library/cpp/messagebus/test/example/ya.make b/library/cpp/messagebus/test/example/ya.make
index 1b0d29a615..f275351c29 100644
--- a/library/cpp/messagebus/test/example/ya.make
+++ b/library/cpp/messagebus/test/example/ya.make
@@ -1,7 +1,7 @@
OWNER(g:messagebus)
RECURSE(
- client
- common
- server
+ client
+ common
+ server
)
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index d2dd0e408c..8489319278 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/test/perftest/perftest.cpp
@@ -1,4 +1,4 @@
-#include "simple_proto.h"
+#include "simple_proto.h"
#include <library/cpp/messagebus/test/perftest/messages.pb.h>
@@ -16,22 +16,22 @@
#include <library/cpp/sighandler/async_signals_handler.h>
#include <library/cpp/threading/future/legacy_future.h>
-#include <util/generic/ptr.h>
+#include <util/generic/ptr.h>
#include <util/generic/string.h>
#include <util/generic/vector.h>
-#include <util/generic/yexception.h>
+#include <util/generic/yexception.h>
#include <util/random/random.h>
-#include <util/stream/file.h>
-#include <util/stream/output.h>
-#include <util/stream/str.h>
-#include <util/string/split.h>
-#include <util/system/event.h>
-#include <util/system/sysstat.h>
-#include <util/system/thread.h>
-#include <util/thread/lfqueue.h>
-
-#include <signal.h>
-#include <stdlib.h>
+#include <util/stream/file.h>
+#include <util/stream/output.h>
+#include <util/stream/str.h>
+#include <util/string/split.h>
+#include <util/system/event.h>
+#include <util/system/sysstat.h>
+#include <util/system/thread.h>
+#include <util/thread/lfqueue.h>
+
+#include <signal.h>
+#include <stdlib.h>
using namespace NBus;
diff --git a/library/cpp/messagebus/test/ya.make b/library/cpp/messagebus/test/ya.make
index f178fe5edc..0dc4bd4720 100644
--- a/library/cpp/messagebus/test/ya.make
+++ b/library/cpp/messagebus/test/ya.make
@@ -1,7 +1,7 @@
OWNER(g:messagebus)
RECURSE(
- example
- perftest
- ut
+ example
+ perftest
+ ut
)
diff --git a/library/cpp/messagebus/ya.make b/library/cpp/messagebus/ya.make
index b9350e9055..e13cf06dea 100644
--- a/library/cpp/messagebus/ya.make
+++ b/library/cpp/messagebus/ya.make
@@ -7,52 +7,52 @@ IF (SANITIZER_TYPE == "undefined")
ENDIF()
SRCS(
- acceptor.cpp
- acceptor_status.cpp
+ acceptor.cpp
+ acceptor_status.cpp
connection.cpp
- coreconn.cpp
+ coreconn.cpp
duration_histogram.cpp
- event_loop.cpp
- futex_like.cpp
- handler.cpp
- key_value_printer.cpp
- local_flags.cpp
- locator.cpp
+ event_loop.cpp
+ futex_like.cpp
+ handler.cpp
+ key_value_printer.cpp
+ local_flags.cpp
+ locator.cpp
mb_lwtrace.cpp
- message.cpp
- message_counter.cpp
- message_status.cpp
- message_status_counter.cpp
- messqueue.cpp
+ message.cpp
+ message_counter.cpp
+ message_status.cpp
+ message_status_counter.cpp
+ messqueue.cpp
misc/atomic_box.h
misc/granup.h
misc/test_sync.h
misc/tokenquota.h
misc/weak_ptr.h
- network.cpp
- queue_config.cpp
- remote_client_connection.cpp
- remote_client_session.cpp
- remote_client_session_semaphore.cpp
- remote_connection.cpp
- remote_connection_status.cpp
- remote_server_connection.cpp
- remote_server_session.cpp
- remote_server_session_semaphore.cpp
- session.cpp
- session_impl.cpp
- session_job_count.cpp
- shutdown_state.cpp
+ network.cpp
+ queue_config.cpp
+ remote_client_connection.cpp
+ remote_client_session.cpp
+ remote_client_session_semaphore.cpp
+ remote_connection.cpp
+ remote_connection_status.cpp
+ remote_server_connection.cpp
+ remote_server_session.cpp
+ remote_server_session_semaphore.cpp
+ session.cpp
+ session_impl.cpp
+ session_job_count.cpp
+ shutdown_state.cpp
socket_addr.cpp
- storage.cpp
- synchandler.cpp
- use_after_free_checker.cpp
- use_count_checker.cpp
- ybus.h
+ storage.cpp
+ synchandler.cpp
+ use_after_free_checker.cpp
+ use_count_checker.cpp
+ ybus.h
)
PEERDIR(
- contrib/libs/sparsehash
+ contrib/libs/sparsehash
library/cpp/codecs
library/cpp/deprecated/enum_codegen
library/cpp/getopt/small