diff options
author | aozeritsky <aozeritsky@yandex-team.ru> | 2022-03-24 22:09:44 +0300 |
---|---|---|
committer | aozeritsky <aozeritsky@yandex-team.ru> | 2022-03-24 22:09:44 +0300 |
commit | 336c4b71b8c800813fb3fc246335ce71bab6d170 (patch) | |
tree | dd18ee4012edb3775e3e67aac4b3f7dcda6606e1 | |
parent | a5cd1a0c117aeb638bcd9f70bbf20acaa0151927 (diff) | |
download | ydb-336c4b71b8c800813fb3fc246335ce71bab6d170.tar.gz |
YQL-14319: Execute PassAway once (2)
ref:6ae266921385a607f34795648b02b05fd0cb5de9
-rw-r--r-- | ydb/library/yql/providers/dq/actors/actor_helpers.h | 3 |
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(); |