aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorIlnur Khuziev <ilnur.khuziev@yandex.ru>2022-02-10 16:46:14 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:14 +0300
commit60040c91ffe701a84689b2c6310ff845e65cff42 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/messagebus
parent736dcd8ca259457a136f2f9f9168c44643914323 (diff)
downloadydb-60040c91ffe701a84689b2c6310ff845e65cff42.tar.gz
Restoring authorship annotation for Ilnur Khuziev <ilnur.khuziev@yandex.ru>. Commit 2 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 b74c8d4fcb..b76ab55bfa 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 068023e8ab..bdb379b3a9 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 ddc97ee5ec..d80e8451a5 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 82f1cf840e..e4b218a7ca 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 919501915c..2e96492afd 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 9f2594b26a..206bb7c96a 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 312d776e26..84753350a9 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 0d3f599f02..20c7dfed19 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 03436335fd..b1df64ddc1 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 d097c762fc..beb6850f26 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 4e2322fc5b..23b02d1003 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 8e84fdfc14..f1b14d35bb 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 7151dd1a91..01bcc095e9 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 350e56a245..bfab04f527 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 7fd7562216..f80434c0d4 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 e2d3d3a9c7..189d73eb0f 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 34bf272379..00654f28a1 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 ff56972073..9598651329 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 5b918eb086..5a325278db 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 63a67a7c77..c1a07cce7e 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 bfe5467ddb..e5c68bf402 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 3172fdf655..f1798419db 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 f165781fb8..208042a2ba 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 e442df1447..a9955f0c70 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 e39b197cbc..61a33584a5 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 1baede3396..d4545e05aa 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 5703511bfa..2ae85a87b1 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 8559d56d91..ba5a5e41cf 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 e73cc5ebc1..05f7de1319 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 a8fbc8b820..5ef5ceeece 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 96fc8e213e..1628114391 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 bad491bf7c..daac8d9a99 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 3dbe762745..1b3618558b 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 0788571750..7c11399f1b 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 ba9a286b59..9f7a93417a 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 0c9ec71af8..afcc0de55d 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 f26e5b6280..a5ea641c10 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 2f23896d13..dcb7408a20 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 c7ecd82967..e81ffd3186 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 0e47ea1351..fb12ab7c22 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 ba6a47cca8..90ef246ff8 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 6f82f54ad3..783bb62a86 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 09613fca06..8e891d66b3 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 957887ed3d..7c6d704042 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 acd5615ddc..26b7475308 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 271fb1f868..258da0d1a5 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 304f7575ee..1c4756e58c 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 befae8c2d0..8489319278 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 7cd3e59446..24c2848ed5 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 1e0cbe3432..3fdd175d73 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 8de18eeccb..040f9b7702 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 70981848ed..4083cf3b7b 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 9b4157ef30..ebfe185cc6 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 97ac28ee6f..88fe1dd9b6 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 ccb927ca5d..dd4d3aaa5e 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 a4539687f9..fe1b4961d6 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 5014e963fc..c2dcad834c 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 3d76f67963..693cc6857b 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 4168a617cf..6cd652b477 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 9c9f7c9c03..972390cea3 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 49d88353ea..e13cf06dea 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()