aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/actors/testlib/test_runtime.cpp
diff options
context:
space:
mode:
authorAlexander Gololobov <davenger@yandex-team.com>2022-02-10 16:47:37 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:47:37 +0300
commit39608cdb86363c75ce55b2b9a69841c3b71f22cf (patch)
tree4ec132c1665bd4d68e3628aa18d937c70d32413b /library/cpp/actors/testlib/test_runtime.cpp
parent54295b9bd4dc45c54d804084fd846d945148a7f0 (diff)
downloadydb-39608cdb86363c75ce55b2b9a69841c3b71f22cf.tar.gz
Restoring authorship annotation for Alexander Gololobov <davenger@yandex-team.com>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/actors/testlib/test_runtime.cpp')
-rw-r--r--library/cpp/actors/testlib/test_runtime.cpp34
1 files changed, 17 insertions, 17 deletions
diff --git a/library/cpp/actors/testlib/test_runtime.cpp b/library/cpp/actors/testlib/test_runtime.cpp
index 6fa25b9965..fd61e4c720 100644
--- a/library/cpp/actors/testlib/test_runtime.cpp
+++ b/library/cpp/actors/testlib/test_runtime.cpp
@@ -19,7 +19,7 @@
#include <util/string/printf.h>
#include <typeinfo>
-bool VERBOSE = false;
+bool VERBOSE = false;
const bool PRINT_EVENT_BODY = false;
namespace {
@@ -86,8 +86,8 @@ namespace NActors {
public:
static constexpr EActivityType ActorActivityType() {
return TEST_ACTOR_RUNTIME;
- }
-
+ }
+
TEdgeActor(TTestActorRuntimeBase* runtime)
: TActor(&TEdgeActor::StateFunc)
, Runtime(runtime)
@@ -722,9 +722,9 @@ namespace NActors {
}
void TTestActorRuntimeBase::SetVerbose(bool verbose) {
- VERBOSE = verbose;
- }
-
+ VERBOSE = verbose;
+ }
+
void TTestActorRuntimeBase::AddLocalService(const TActorId& actorId, const TActorSetupCmd& cmd, ui32 nodeIndex) {
Y_VERIFY(!IsInitialized);
Y_VERIFY(nodeIndex < NodeCount);
@@ -1038,10 +1038,10 @@ namespace NActors {
bool TTestActorRuntimeBase::DispatchEvents(const TDispatchOptions& options, TInstant simDeadline) {
TGuard<TMutex> guard(Mutex);
- return DispatchEventsInternal(options, simDeadline);
- }
-
- // Mutex must be locked by caller!
+ return DispatchEventsInternal(options, simDeadline);
+ }
+
+ // Mutex must be locked by caller!
bool TTestActorRuntimeBase::DispatchEventsInternal(const TDispatchOptions& options, TInstant simDeadline) {
TDispatchContext localContext;
localContext.Options = &options;
@@ -1253,9 +1253,9 @@ namespace NActors {
if (!localContext.FoundNonEmptyMailboxes.empty())
return true;
- if (options.CustomFinalCondition && options.CustomFinalCondition())
- return true;
-
+ if (options.CustomFinalCondition && options.CustomFinalCondition())
+ return true;
+
if (options.FinalEvents.empty()) {
for (auto& mbox : currentMailboxes) {
if (!mbox.second->IsActive(TInstant::MicroSeconds(CurrentTimestamp)))
@@ -1755,8 +1755,8 @@ namespace NActors {
public:
static constexpr EActivityType ActorActivityType() {
return TEST_ACTOR_RUNTIME;
- }
-
+ }
+
TReplyActor(TStrandingActorDecorator* owner)
: TActor(&TReplyActor::StateFunc)
, Owner(owner)
@@ -1771,8 +1771,8 @@ namespace NActors {
static constexpr EActivityType ActorActivityType() {
return TEST_ACTOR_RUNTIME;
- }
-
+ }
+
TStrandingActorDecorator(const TActorId& delegatee, bool isSync, const TVector<TActorId>& additionalActors,
TSimpleSharedPtr<TStrandingActorDecoratorContext> context, TTestActorRuntimeBase* runtime,
TReplyCheckerCreator createReplyChecker)