diff --git a/tdactor/td/actor/impl/Scheduler-decl.h b/tdactor/td/actor/impl/Scheduler-decl.h index f44ab8e8..0e68b4c1 100644 --- a/tdactor/td/actor/impl/Scheduler-decl.h +++ b/tdactor/td/actor/impl/Scheduler-decl.h @@ -219,7 +219,7 @@ class Scheduler { bool has_guard_ = false; bool close_flag_ = false; - uint32 wait_generation_ = 0; + uint32 wait_generation_ = 1; int32 sched_id_ = 0; int32 sched_n_ = 0; std::shared_ptr> inbound_queue_; diff --git a/tdactor/td/actor/impl/Scheduler.h b/tdactor/td/actor/impl/Scheduler.h index 36b7b552..e26e479a 100644 --- a/tdactor/td/actor/impl/Scheduler.h +++ b/tdactor/td/actor/impl/Scheduler.h @@ -190,7 +190,7 @@ inline void Scheduler::before_tail_send(const ActorId<> &actor_id) { } inline void Scheduler::inc_wait_generation() { - wait_generation_++; + wait_generation_ += 2; } template