Lines Matching refs:scheduler
29 fit::subtle::scheduler scheduler; in initial_state() local
30 EXPECT_FALSE(scheduler.has_runnable_tasks()); in initial_state()
31 EXPECT_FALSE(scheduler.has_suspended_tasks()); in initial_state()
32 EXPECT_FALSE(scheduler.has_outstanding_tickets()); in initial_state()
40 fit::subtle::scheduler scheduler; in schedule_task() local
41 fit::subtle::scheduler::task_queue tasks; in schedule_task()
46 scheduler.take_runnable_tasks(&tasks); in schedule_task()
50 scheduler.schedule_task(make_pending_task(&run_count[0])); in schedule_task()
51 EXPECT_TRUE(scheduler.has_runnable_tasks()); in schedule_task()
52 EXPECT_FALSE(scheduler.has_suspended_tasks()); in schedule_task()
53 EXPECT_FALSE(scheduler.has_outstanding_tickets()); in schedule_task()
54 scheduler.take_runnable_tasks(&tasks); in schedule_task()
61 scheduler.schedule_task(make_pending_task(&run_count[0])); in schedule_task()
62 scheduler.schedule_task(make_pending_task(&run_count[1])); in schedule_task()
63 scheduler.schedule_task(make_pending_task(&run_count[2])); in schedule_task()
64 EXPECT_TRUE(scheduler.has_runnable_tasks()); in schedule_task()
65 EXPECT_FALSE(scheduler.has_suspended_tasks()); in schedule_task()
66 EXPECT_FALSE(scheduler.has_outstanding_tickets()); in schedule_task()
67 scheduler.take_runnable_tasks(&tasks); in schedule_task()
86 scheduler.take_runnable_tasks(&tasks); in schedule_task()
95 fit::subtle::scheduler scheduler; in ticket_obtain_finalize_without_task() local
97 fit::suspended_task::ticket t = scheduler.obtain_ticket(); in ticket_obtain_finalize_without_task()
98 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain_finalize_without_task()
99 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain_finalize_without_task()
100 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain_finalize_without_task()
103 scheduler.finalize_ticket(t, &task); in ticket_obtain_finalize_without_task()
104 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain_finalize_without_task()
105 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain_finalize_without_task()
106 EXPECT_FALSE(scheduler.has_outstanding_tickets()); in ticket_obtain_finalize_without_task()
114 fit::subtle::scheduler scheduler; in ticket_obtain_finalize_with_task() local
116 fit::suspended_task::ticket t = scheduler.obtain_ticket(); in ticket_obtain_finalize_with_task()
117 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain_finalize_with_task()
118 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain_finalize_with_task()
119 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain_finalize_with_task()
123 scheduler.finalize_ticket(t, &p); in ticket_obtain_finalize_with_task()
124 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain_finalize_with_task()
125 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain_finalize_with_task()
126 EXPECT_FALSE(scheduler.has_outstanding_tickets()); in ticket_obtain_finalize_with_task()
135 fit::subtle::scheduler scheduler; in ticket_obtain2_duplicate_finalize_release() local
137 fit::suspended_task::ticket t = scheduler.obtain_ticket(2 /*initial_refs*/); in ticket_obtain2_duplicate_finalize_release()
138 scheduler.duplicate_ticket(t); in ticket_obtain2_duplicate_finalize_release()
139 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_duplicate_finalize_release()
140 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_duplicate_finalize_release()
141 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_duplicate_finalize_release()
145 scheduler.finalize_ticket(t, &p); in ticket_obtain2_duplicate_finalize_release()
146 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_duplicate_finalize_release()
147 EXPECT_TRUE(scheduler.has_suspended_tasks()); in ticket_obtain2_duplicate_finalize_release()
148 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_duplicate_finalize_release()
151 p = scheduler.release_ticket(t); in ticket_obtain2_duplicate_finalize_release()
152 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_duplicate_finalize_release()
153 EXPECT_TRUE(scheduler.has_suspended_tasks()); in ticket_obtain2_duplicate_finalize_release()
154 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_duplicate_finalize_release()
157 p = scheduler.release_ticket(t); in ticket_obtain2_duplicate_finalize_release()
158 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_duplicate_finalize_release()
159 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_duplicate_finalize_release()
160 EXPECT_FALSE(scheduler.has_outstanding_tickets()); in ticket_obtain2_duplicate_finalize_release()
169 fit::subtle::scheduler scheduler; in ticket_obtain2_duplicate_finalize_resume() local
171 fit::suspended_task::ticket t = scheduler.obtain_ticket(2 /*initial_refs*/); in ticket_obtain2_duplicate_finalize_resume()
172 scheduler.duplicate_ticket(t); in ticket_obtain2_duplicate_finalize_resume()
173 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_duplicate_finalize_resume()
174 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_duplicate_finalize_resume()
175 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_duplicate_finalize_resume()
179 scheduler.finalize_ticket(t, &p); in ticket_obtain2_duplicate_finalize_resume()
180 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_duplicate_finalize_resume()
181 EXPECT_TRUE(scheduler.has_suspended_tasks()); in ticket_obtain2_duplicate_finalize_resume()
182 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_duplicate_finalize_resume()
185 scheduler.resume_task_with_ticket(t); in ticket_obtain2_duplicate_finalize_resume()
186 EXPECT_TRUE(scheduler.has_runnable_tasks()); in ticket_obtain2_duplicate_finalize_resume()
187 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_duplicate_finalize_resume()
188 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_duplicate_finalize_resume()
190 p = scheduler.release_ticket(t); in ticket_obtain2_duplicate_finalize_resume()
191 EXPECT_TRUE(scheduler.has_runnable_tasks()); in ticket_obtain2_duplicate_finalize_resume()
192 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_duplicate_finalize_resume()
193 EXPECT_FALSE(scheduler.has_outstanding_tickets()); in ticket_obtain2_duplicate_finalize_resume()
196 fit::subtle::scheduler::task_queue tasks; in ticket_obtain2_duplicate_finalize_resume()
197 scheduler.take_runnable_tasks(&tasks); in ticket_obtain2_duplicate_finalize_resume()
210 fit::subtle::scheduler scheduler; in ticket_obtain2_release_finalize() local
212 fit::suspended_task::ticket t = scheduler.obtain_ticket(2 /*initial_refs*/); in ticket_obtain2_release_finalize()
213 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_release_finalize()
214 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_release_finalize()
215 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_release_finalize()
217 fit::pending_task p = scheduler.release_ticket(t); in ticket_obtain2_release_finalize()
218 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_release_finalize()
219 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_release_finalize()
220 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_release_finalize()
225 scheduler.finalize_ticket(t, &p); in ticket_obtain2_release_finalize()
226 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_release_finalize()
227 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_release_finalize()
228 EXPECT_FALSE(scheduler.has_outstanding_tickets()); in ticket_obtain2_release_finalize()
237 fit::subtle::scheduler scheduler; in ticket_obtain2_resume_finalize() local
239 fit::suspended_task::ticket t = scheduler.obtain_ticket(2 /*initial_refs*/); in ticket_obtain2_resume_finalize()
240 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_resume_finalize()
241 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_resume_finalize()
242 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_resume_finalize()
244 scheduler.resume_task_with_ticket(t); in ticket_obtain2_resume_finalize()
245 EXPECT_FALSE(scheduler.has_runnable_tasks()); in ticket_obtain2_resume_finalize()
246 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_resume_finalize()
247 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in ticket_obtain2_resume_finalize()
251 scheduler.finalize_ticket(t, &p); in ticket_obtain2_resume_finalize()
252 EXPECT_TRUE(scheduler.has_runnable_tasks()); in ticket_obtain2_resume_finalize()
253 EXPECT_FALSE(scheduler.has_suspended_tasks()); in ticket_obtain2_resume_finalize()
254 EXPECT_FALSE(scheduler.has_outstanding_tickets()); in ticket_obtain2_resume_finalize()
257 fit::subtle::scheduler::task_queue tasks; in ticket_obtain2_resume_finalize()
258 scheduler.take_runnable_tasks(&tasks); in ticket_obtain2_resume_finalize()
271 fit::subtle::scheduler scheduler; in take_all_tasks() local
272 fit::subtle::scheduler::task_queue tasks; in take_all_tasks()
277 scheduler.take_all_tasks(&tasks); in take_all_tasks()
281 scheduler.schedule_task(make_pending_task(&run_count[0])); in take_all_tasks()
282 EXPECT_TRUE(scheduler.has_runnable_tasks()); in take_all_tasks()
286 fit::suspended_task::ticket t1 = scheduler.obtain_ticket(); in take_all_tasks()
288 scheduler.finalize_ticket(t1, &p1); in take_all_tasks()
293 fit::suspended_task::ticket t2 = scheduler.obtain_ticket(); in take_all_tasks()
295 scheduler.duplicate_ticket(t2); in take_all_tasks()
296 scheduler.finalize_ticket(t2, &p2); in take_all_tasks()
301 fit::suspended_task::ticket t3 = scheduler.obtain_ticket(); in take_all_tasks()
303 scheduler.duplicate_ticket(t3); in take_all_tasks()
304 scheduler.finalize_ticket(t3, &p3); in take_all_tasks()
306 p3 = scheduler.release_ticket(t3); in take_all_tasks()
311 fit::suspended_task::ticket t4 = scheduler.obtain_ticket(); in take_all_tasks()
313 scheduler.duplicate_ticket(t4); in take_all_tasks()
314 scheduler.finalize_ticket(t4, &p4); in take_all_tasks()
316 EXPECT_TRUE(scheduler.resume_task_with_ticket(t4)); in take_all_tasks()
321 fit::suspended_task::ticket t5 = scheduler.obtain_ticket(); in take_all_tasks()
323 scheduler.duplicate_ticket(t5); in take_all_tasks()
324 scheduler.duplicate_ticket(t5); in take_all_tasks()
325 scheduler.finalize_ticket(t5, &p5); in take_all_tasks()
327 EXPECT_TRUE(scheduler.resume_task_with_ticket(t5)); in take_all_tasks()
333 EXPECT_TRUE(scheduler.has_runnable_tasks()); in take_all_tasks()
334 EXPECT_TRUE(scheduler.has_suspended_tasks()); in take_all_tasks()
335 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in take_all_tasks()
336 scheduler.take_all_tasks(&tasks); in take_all_tasks()
337 EXPECT_FALSE(scheduler.has_runnable_tasks()); in take_all_tasks()
338 EXPECT_FALSE(scheduler.has_suspended_tasks()); in take_all_tasks()
339 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in take_all_tasks()
355 scheduler.take_all_tasks(&tasks); in take_all_tasks()
356 EXPECT_FALSE(scheduler.has_runnable_tasks()); in take_all_tasks()
357 EXPECT_FALSE(scheduler.has_suspended_tasks()); in take_all_tasks()
358 EXPECT_TRUE(scheduler.has_outstanding_tickets()); in take_all_tasks()