diff options
| author | kruall <kruall@ydb.tech> | 2023-01-09 17:35:32 +0300 |
|---|---|---|
| committer | kruall <kruall@ydb.tech> | 2023-01-09 17:35:32 +0300 |
| commit | 2eb12d53403f4761132b4c7a2de6510ee0caf934 (patch) | |
| tree | 69617babc329cd4fb61a2afd367598e915a167ae /library | |
| parent | 1e3963d9b9d567e40e89cd5ae48f4d4f1b8f2702 (diff) | |
| download | ydb-2eb12d53403f4761132b4c7a2de6510ee0caf934.tar.gz | |
Fix failed tests with united pool,
Diffstat (limited to 'library')
| -rw-r--r-- | library/cpp/actors/core/executor_thread.cpp | 3 | ||||
| -rw-r--r-- | library/cpp/actors/core/executor_thread.h | 1 |
2 files changed, 3 insertions, 1 deletions
diff --git a/library/cpp/actors/core/executor_thread.cpp b/library/cpp/actors/core/executor_thread.cpp index 8d1925f58e..215a6a4e57 100644 --- a/library/cpp/actors/core/executor_thread.cpp +++ b/library/cpp/actors/core/executor_thread.cpp @@ -40,6 +40,7 @@ namespace NActors { , ExecutorPool(executorPool) , Ctx(workerId, cpuId, actorSystem ? actorSystem->GetMaxActivityType() : 1) , ThreadName(threadName) + , IsUnitedWorker(true) { Ctx.Switch( ExecutorPool, @@ -62,7 +63,7 @@ namespace NActors { } void TExecutorThread::UnregisterActor(TMailboxHeader* mailbox, TActorId actorId) { - Y_VERIFY_DEBUG(actorId.PoolID() == ExecutorPool->PoolId && ExecutorPool->ResolveMailbox(actorId.Hint()) == mailbox); + Y_VERIFY_DEBUG(IsUnitedWorker || actorId.PoolID() == ExecutorPool->PoolId && ExecutorPool->ResolveMailbox(actorId.Hint()) == mailbox); IActor* actor = mailbox->DetachActor(actorId.LocalId()); Ctx.DecrementActorsAliveByActivity(actor->GetActivityType()); DyingActors.push_back(THolder(actor)); diff --git a/library/cpp/actors/core/executor_thread.h b/library/cpp/actors/core/executor_thread.h index 8597336bd1..9d2b67e9b5 100644 --- a/library/cpp/actors/core/executor_thread.h +++ b/library/cpp/actors/core/executor_thread.h @@ -106,6 +106,7 @@ namespace NActors { ui64 RevolvingWriteCounter = 0; const TString ThreadName; volatile TThreadId ThreadId = UnknownThreadId; + bool IsUnitedWorker = false; }; template <typename TMailbox> |