diff options
author | neksard <neksard@yandex-team.ru> | 2022-02-10 16:45:33 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:45:33 +0300 |
commit | 1d9c550e7c38e051d7961f576013a482003a70d9 (patch) | |
tree | b2cc84ee7850122e7ccf51d0ea21e4fa7e7a5685 /library/cpp/messagebus | |
parent | 8f7cf138264e0caa318144bf8a2c950e0b0a8593 (diff) | |
download | ydb-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.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/all/ya.make | 2 | ||||
-rw-r--r-- | library/cpp/messagebus/config/netaddr.cpp | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/config/session_config.h | 2 | ||||
-rw-r--r-- | library/cpp/messagebus/debug_receiver/debug_receiver.cpp | 6 | ||||
-rw-r--r-- | library/cpp/messagebus/protobuf/ya.make | 2 | ||||
-rw-r--r-- | library/cpp/messagebus/rain_check/core/coro.h | 12 | ||||
-rw-r--r-- | library/cpp/messagebus/rain_check/core/coro_stack.cpp | 2 | ||||
-rw-r--r-- | library/cpp/messagebus/rain_check/test/helper/ya.make | 6 | ||||
-rw-r--r-- | library/cpp/messagebus/rain_check/test/ya.make | 4 | ||||
-rw-r--r-- | library/cpp/messagebus/rain_check/ya.make | 8 | ||||
-rw-r--r-- | library/cpp/messagebus/scheduler/ya.make | 6 | ||||
-rw-r--r-- | library/cpp/messagebus/test/example/ya.make | 6 | ||||
-rw-r--r-- | library/cpp/messagebus/test/perftest/perftest.cpp | 28 | ||||
-rw-r--r-- | library/cpp/messagebus/test/ya.make | 6 | ||||
-rw-r--r-- | library/cpp/messagebus/ya.make | 68 |
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 |