aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
authoraozeritsky <aozeritsky@yandex-team.ru>2022-03-24 22:09:44 +0300
committeraozeritsky <aozeritsky@yandex-team.ru>2022-03-24 22:09:44 +0300
commit336c4b71b8c800813fb3fc246335ce71bab6d170 (patch)
treedd18ee4012edb3775e3e67aac4b3f7dcda6606e1
parenta5cd1a0c117aeb638bcd9f70bbf20acaa0151927 (diff)
downloadydb-336c4b71b8c800813fb3fc246335ce71bab6d170.tar.gz
YQL-14319: Execute PassAway once (2)
ref:6ae266921385a607f34795648b02b05fd0cb5de9
-rw-r--r--ydb/library/yql/providers/dq/actors/actor_helpers.h3
1 files changed, 1 insertions, 2 deletions
diff --git a/ydb/library/yql/providers/dq/actors/actor_helpers.h b/ydb/library/yql/providers/dq/actors/actor_helpers.h
index 3a2c52f926..65be3a25d6 100644
--- a/ydb/library/yql/providers/dq/actors/actor_helpers.h
+++ b/ydb/library/yql/providers/dq/actors/actor_helpers.h
@@ -131,7 +131,6 @@ private:
ESyncState SyncState_{E_IDLE};
ui32 ExpectedEventType_{0};
THashSet<ui32> CriticalEventTypes_{};
- bool Killed = false;
void SyncHandler(TAutoPtr<NActors::IEventHandle>& ev, const NActors::TActorContext& ctx) {
const ui32 etype = ev->GetTypeRewrite();
@@ -154,7 +153,7 @@ private:
}
SyncCallback_ = nullptr;
- while (!DelayedEvents_.empty() && !Killed) {
+ while (!DelayedEvents_.empty() && !TBase::Killed) {
auto event = std::move(DelayedEvents_.front());
DelayedEvents_.pop_front();
InterruptedHandler_ = TBase::CurrentStateFunc();