diff options
Diffstat (limited to 'tdactor/td/actor/impl/Scheduler.h')
| -rw-r--r-- | tdactor/td/actor/impl/Scheduler.h | 9 |
1 files changed, 1 insertions, 8 deletions
diff --git a/tdactor/td/actor/impl/Scheduler.h b/tdactor/td/actor/impl/Scheduler.h index 176dbe425..298c3a05c 100644 --- a/tdactor/td/actor/impl/Scheduler.h +++ b/tdactor/td/actor/impl/Scheduler.h @@ -191,10 +191,6 @@ inline void Scheduler::before_tail_send(const ActorId<> &actor_id) { // TODO } -inline void Scheduler::inc_wait_generation() { - wait_generation_ += 2; -} - template <ActorSendType send_type, class RunFuncT, class EventFuncT> void Scheduler::send_impl(const ActorId<> &actor_id, const RunFuncT &run_func, const EventFuncT &event_func) { ActorInfo *actor_info = actor_id.get_actor_info(); @@ -210,7 +206,7 @@ void Scheduler::send_impl(const ActorId<> &actor_id, const RunFuncT &run_func, c CHECK(has_guard_ || !on_current_sched); if (likely(send_type == ActorSendType::Immediate && on_current_sched && !actor_info->is_running() && - !actor_info->must_wait(wait_generation_))) { // run immediately + !actor_info->must_wait())) { // run immediately if (likely(actor_info->mailbox_.empty())) { EventGuard guard(this, actor_info); run_func(actor_info); @@ -220,9 +216,6 @@ void Scheduler::send_impl(const ActorId<> &actor_id, const RunFuncT &run_func, c } else { if (on_current_sched) { add_to_mailbox(actor_info, event_func()); - if (send_type == ActorSendType::Later) { - actor_info->set_wait_generation(wait_generation_); - } } else { send_to_scheduler(actor_sched_id, actor_id, event_func()); } |