aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/test
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/test
parent4ca29390ac54b7877174de542de47532c67453b5 (diff)
downloadydb-ca04a556317a80ac802f38457a2292185282878b.tar.gz
Restoring authorship annotation for <asatarin@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/test')
-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
3 files changed, 47 insertions, 47 deletions
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()