aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/messagebus/rain_check/test/helper
diff options
context:
space:
mode:
authornga <nga@yandex-team.ru>2022-02-10 16:48:09 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:48:09 +0300
commitc2a1af049e9deca890e9923abe64fe6c59060348 (patch)
treeb222e5ac2e2e98872661c51ccceee5da0d291e13 /library/cpp/messagebus/rain_check/test/helper
parent1f553f46fb4f3c5eec631352cdd900a0709016af (diff)
downloadydb-c2a1af049e9deca890e9923abe64fe6c59060348.tar.gz
Restoring authorship annotation for <nga@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/messagebus/rain_check/test/helper')
-rw-r--r--library/cpp/messagebus/rain_check/test/helper/misc.cpp38
-rw-r--r--library/cpp/messagebus/rain_check/test/helper/misc.h78
-rw-r--r--library/cpp/messagebus/rain_check/test/helper/ya.make16
3 files changed, 66 insertions, 66 deletions
diff --git a/library/cpp/messagebus/rain_check/test/helper/misc.cpp b/library/cpp/messagebus/rain_check/test/helper/misc.cpp
index 2a75c42744..c0fcb27252 100644
--- a/library/cpp/messagebus/rain_check/test/helper/misc.cpp
+++ b/library/cpp/messagebus/rain_check/test/helper/misc.cpp
@@ -1,27 +1,27 @@
#include "misc.h"
-#include <util/system/yassert.h>
-
-using namespace NRainCheck;
-
+#include <util/system/yassert.h>
+
+using namespace NRainCheck;
+
void TSpawnNopTasksCoroTask::Run() {
Y_VERIFY(Count <= Completion.size());
- for (unsigned i = 0; i < Count; ++i) {
- SpawnSubtask<TNopCoroTask>(Env, &Completion[i], "");
- }
-
- WaitForSubtasks();
-}
-
+ for (unsigned i = 0; i < Count; ++i) {
+ SpawnSubtask<TNopCoroTask>(Env, &Completion[i], "");
+ }
+
+ WaitForSubtasks();
+}
+
TContinueFunc TSpawnNopTasksSimpleTask::Start() {
Y_VERIFY(Count <= Completion.size());
- for (unsigned i = 0; i < Count; ++i) {
- SpawnSubtask<TNopSimpleTask>(Env, &Completion[i], "");
- }
-
- return &TSpawnNopTasksSimpleTask::Join;
-}
-
+ for (unsigned i = 0; i < Count; ++i) {
+ SpawnSubtask<TNopSimpleTask>(Env, &Completion[i], "");
+ }
+
+ return &TSpawnNopTasksSimpleTask::Join;
+}
+
TContinueFunc TSpawnNopTasksSimpleTask::Join() {
return nullptr;
-}
+}
diff --git a/library/cpp/messagebus/rain_check/test/helper/misc.h b/library/cpp/messagebus/rain_check/test/helper/misc.h
index dbcc04778d..9150be4d2f 100644
--- a/library/cpp/messagebus/rain_check/test/helper/misc.h
+++ b/library/cpp/messagebus/rain_check/test/helper/misc.h
@@ -1,57 +1,57 @@
-#pragma once
-
+#pragma once
+
#include <library/cpp/messagebus/rain_check/core/rain_check.h>
-
+
#include <array>
-
-namespace NRainCheck {
- struct TNopSimpleTask: public ISimpleTask {
+
+namespace NRainCheck {
+ struct TNopSimpleTask: public ISimpleTask {
TNopSimpleTask(IEnv*, const void*) {
}
-
+
TContinueFunc Start() override {
return nullptr;
- }
- };
-
- struct TNopCoroTask: public ICoroTask {
+ }
+ };
+
+ struct TNopCoroTask: public ICoroTask {
TNopCoroTask(IEnv*, const void*) {
}
-
+
void Run() override {
}
- };
-
- struct TSpawnNopTasksCoroTask: public ICoroTask {
- IEnv* const Env;
- unsigned const Count;
-
- TSpawnNopTasksCoroTask(IEnv* env, unsigned count)
- : Env(env)
- , Count(count)
+ };
+
+ struct TSpawnNopTasksCoroTask: public ICoroTask {
+ IEnv* const Env;
+ unsigned const Count;
+
+ TSpawnNopTasksCoroTask(IEnv* env, unsigned count)
+ : Env(env)
+ , Count(count)
{
}
-
+
std::array<TSubtaskCompletion, 2> Completion;
-
+
void Run() override;
- };
-
- struct TSpawnNopTasksSimpleTask: public ISimpleTask {
- IEnv* const Env;
- unsigned const Count;
-
- TSpawnNopTasksSimpleTask(IEnv* env, unsigned count)
- : Env(env)
- , Count(count)
+ };
+
+ struct TSpawnNopTasksSimpleTask: public ISimpleTask {
+ IEnv* const Env;
+ unsigned const Count;
+
+ TSpawnNopTasksSimpleTask(IEnv* env, unsigned count)
+ : Env(env)
+ , Count(count)
{
}
-
+
std::array<TSubtaskCompletion, 2> Completion;
-
+
TContinueFunc Start() override;
-
- TContinueFunc Join();
- };
-
-}
+
+ TContinueFunc Join();
+ };
+
+}
diff --git a/library/cpp/messagebus/rain_check/test/helper/ya.make b/library/cpp/messagebus/rain_check/test/helper/ya.make
index 08265167a7..aa9e4e6d81 100644
--- a/library/cpp/messagebus/rain_check/test/helper/ya.make
+++ b/library/cpp/messagebus/rain_check/test/helper/ya.make
@@ -1,13 +1,13 @@
-LIBRARY(messagebus-rain_check-test-helper)
-
+LIBRARY(messagebus-rain_check-test-helper)
+
OWNER(g:messagebus)
-
+
PEERDIR(
library/cpp/messagebus/rain_check/core
)
-SRCS(
- misc.cpp
-)
-
-END()
+SRCS(
+ misc.cpp
+)
+
+END()