diff options
author | maksim-kita <maksim-kita@yandex-team.com> | 2023-11-09 17:34:30 +0300 |
---|---|---|
committer | maksim-kita <maksim-kita@yandex-team.com> | 2023-11-09 17:53:51 +0300 |
commit | f8ca3b8af2a4bbbfe4a4eca3a8c89c635eb27822 (patch) | |
tree | e58030d588f12887897f5c1373a83ed403707f0d /library | |
parent | 41d2557bbd64ce3adc13e83f4926e59723457726 (diff) | |
download | ydb-f8ca3b8af2a4bbbfe4a4eca3a8c89c635eb27822.tar.gz |
ActorSystem remove unused code
Diffstat (limited to 'library')
-rw-r--r-- | library/cpp/actors/core/executor_pool_basic.cpp | 5 | ||||
-rw-r--r-- | library/cpp/actors/core/executor_pool_basic.h | 5 |
2 files changed, 2 insertions, 8 deletions
diff --git a/library/cpp/actors/core/executor_pool_basic.cpp b/library/cpp/actors/core/executor_pool_basic.cpp index bb36fce894..ccd813bb2e 100644 --- a/library/cpp/actors/core/executor_pool_basic.cpp +++ b/library/cpp/actors/core/executor_pool_basic.cpp @@ -285,9 +285,7 @@ namespace NActors { if (timers.Parked > 0) { wctx.AddParkedCycles(timers.Parked); } - if (timers.Blocked > 0) { - wctx.AddBlockedCycles(timers.Blocked); - } + return activation; } semaphore.CurrentSleepThreadCount++; @@ -490,7 +488,6 @@ namespace NActors { for (i16 i = 0; i != PoolThreads; ++i) { Threads[i].Thread->StopFlag = true; Threads[i].Pad.Interrupt(); - Threads[i].BlockedPad.Interrupt(); } } diff --git a/library/cpp/actors/core/executor_pool_basic.h b/library/cpp/actors/core/executor_pool_basic.h index 9e1d017ce6..dcbcaeb3db 100644 --- a/library/cpp/actors/core/executor_pool_basic.h +++ b/library/cpp/actors/core/executor_pool_basic.h @@ -21,13 +21,11 @@ namespace NActors { struct TThreadCtx { TAutoPtr<TExecutorThread> Thread; TThreadParkPad Pad; - TThreadParkPad BlockedPad; TAtomic WaitingFlag; - TAtomic BlockedFlag; // different threads must spin/block on different cache-lines. // we add some padding bytes to enforce this rule - static const size_t SizeWithoutPadding = sizeof(TAutoPtr<TExecutorThread>) + 2 * sizeof(TThreadParkPad) + sizeof(TAtomic); + static const size_t SizeWithoutPadding = sizeof(TAutoPtr<TExecutorThread>) + sizeof(TThreadParkPad) + sizeof(TAtomic); ui8 Padding[64 - SizeWithoutPadding]; static_assert(64 >= SizeWithoutPadding); @@ -47,7 +45,6 @@ namespace NActors { struct TTimers { NHPTimer::STime Elapsed = 0; NHPTimer::STime Parked = 0; - NHPTimer::STime Blocked = 0; NHPTimer::STime HPStart = GetCycleCountFast(); NHPTimer::STime HPNow; }; |