aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorIlnur Khuziev <ilnur.khuziev@yandex.ru>2022-02-10 16:46:13 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:13 +0300
commit736dcd8ca259457a136f2f9f9168c44643914323 (patch)
treeddd46a036d68bfa83aa11b892f31243ea6b068a1 /library/cpp/messagebus
parent9bf2fa2b060c9881d3135c2208c624a1dd546ecc (diff)
downloadydb-736dcd8ca259457a136f2f9f9168c44643914323.tar.gz
Restoring authorship annotation for Ilnur Khuziev <ilnur.khuziev@yandex.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/actor/actor_ut.cpp2
-rw-r--r--library/cpp/messagebus/actor/ring_buffer_ut.cpp2
-rw-r--r--library/cpp/messagebus/actor/tasks_ut.cpp2
-rw-r--r--library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp2
-rw-r--r--library/cpp/messagebus/async_result_ut.cpp2
-rw-r--r--library/cpp/messagebus/cc_semaphore_ut.cpp2
-rw-r--r--library/cpp/messagebus/config/session_config.h2
-rw-r--r--library/cpp/messagebus/config/ya.make2
-rw-r--r--library/cpp/messagebus/connection.h4
-rw-r--r--library/cpp/messagebus/coreconn_ut.cpp2
-rw-r--r--library/cpp/messagebus/debug_receiver/debug_receiver.cpp2
-rw-r--r--library/cpp/messagebus/debug_receiver/ya.make2
-rw-r--r--library/cpp/messagebus/duration_histogram_ut.cpp2
-rw-r--r--library/cpp/messagebus/latch_ut.cpp2
-rw-r--r--library/cpp/messagebus/lfqueue_batch_ut.cpp2
-rw-r--r--library/cpp/messagebus/local_flags_ut.cpp2
-rw-r--r--library/cpp/messagebus/memory_ut.cpp2
-rw-r--r--library/cpp/messagebus/message_status_counter_ut.cpp2
-rw-r--r--library/cpp/messagebus/misc/weak_ptr_ut.cpp2
-rw-r--r--library/cpp/messagebus/moved_ut.cpp2
-rw-r--r--library/cpp/messagebus/netaddr_ut.cpp2
-rw-r--r--library/cpp/messagebus/network_ut.cpp2
-rw-r--r--library/cpp/messagebus/nondestroying_holder_ut.cpp2
-rw-r--r--library/cpp/messagebus/queue_config.h2
-rw-r--r--library/cpp/messagebus/rain_check/core/coro_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/core/simple_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/core/sleep_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/core/spawn_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/core/track_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/http/client.cpp4
-rw-r--r--library/cpp/messagebus/rain_check/http/client_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp8
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp2
-rw-r--r--library/cpp/messagebus/rain_check/test/ut/ya.make2
-rw-r--r--library/cpp/messagebus/scheduler/scheduler.h2
-rw-r--r--library/cpp/messagebus/scheduler/scheduler_ut.cpp2
-rw-r--r--library/cpp/messagebus/scheduler/ya.make2
-rw-r--r--library/cpp/messagebus/scheduler_actor_ut.cpp2
-rw-r--r--library/cpp/messagebus/session.h6
-rw-r--r--library/cpp/messagebus/session_impl.h2
-rw-r--r--library/cpp/messagebus/socket_addr_ut.cpp2
-rw-r--r--library/cpp/messagebus/synchandler.cpp2
-rw-r--r--library/cpp/messagebus/test/helper/example.cpp2
-rw-r--r--library/cpp/messagebus/test/helper/example.h2
-rw-r--r--library/cpp/messagebus/test/helper/fixed_port.cpp4
-rw-r--r--library/cpp/messagebus/test/helper/object_count_check.h2
-rw-r--r--library/cpp/messagebus/test/perftest/perftest.cpp4
-rw-r--r--library/cpp/messagebus/test/perftest/ya.make4
-rw-r--r--library/cpp/messagebus/test/ut/locator_uniq_ut.cpp2
-rw-r--r--library/cpp/messagebus/test/ut/messagebus_ut.cpp4
-rw-r--r--library/cpp/messagebus/test/ut/module_client_one_way_ut.cpp2
-rw-r--r--library/cpp/messagebus/test/ut/module_client_ut.cpp2
-rw-r--r--library/cpp/messagebus/test/ut/module_server_ut.cpp2
-rw-r--r--library/cpp/messagebus/test/ut/starter_ut.cpp2
-rw-r--r--library/cpp/messagebus/test/ut/ya.make2
-rw-r--r--library/cpp/messagebus/text_utils.h2
-rw-r--r--library/cpp/messagebus/vector_swaps_ut.cpp2
-rw-r--r--library/cpp/messagebus/www/www.h2
-rw-r--r--library/cpp/messagebus/www/ya.make2
-rw-r--r--library/cpp/messagebus/ya.make6
61 files changed, 74 insertions, 74 deletions
diff --git a/library/cpp/messagebus/actor/actor_ut.cpp b/library/cpp/messagebus/actor/actor_ut.cpp
index b76ab55bfa..b74c8d4fcb 100644
--- a/library/cpp/messagebus/actor/actor_ut.cpp
+++ b/library/cpp/messagebus/actor/actor_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "actor.h"
#include "queue_in_actor.h"
diff --git a/library/cpp/messagebus/actor/ring_buffer_ut.cpp b/library/cpp/messagebus/actor/ring_buffer_ut.cpp
index bdb379b3a9..068023e8ab 100644
--- a/library/cpp/messagebus/actor/ring_buffer_ut.cpp
+++ b/library/cpp/messagebus/actor/ring_buffer_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "ring_buffer.h"
diff --git a/library/cpp/messagebus/actor/tasks_ut.cpp b/library/cpp/messagebus/actor/tasks_ut.cpp
index d80e8451a5..ddc97ee5ec 100644
--- a/library/cpp/messagebus/actor/tasks_ut.cpp
+++ b/library/cpp/messagebus/actor/tasks_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "tasks.h"
diff --git a/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp b/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp
index e4b218a7ca..82f1cf840e 100644
--- a/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp
+++ b/library/cpp/messagebus/actor/what_thread_does_guard_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "what_thread_does_guard.h"
diff --git a/library/cpp/messagebus/async_result_ut.cpp b/library/cpp/messagebus/async_result_ut.cpp
index 2e96492afd..919501915c 100644
--- a/library/cpp/messagebus/async_result_ut.cpp
+++ b/library/cpp/messagebus/async_result_ut.cpp
@@ -1,5 +1,5 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "async_result.h"
diff --git a/library/cpp/messagebus/cc_semaphore_ut.cpp b/library/cpp/messagebus/cc_semaphore_ut.cpp
index 206bb7c96a..9f2594b26a 100644
--- a/library/cpp/messagebus/cc_semaphore_ut.cpp
+++ b/library/cpp/messagebus/cc_semaphore_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "cc_semaphore.h"
diff --git a/library/cpp/messagebus/config/session_config.h b/library/cpp/messagebus/config/session_config.h
index 84753350a9..312d776e26 100644
--- a/library/cpp/messagebus/config/session_config.h
+++ b/library/cpp/messagebus/config/session_config.h
@@ -3,7 +3,7 @@
#include "codegen.h"
#include "defs.h"
-#include <library/cpp/getopt/last_getopt.h>
+#include <library/cpp/getopt/last_getopt.h>
#include <util/generic/string.h>
diff --git a/library/cpp/messagebus/config/ya.make b/library/cpp/messagebus/config/ya.make
index 20c7dfed19..0d3f599f02 100644
--- a/library/cpp/messagebus/config/ya.make
+++ b/library/cpp/messagebus/config/ya.make
@@ -3,7 +3,7 @@ LIBRARY()
OWNER(g:messagebus)
PEERDIR(
- library/cpp/getopt
+ library/cpp/getopt
library/cpp/deprecated/enum_codegen
)
diff --git a/library/cpp/messagebus/connection.h b/library/cpp/messagebus/connection.h
index b1df64ddc1..03436335fd 100644
--- a/library/cpp/messagebus/connection.h
+++ b/library/cpp/messagebus/connection.h
@@ -22,7 +22,7 @@ namespace NBus {
EMessageStatus SendMessageAutoPtr(const TAutoPtr<T>& mes, bool wait = false) {
EMessageStatus status = SendMessage(mes.Get(), wait);
if (status == MESSAGE_OK)
- Y_UNUSED(mes.Release());
+ Y_UNUSED(mes.Release());
return status;
}
@@ -31,7 +31,7 @@ namespace NBus {
EMessageStatus SendMessageOneWayAutoPtr(const TAutoPtr<T>& mes, bool wait = false) {
EMessageStatus status = SendMessageOneWay(mes.Get(), wait);
if (status == MESSAGE_OK)
- Y_UNUSED(mes.Release());
+ Y_UNUSED(mes.Release());
return status;
}
diff --git a/library/cpp/messagebus/coreconn_ut.cpp b/library/cpp/messagebus/coreconn_ut.cpp
index beb6850f26..d097c762fc 100644
--- a/library/cpp/messagebus/coreconn_ut.cpp
+++ b/library/cpp/messagebus/coreconn_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "coreconn.h"
diff --git a/library/cpp/messagebus/debug_receiver/debug_receiver.cpp b/library/cpp/messagebus/debug_receiver/debug_receiver.cpp
index 23b02d1003..4e2322fc5b 100644
--- a/library/cpp/messagebus/debug_receiver/debug_receiver.cpp
+++ b/library/cpp/messagebus/debug_receiver/debug_receiver.cpp
@@ -3,7 +3,7 @@
#include <library/cpp/messagebus/ybus.h>
-#include <library/cpp/getopt/last_getopt.h>
+#include <library/cpp/getopt/last_getopt.h>
#include <library/cpp/lwtrace/all.h>
using namespace NBus;
diff --git a/library/cpp/messagebus/debug_receiver/ya.make b/library/cpp/messagebus/debug_receiver/ya.make
index f1b14d35bb..8e84fdfc14 100644
--- a/library/cpp/messagebus/debug_receiver/ya.make
+++ b/library/cpp/messagebus/debug_receiver/ya.make
@@ -9,7 +9,7 @@ SRCS(
)
PEERDIR(
- library/cpp/getopt
+ library/cpp/getopt
library/cpp/lwtrace
library/cpp/messagebus
)
diff --git a/library/cpp/messagebus/duration_histogram_ut.cpp b/library/cpp/messagebus/duration_histogram_ut.cpp
index 01bcc095e9..7151dd1a91 100644
--- a/library/cpp/messagebus/duration_histogram_ut.cpp
+++ b/library/cpp/messagebus/duration_histogram_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "duration_histogram.h"
diff --git a/library/cpp/messagebus/latch_ut.cpp b/library/cpp/messagebus/latch_ut.cpp
index bfab04f527..350e56a245 100644
--- a/library/cpp/messagebus/latch_ut.cpp
+++ b/library/cpp/messagebus/latch_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "latch.h"
diff --git a/library/cpp/messagebus/lfqueue_batch_ut.cpp b/library/cpp/messagebus/lfqueue_batch_ut.cpp
index f80434c0d4..7fd7562216 100644
--- a/library/cpp/messagebus/lfqueue_batch_ut.cpp
+++ b/library/cpp/messagebus/lfqueue_batch_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "lfqueue_batch.h"
diff --git a/library/cpp/messagebus/local_flags_ut.cpp b/library/cpp/messagebus/local_flags_ut.cpp
index 189d73eb0f..e2d3d3a9c7 100644
--- a/library/cpp/messagebus/local_flags_ut.cpp
+++ b/library/cpp/messagebus/local_flags_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "local_flags.h"
diff --git a/library/cpp/messagebus/memory_ut.cpp b/library/cpp/messagebus/memory_ut.cpp
index 00654f28a1..34bf272379 100644
--- a/library/cpp/messagebus/memory_ut.cpp
+++ b/library/cpp/messagebus/memory_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "memory.h"
diff --git a/library/cpp/messagebus/message_status_counter_ut.cpp b/library/cpp/messagebus/message_status_counter_ut.cpp
index 9598651329..ff56972073 100644
--- a/library/cpp/messagebus/message_status_counter_ut.cpp
+++ b/library/cpp/messagebus/message_status_counter_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "message_status_counter.h"
diff --git a/library/cpp/messagebus/misc/weak_ptr_ut.cpp b/library/cpp/messagebus/misc/weak_ptr_ut.cpp
index 5a325278db..5b918eb086 100644
--- a/library/cpp/messagebus/misc/weak_ptr_ut.cpp
+++ b/library/cpp/messagebus/misc/weak_ptr_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "weak_ptr.h"
diff --git a/library/cpp/messagebus/moved_ut.cpp b/library/cpp/messagebus/moved_ut.cpp
index c1a07cce7e..63a67a7c77 100644
--- a/library/cpp/messagebus/moved_ut.cpp
+++ b/library/cpp/messagebus/moved_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "moved.h"
diff --git a/library/cpp/messagebus/netaddr_ut.cpp b/library/cpp/messagebus/netaddr_ut.cpp
index e5c68bf402..bfe5467ddb 100644
--- a/library/cpp/messagebus/netaddr_ut.cpp
+++ b/library/cpp/messagebus/netaddr_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "netaddr.h"
#include "test_utils.h"
diff --git a/library/cpp/messagebus/network_ut.cpp b/library/cpp/messagebus/network_ut.cpp
index f1798419db..3172fdf655 100644
--- a/library/cpp/messagebus/network_ut.cpp
+++ b/library/cpp/messagebus/network_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "network.h"
diff --git a/library/cpp/messagebus/nondestroying_holder_ut.cpp b/library/cpp/messagebus/nondestroying_holder_ut.cpp
index 208042a2ba..f165781fb8 100644
--- a/library/cpp/messagebus/nondestroying_holder_ut.cpp
+++ b/library/cpp/messagebus/nondestroying_holder_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "nondestroying_holder.h"
diff --git a/library/cpp/messagebus/queue_config.h b/library/cpp/messagebus/queue_config.h
index a9955f0c70..e442df1447 100644
--- a/library/cpp/messagebus/queue_config.h
+++ b/library/cpp/messagebus/queue_config.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/getopt/last_getopt.h>
+#include <library/cpp/getopt/last_getopt.h>
namespace NBus {
//////////////////////////////////////////////////////////////////
diff --git a/library/cpp/messagebus/rain_check/core/coro_ut.cpp b/library/cpp/messagebus/rain_check/core/coro_ut.cpp
index 61a33584a5..e39b197cbc 100644
--- a/library/cpp/messagebus/rain_check/core/coro_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/coro_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "coro.h"
#include "spawn.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..1baede3396 100644
--- a/library/cpp/messagebus/rain_check/core/simple_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/simple_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <library/cpp/messagebus/rain_check/test/ut/test.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..5703511bfa 100644
--- a/library/cpp/messagebus/rain_check/core/sleep_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/sleep_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <library/cpp/messagebus/rain_check/test/ut/test.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..8559d56d91 100644
--- a/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/spawn_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#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>
diff --git a/library/cpp/messagebus/rain_check/core/track_ut.cpp b/library/cpp/messagebus/rain_check/core/track_ut.cpp
index 05f7de1319..e73cc5ebc1 100644
--- a/library/cpp/messagebus/rain_check/core/track_ut.cpp
+++ b/library/cpp/messagebus/rain_check/core/track_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "track.h"
diff --git a/library/cpp/messagebus/rain_check/http/client.cpp b/library/cpp/messagebus/rain_check/http/client.cpp
index 5ef5ceeece..a8fbc8b820 100644
--- a/library/cpp/messagebus/rain_check/http/client.cpp
+++ b/library/cpp/messagebus/rain_check/http/client.cpp
@@ -79,7 +79,7 @@ namespace NRainCheck {
headers.OutTo(&headersText);
NNeh::NHttp::MakeFullRequest(msg, headersText.Str(), TString());
FullProtocol->ScheduleRequest(msg, callback.Get(), stat);
- Y_UNUSED(callback.Release());
+ Y_UNUSED(callback.Release());
} catch (const TNetworkResolutionError& err) {
future->SetFail(THttpFuture::CantResolveNameError, err.AsStrBuf());
} catch (const yexception& err) {
@@ -100,7 +100,7 @@ namespace NRainCheck {
GetProtocol->ScheduleRequest(NNeh::TMessage::FromString(request),
callback.Get(),
stat);
- Y_UNUSED(callback.Release());
+ Y_UNUSED(callback.Release());
} catch (const TNetworkResolutionError& err) {
future->SetFail(THttpFuture::CantResolveNameError, err.AsStrBuf());
} catch (const yexception& err) {
diff --git a/library/cpp/messagebus/rain_check/http/client_ut.cpp b/library/cpp/messagebus/rain_check/http/client_ut.cpp
index 1628114391..96fc8e213e 100644
--- a/library/cpp/messagebus/rain_check/http/client_ut.cpp
+++ b/library/cpp/messagebus/rain_check/http/client_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "client.h"
#include "http_code_extractor.h"
diff --git a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp
index daac8d9a99..bad491bf7c 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client.cpp
@@ -31,7 +31,7 @@ void TBusClientService::SendCommon(NBus::TBusMessage* message, const NBus::TNetA
void TBusClientService::ProcessResultCommon(NBus::TBusMessageAutoPtr message,
const NBus::TNetAddr&, TBusFuture* future,
NBus::EMessageStatus status) {
- Y_UNUSED(message.Release());
+ Y_UNUSED(message.Release());
if (status == NBus::MESSAGE_OK) {
return;
@@ -67,7 +67,7 @@ void TBusClientService::OnReply(
TAutoPtr<TBusMessage> response) {
TBusFuture* future = (TBusFuture*)request->Data;
Y_ASSERT(future->Request.Get() == request.Get());
- Y_UNUSED(request.Release());
+ Y_UNUSED(request.Release());
future->SetDoneAndSchedule(MESSAGE_OK, response);
}
@@ -75,7 +75,7 @@ void NRainCheck::TBusClientService::OnMessageSentOneWay(
TAutoPtr<NBus::TBusMessage> request) {
TBusFuture* future = (TBusFuture*)request->Data;
Y_ASSERT(future->Request.Get() == request.Get());
- Y_UNUSED(request.Release());
+ Y_UNUSED(request.Release());
future->SetDoneAndSchedule(MESSAGE_OK, nullptr);
}
@@ -87,7 +87,7 @@ void TBusClientService::OnError(
TBusFuture* future = (TBusFuture*)message->Data;
Y_ASSERT(future->Request.Get() == message.Get());
- Y_UNUSED(message.Release());
+ Y_UNUSED(message.Release());
future->SetDoneAndSchedule(status, nullptr);
}
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..3dbe762745 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_client_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "messagebus_client.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..0788571750 100644
--- a/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp
+++ b/library/cpp/messagebus/rain_check/messagebus/messagebus_server_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "messagebus_server.h"
diff --git a/library/cpp/messagebus/rain_check/test/ut/ya.make b/library/cpp/messagebus/rain_check/test/ut/ya.make
index 9f7a93417a..ba9a286b59 100644
--- a/library/cpp/messagebus/rain_check/test/ut/ya.make
+++ b/library/cpp/messagebus/rain_check/test/ut/ya.make
@@ -3,7 +3,7 @@ PROGRAM(library-messagebus-rain_check-test-ut)
OWNER(g:messagebus)
PEERDIR(
- library/cpp/testing/unittest_main
+ library/cpp/testing/unittest_main
library/cpp/messagebus/rain_check/core
library/cpp/messagebus/rain_check/http
library/cpp/messagebus/rain_check/messagebus
diff --git a/library/cpp/messagebus/scheduler/scheduler.h b/library/cpp/messagebus/scheduler/scheduler.h
index afcc0de55d..0c9ec71af8 100644
--- a/library/cpp/messagebus/scheduler/scheduler.h
+++ b/library/cpp/messagebus/scheduler/scheduler.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/threading/future/legacy_future.h>
+#include <library/cpp/threading/future/legacy_future.h>
#include <util/datetime/base.h>
#include <util/generic/object_counter.h>
diff --git a/library/cpp/messagebus/scheduler/scheduler_ut.cpp b/library/cpp/messagebus/scheduler/scheduler_ut.cpp
index a5ea641c10..f26e5b6280 100644
--- a/library/cpp/messagebus/scheduler/scheduler_ut.cpp
+++ b/library/cpp/messagebus/scheduler/scheduler_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "scheduler.h"
diff --git a/library/cpp/messagebus/scheduler/ya.make b/library/cpp/messagebus/scheduler/ya.make
index dcb7408a20..2f23896d13 100644
--- a/library/cpp/messagebus/scheduler/ya.make
+++ b/library/cpp/messagebus/scheduler/ya.make
@@ -3,7 +3,7 @@ LIBRARY()
OWNER(g:messagebus)
PEERDIR(
- library/cpp/threading/future
+ library/cpp/threading/future
)
SRCS(
diff --git a/library/cpp/messagebus/scheduler_actor_ut.cpp b/library/cpp/messagebus/scheduler_actor_ut.cpp
index e81ffd3186..c7ecd82967 100644
--- a/library/cpp/messagebus/scheduler_actor_ut.cpp
+++ b/library/cpp/messagebus/scheduler_actor_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "scheduler_actor.h"
#include "misc/test_sync.h"
diff --git a/library/cpp/messagebus/session.h b/library/cpp/messagebus/session.h
index fb12ab7c22..0e47ea1351 100644
--- a/library/cpp/messagebus/session.h
+++ b/library/cpp/messagebus/session.h
@@ -88,7 +88,7 @@ namespace NBus {
EMessageStatus SendMessageAutoPtr(const TAutoPtr<T>& mes, const TNetAddr* addr = nullptr, bool wait = false) {
EMessageStatus status = SendMessage(mes.Get(), addr, wait);
if (status == MESSAGE_OK)
- Y_UNUSED(mes.Release());
+ Y_UNUSED(mes.Release());
return status;
}
@@ -97,7 +97,7 @@ namespace NBus {
EMessageStatus SendMessageOneWayAutoPtr(const TAutoPtr<T>& mes, const TNetAddr* addr = nullptr, bool wait = false) {
EMessageStatus status = SendMessageOneWay(mes.Get(), addr, wait);
if (status == MESSAGE_OK)
- Y_UNUSED(mes.Release());
+ Y_UNUSED(mes.Release());
return status;
}
@@ -138,7 +138,7 @@ namespace NBus {
EMessageStatus SendReplyAutoPtr(TBusIdentity& ident, TAutoPtr<U>& resp) {
EMessageStatus status = SendReply(const_cast<const TBusIdentity&>(ident), resp.Get());
if (status == MESSAGE_OK) {
- Y_UNUSED(resp.Release());
+ Y_UNUSED(resp.Release());
}
return status;
}
diff --git a/library/cpp/messagebus/session_impl.h b/library/cpp/messagebus/session_impl.h
index 90ef246ff8..ba6a47cca8 100644
--- a/library/cpp/messagebus/session_impl.h
+++ b/library/cpp/messagebus/session_impl.h
@@ -14,7 +14,7 @@
#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>
+#include <library/cpp/threading/future/legacy_future.h>
#include <util/generic/array_ref.h>
#include <util/generic/string.h>
diff --git a/library/cpp/messagebus/socket_addr_ut.cpp b/library/cpp/messagebus/socket_addr_ut.cpp
index 783bb62a86..6f82f54ad3 100644
--- a/library/cpp/messagebus/socket_addr_ut.cpp
+++ b/library/cpp/messagebus/socket_addr_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "netaddr.h"
#include "socket_addr.h"
diff --git a/library/cpp/messagebus/synchandler.cpp b/library/cpp/messagebus/synchandler.cpp
index 8e891d66b3..09613fca06 100644
--- a/library/cpp/messagebus/synchandler.cpp
+++ b/library/cpp/messagebus/synchandler.cpp
@@ -194,5 +194,5 @@ TBusSyncClientSessionPtr TBusMessageQueue::CreateSyncSource(TBusProtocol* proto,
void TBusMessageQueue::Destroy(TBusSyncClientSessionPtr session) {
Destroy(session->Session.Get());
- Y_UNUSED(session->Session.Release());
+ Y_UNUSED(session->Session.Release());
}
diff --git a/library/cpp/messagebus/test/helper/example.cpp b/library/cpp/messagebus/test/helper/example.cpp
index 7c6d704042..957887ed3d 100644
--- a/library/cpp/messagebus/test/helper/example.cpp
+++ b/library/cpp/messagebus/test/helper/example.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "example.h"
diff --git a/library/cpp/messagebus/test/helper/example.h b/library/cpp/messagebus/test/helper/example.h
index 26b7475308..acd5615ddc 100644
--- a/library/cpp/messagebus/test/helper/example.h
+++ b/library/cpp/messagebus/test/helper/example.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "alloc_counter.h"
#include "message_handler_error.h"
diff --git a/library/cpp/messagebus/test/helper/fixed_port.cpp b/library/cpp/messagebus/test/helper/fixed_port.cpp
index 258da0d1a5..271fb1f868 100644
--- a/library/cpp/messagebus/test/helper/fixed_port.cpp
+++ b/library/cpp/messagebus/test/helper/fixed_port.cpp
@@ -1,10 +1,10 @@
#include "fixed_port.h"
-#include <util/system/env.h>
+#include <util/system/env.h>
#include <stdlib.h>
bool NBus::NTest::IsFixedPortTestAllowed() {
// TODO: report skipped tests to test
- return !GetEnv("MB_TESTS_SKIP_FIXED_PORT");
+ return !GetEnv("MB_TESTS_SKIP_FIXED_PORT");
}
diff --git a/library/cpp/messagebus/test/helper/object_count_check.h b/library/cpp/messagebus/test/helper/object_count_check.h
index 1c4756e58c..304f7575ee 100644
--- a/library/cpp/messagebus/test/helper/object_count_check.h
+++ b/library/cpp/messagebus/test/helper/object_count_check.h
@@ -1,6 +1,6 @@
#pragma once
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <library/cpp/messagebus/remote_client_connection.h>
#include <library/cpp/messagebus/remote_client_session.h>
diff --git a/library/cpp/messagebus/test/perftest/perftest.cpp b/library/cpp/messagebus/test/perftest/perftest.cpp
index 8489319278..befae8c2d0 100644
--- a/library/cpp/messagebus/test/perftest/perftest.cpp
+++ b/library/cpp/messagebus/test/perftest/perftest.cpp
@@ -11,10 +11,10 @@
#include <library/cpp/deprecated/threadable/threadable.h>
#include <library/cpp/execprofile/profile.h>
-#include <library/cpp/getopt/opt.h>
+#include <library/cpp/getopt/opt.h>
#include <library/cpp/lwtrace/start.h>
#include <library/cpp/sighandler/async_signals_handler.h>
-#include <library/cpp/threading/future/legacy_future.h>
+#include <library/cpp/threading/future/legacy_future.h>
#include <util/generic/ptr.h>
#include <util/generic/string.h>
diff --git a/library/cpp/messagebus/test/perftest/ya.make b/library/cpp/messagebus/test/perftest/ya.make
index 24c2848ed5..7cd3e59446 100644
--- a/library/cpp/messagebus/test/perftest/ya.make
+++ b/library/cpp/messagebus/test/perftest/ya.make
@@ -5,14 +5,14 @@ OWNER(g:messagebus)
PEERDIR(
library/cpp/deprecated/threadable
library/cpp/execprofile
- library/cpp/getopt
+ 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/threading/future
+ library/cpp/threading/future
)
SRCS(
diff --git a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
index 3fdd175d73..1e0cbe3432 100644
--- a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
+++ b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <library/cpp/messagebus/test_utils.h>
#include <library/cpp/messagebus/ybus.h>
diff --git a/library/cpp/messagebus/test/ut/messagebus_ut.cpp b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
index 040f9b7702..8de18eeccb 100644
--- a/library/cpp/messagebus/test/ut/messagebus_ut.cpp
+++ b/library/cpp/messagebus/test/ut/messagebus_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include <library/cpp/messagebus/test/helper/example.h>
#include <library/cpp/messagebus/test/helper/fixed_port.h>
@@ -733,7 +733,7 @@ Y_UNIT_TEST_SUITE(TMessageBusTests) {
// intentionally don't destroy the message
// we will try to resend it
- Y_UNUSED(message.Release());
+ Y_UNUSED(message.Release());
TestSync.CheckAndIncrement(1);
}
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..70981848ed 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,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#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>
diff --git a/library/cpp/messagebus/test/ut/module_client_ut.cpp b/library/cpp/messagebus/test/ut/module_client_ut.cpp
index ebfe185cc6..9b4157ef30 100644
--- a/library/cpp/messagebus/test/ut/module_client_ut.cpp
+++ b/library/cpp/messagebus/test/ut/module_client_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "count_down_latch.h"
#include "moduletest.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..97ac28ee6f 100644
--- a/library/cpp/messagebus/test/ut/module_server_ut.cpp
+++ b/library/cpp/messagebus/test/ut/module_server_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "count_down_latch.h"
#include "moduletest.h"
diff --git a/library/cpp/messagebus/test/ut/starter_ut.cpp b/library/cpp/messagebus/test/ut/starter_ut.cpp
index dd4d3aaa5e..ccb927ca5d 100644
--- a/library/cpp/messagebus/test/ut/starter_ut.cpp
+++ b/library/cpp/messagebus/test/ut/starter_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#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>
diff --git a/library/cpp/messagebus/test/ut/ya.make b/library/cpp/messagebus/test/ut/ya.make
index fe1b4961d6..a4539687f9 100644
--- a/library/cpp/messagebus/test/ut/ya.make
+++ b/library/cpp/messagebus/test/ut/ya.make
@@ -14,7 +14,7 @@ TAG(
FORK_SUBTESTS()
PEERDIR(
- library/cpp/testing/unittest_main
+ library/cpp/testing/unittest_main
library/cpp/messagebus
library/cpp/messagebus/test/helper
library/cpp/messagebus/www
diff --git a/library/cpp/messagebus/text_utils.h b/library/cpp/messagebus/text_utils.h
index c2dcad834c..5014e963fc 100644
--- a/library/cpp/messagebus/text_utils.h
+++ b/library/cpp/messagebus/text_utils.h
@@ -1,3 +1,3 @@
#pragma once
-#include <library/cpp/string_utils/indent_text/indent_text.h>
+#include <library/cpp/string_utils/indent_text/indent_text.h>
diff --git a/library/cpp/messagebus/vector_swaps_ut.cpp b/library/cpp/messagebus/vector_swaps_ut.cpp
index 693cc6857b..3d76f67963 100644
--- a/library/cpp/messagebus/vector_swaps_ut.cpp
+++ b/library/cpp/messagebus/vector_swaps_ut.cpp
@@ -1,4 +1,4 @@
-#include <library/cpp/testing/unittest/registar.h>
+#include <library/cpp/testing/unittest/registar.h>
#include "vector_swaps.h"
diff --git a/library/cpp/messagebus/www/www.h b/library/cpp/messagebus/www/www.h
index 6cd652b477..4168a617cf 100644
--- a/library/cpp/messagebus/www/www.h
+++ b/library/cpp/messagebus/www/www.h
@@ -5,7 +5,7 @@
#include <util/generic/ptr.h>
#include <util/generic/string.h>
-#include <library/cpp/cgiparam/cgiparam.h>
+#include <library/cpp/cgiparam/cgiparam.h>
namespace NBus {
class TBusWww: public TAtomicRefCount<TBusWww> {
diff --git a/library/cpp/messagebus/www/ya.make b/library/cpp/messagebus/www/ya.make
index 972390cea3..9c9f7c9c03 100644
--- a/library/cpp/messagebus/www/ya.make
+++ b/library/cpp/messagebus/www/ya.make
@@ -15,7 +15,7 @@ ARCHIVE(
PEERDIR(
library/cpp/archive
- library/cpp/cgiparam
+ library/cpp/cgiparam
library/cpp/html/pcdata
library/cpp/http/fetch
library/cpp/http/server
diff --git a/library/cpp/messagebus/ya.make b/library/cpp/messagebus/ya.make
index e13cf06dea..49d88353ea 100644
--- a/library/cpp/messagebus/ya.make
+++ b/library/cpp/messagebus/ya.make
@@ -55,14 +55,14 @@ PEERDIR(
contrib/libs/sparsehash
library/cpp/codecs
library/cpp/deprecated/enum_codegen
- library/cpp/getopt/small
+ 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/string_utils/indent_text
- library/cpp/threading/future
+ library/cpp/string_utils/indent_text
+ library/cpp/threading/future
)
END()