aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus
diff options
context:
space:
mode:
authorasatarin <asatarin@yandex-team.ru>2022-02-10 16:47:30 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:30 +0300
commitca04a556317a80ac802f38457a2292185282878b (patch)
treec0748b5dcbade83af788c0abfa89c0383d6b779c /library/cpp/messagebus
parent4ca29390ac54b7877174de542de47532c67453b5 (diff)
downloadydb-ca04a556317a80ac802f38457a2292185282878b.tar.gz
Restoring authorship annotation for <asatarin@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus')
-rw-r--r--library/cpp/messagebus/netaddr_ut.cpp4
-rw-r--r--library/cpp/messagebus/test/ut/locator_uniq_ut.cpp4
-rw-r--r--library/cpp/messagebus/test/ut/one_way_ut.cpp12
-rw-r--r--library/cpp/messagebus/test/ut/ya.make78
-rw-r--r--library/cpp/messagebus/test_utils.h8
-rw-r--r--library/cpp/messagebus/ya.make6
6 files changed, 56 insertions, 56 deletions
diff --git a/library/cpp/messagebus/netaddr_ut.cpp b/library/cpp/messagebus/netaddr_ut.cpp
index dcaeae3e8a..e5c68bf402 100644
--- a/library/cpp/messagebus/netaddr_ut.cpp
+++ b/library/cpp/messagebus/netaddr_ut.cpp
@@ -1,13 +1,13 @@
#include <library/cpp/testing/unittest/registar.h>
#include "netaddr.h"
-#include "test_utils.h"
+#include "test_utils.h"
using namespace NBus;
Y_UNIT_TEST_SUITE(TNetAddr) {
Y_UNIT_TEST(ResolveIpv4) {
- ASSUME_IP_V4_ENABLED;
+ ASSUME_IP_V4_ENABLED;
UNIT_ASSERT(TNetAddr("ns1.yandex.ru", 80, EIP_VERSION_4).IsIpv4());
}
diff --git a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
index afc99b05e4..3fdd175d73 100644
--- a/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
+++ b/library/cpp/messagebus/test/ut/locator_uniq_ut.cpp
@@ -15,8 +15,8 @@ protected:
UNIT_TEST_SUITE_REGISTRATION(TLocatorRegisterUniqTest);
void TLocatorRegisterUniqTest::TestRegister() {
- ASSUME_IP_V4_ENABLED;
-
+ ASSUME_IP_V4_ENABLED;
+
NBus::TBusLocator locator;
const char* serviceName = "TestService";
const char* hostName = "192.168.0.42";
diff --git a/library/cpp/messagebus/test/ut/one_way_ut.cpp b/library/cpp/messagebus/test/ut/one_way_ut.cpp
index 56f7697762..9c21227e2b 100644
--- a/library/cpp/messagebus/test/ut/one_way_ut.cpp
+++ b/library/cpp/messagebus/test/ut/one_way_ut.cpp
@@ -65,9 +65,9 @@ struct NullClient : TBusClientHandlerError {
}
~NullClient() override {
- Session->Shutdown();
- }
-
+ Session->Shutdown();
+ }
+
/// dispatch of requests is done here
void Work() {
int batch = 10;
@@ -107,9 +107,9 @@ public:
}
~NullServer() override {
- Session->Shutdown();
- }
-
+ Session->Shutdown();
+ }
+
/// when message comes do not send reply, just acknowledge
void OnMessage(TOnMessageContext& mess) override {
TExampleRequest* fmess = static_cast<TExampleRequest*>(mess.GetMessage());
diff --git a/library/cpp/messagebus/test/ut/ya.make b/library/cpp/messagebus/test/ut/ya.make
index 672f3febbe..fe1b4961d6 100644
--- a/library/cpp/messagebus/test/ut/ya.make
+++ b/library/cpp/messagebus/test/ut/ya.make
@@ -11,46 +11,46 @@ TAG(
ya:fat
)
-FORK_SUBTESTS()
-
-PEERDIR(
+FORK_SUBTESTS()
+
+PEERDIR(
library/cpp/testing/unittest_main
library/cpp/messagebus
library/cpp/messagebus/test/helper
library/cpp/messagebus/www
-)
-
-SRCS(
- messagebus_ut.cpp
- module_client_ut.cpp
- module_client_one_way_ut.cpp
- module_server_ut.cpp
- one_way_ut.cpp
- starter_ut.cpp
- sync_client_ut.cpp
- locator_uniq_ut.cpp
- ../../actor/actor_ut.cpp
- ../../actor/ring_buffer_ut.cpp
- ../../actor/tasks_ut.cpp
- ../../actor/what_thread_does_guard_ut.cpp
- ../../async_result_ut.cpp
- ../../cc_semaphore_ut.cpp
- ../../coreconn_ut.cpp
- ../../duration_histogram_ut.cpp
- ../../message_status_counter_ut.cpp
- ../../misc/weak_ptr_ut.cpp
- ../../latch_ut.cpp
- ../../lfqueue_batch_ut.cpp
- ../../local_flags_ut.cpp
- ../../memory_ut.cpp
- ../../moved_ut.cpp
- ../../netaddr_ut.cpp
- ../../network_ut.cpp
- ../../nondestroying_holder_ut.cpp
- ../../scheduler_actor_ut.cpp
- ../../scheduler/scheduler_ut.cpp
- ../../socket_addr_ut.cpp
- ../../vector_swaps_ut.cpp
-)
-
-END()
+)
+
+SRCS(
+ messagebus_ut.cpp
+ module_client_ut.cpp
+ module_client_one_way_ut.cpp
+ module_server_ut.cpp
+ one_way_ut.cpp
+ starter_ut.cpp
+ sync_client_ut.cpp
+ locator_uniq_ut.cpp
+ ../../actor/actor_ut.cpp
+ ../../actor/ring_buffer_ut.cpp
+ ../../actor/tasks_ut.cpp
+ ../../actor/what_thread_does_guard_ut.cpp
+ ../../async_result_ut.cpp
+ ../../cc_semaphore_ut.cpp
+ ../../coreconn_ut.cpp
+ ../../duration_histogram_ut.cpp
+ ../../message_status_counter_ut.cpp
+ ../../misc/weak_ptr_ut.cpp
+ ../../latch_ut.cpp
+ ../../lfqueue_batch_ut.cpp
+ ../../local_flags_ut.cpp
+ ../../memory_ut.cpp
+ ../../moved_ut.cpp
+ ../../netaddr_ut.cpp
+ ../../network_ut.cpp
+ ../../nondestroying_holder_ut.cpp
+ ../../scheduler_actor_ut.cpp
+ ../../scheduler/scheduler_ut.cpp
+ ../../socket_addr_ut.cpp
+ ../../vector_swaps_ut.cpp
+)
+
+END()
diff --git a/library/cpp/messagebus/test_utils.h b/library/cpp/messagebus/test_utils.h
index 42725c0b9b..2abdf504b1 100644
--- a/library/cpp/messagebus/test_utils.h
+++ b/library/cpp/messagebus/test_utils.h
@@ -1,6 +1,6 @@
-#pragma once
-
-// Do nothing if there is no support for IPv4
+#pragma once
+
+// Do nothing if there is no support for IPv4
#define ASSUME_IP_V4_ENABLED \
do { \
try { \
@@ -9,4 +9,4 @@
Y_UNUSED(ex); \
return; \
} \
- } while (0)
+ } while (0)
diff --git a/library/cpp/messagebus/ya.make b/library/cpp/messagebus/ya.make
index f022234eb3..e13cf06dea 100644
--- a/library/cpp/messagebus/ya.make
+++ b/library/cpp/messagebus/ya.make
@@ -3,9 +3,9 @@ LIBRARY()
OWNER(g:messagebus)
IF (SANITIZER_TYPE == "undefined")
- NO_SANITIZE()
-ENDIF()
-
+ NO_SANITIZE()
+ENDIF()
+
SRCS(
acceptor.cpp
acceptor_status.cpp