• Home
  • Raw
  • Download

Lines Matching refs:scbl

175     virtual void schedule(const schedulable& scbl) const = 0;
176 virtual void schedule(clock_type::time_point when, const schedulable& scbl) const = 0;
258 inline void schedule(const schedulable& scbl) const { in schedule()
260 schedule_rebind(scbl); in schedule()
264 inline void schedule(clock_type::time_point when, const schedulable& scbl) const { in schedule()
266 schedule_rebind(when, scbl); in schedule()
273 inline void schedule(clock_type::duration when, const schedulable& scbl) const { in schedule()
275 schedule_rebind(now() + when, scbl); in schedule()
280 …cally(clock_type::time_point initial, clock_type::duration period, const schedulable& scbl) const { in schedule_periodically()
282 schedule_periodically_rebind(initial, period, scbl); in schedule_periodically()
287 …dically(clock_type::duration initial, clock_type::duration period, const schedulable& scbl) const { in schedule_periodically()
289 schedule_periodically_rebind(now() + initial, period, scbl); in schedule_periodically()
301 void schedule_rebind(const schedulable& scbl, ArgN&&... an) const;
312 void schedule_rebind(clock_type::time_point when, const schedulable& scbl, ArgN&&... an) const;
323 …type::time_point initial, clock_type::duration period, const schedulable& scbl, ArgN&&... an) cons…
536 schedulable(schedulable scbl, worker q, action a) in schedulable() argument
537 : lifetime(scbl.get_subscription()) in schedulable()
540 , scoped(scbl.scoped) in schedulable()
541 , action_scope(scbl.scoped ? controller.lock().add(lifetime) : weak_subscription()) in schedulable()
743 const schedulable& scbl) in make_schedulable() argument
745 return schedulable(scbl); in make_schedulable()
749 schedulable&& scbl) in make_schedulable() argument
751 return schedulable(std::move(scbl)); in make_schedulable()
772 auto make_schedulable(schedulable scbl, composite_subscription cs, F&& f) in make_schedulable() argument
774 return schedulable(cs, scbl.get_worker(), make_action(std::forward<F>(f))); in make_schedulable()
777 auto make_schedulable(schedulable scbl, worker sc, F&& f) in make_schedulable() argument
779 return schedulable(scbl, sc, make_action(std::forward<F>(f))); in make_schedulable()
782 auto make_schedulable(schedulable scbl, F&& f) in make_schedulable() argument
784 return schedulable(scbl, scbl.get_worker(), make_action(std::forward<F>(f))); in make_schedulable()
787 inline auto make_schedulable(schedulable scbl, composite_subscription cs) in make_schedulable() argument
789 return schedulable(cs, scbl.get_worker(), scbl.get_action()); in make_schedulable()
791 inline auto make_schedulable(schedulable scbl, worker sc, composite_subscription cs) in make_schedulable() argument
793 return schedulable(cs, sc, scbl.get_action()); in make_schedulable()
795 inline auto make_schedulable(schedulable scbl, worker sc) in make_schedulable() argument
797 return schedulable(scbl, sc, scbl.get_action()); in make_schedulable()
806 auto scbl = make_schedulable(*this, std::forward<Arg0>(a0), std::forward<ArgN>(an)...); in schedule() local
807 trace_activity().schedule_enter(*inner.get(), scbl); in schedule()
808 inner->schedule(std::move(scbl)); in schedule()
812 void worker::schedule_rebind(const schedulable& scbl, ArgN&&... an) const { in schedule_rebind() argument
813 auto rescbl = make_schedulable(scbl, *this, std::forward<ArgN>(an)...); in schedule_rebind()
825 auto scbl = make_schedulable(*this, std::forward<Arg0>(a0), std::forward<ArgN>(an)...); in schedule() local
826 trace_activity().schedule_when_enter(*inner.get(), when, scbl); in schedule()
827 inner->schedule(when, std::move(scbl)); in schedule()
831 void worker::schedule_rebind(clock_type::time_point when, const schedulable& scbl, ArgN&&... an) co… in schedule_rebind() argument
832 auto rescbl = make_schedulable(scbl, *this, std::forward<ArgN>(an)...); in schedule_rebind()
847 …type::time_point initial, clock_type::duration period, const schedulable& scbl, ArgN&&... an) cons… in schedule_periodically_rebind() argument
850 auto activity = make_schedulable(scbl, keepAlive, std::forward<ArgN>(an)...); in schedule_periodically_rebind()