aboutsummaryrefslogtreecommitdiffstats
path: root/library
diff options
context:
space:
mode:
authormaksim-kita <maksim-kita@yandex-team.com>2023-11-09 17:34:30 +0300
committermaksim-kita <maksim-kita@yandex-team.com>2023-11-09 17:53:51 +0300
commitf8ca3b8af2a4bbbfe4a4eca3a8c89c635eb27822 (patch)
treee58030d588f12887897f5c1373a83ed403707f0d /library
parent41d2557bbd64ce3adc13e83f4926e59723457726 (diff)
downloadydb-f8ca3b8af2a4bbbfe4a4eca3a8c89c635eb27822.tar.gz
ActorSystem remove unused code
Diffstat (limited to 'library')
-rw-r--r--library/cpp/actors/core/executor_pool_basic.cpp5
-rw-r--r--library/cpp/actors/core/executor_pool_basic.h5
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;
};