Searched refs:ticket (Results 1 – 7 of 7) sorted by relevance
| /system/ulib/fit/include/lib/fit/ |
| A D | scheduler.h | 43 suspended_task::ticket obtain_ticket(ref_count initial_refs = 1);
66 void finalize_ticket(suspended_task::ticket ticket, pending_task* task);
72 void duplicate_ticket(suspended_task::ticket ticket);
83 pending_task release_ticket(suspended_task::ticket ticket);
93 bool resume_task_with_ticket(suspended_task::ticket ticket);
143 using ticket_map = std::map<suspended_task::ticket, ticket_record>;
148 suspended_task::ticket next_ticket_ = 1;
|
| A D | promise.h | 1425 using ticket = uint64_t;
1465 virtual ticket duplicate_ticket(ticket ticket) = 0;
1469 virtual void resolve_ticket(ticket ticket, bool resume_task) = 0;
1478 suspended_task(resolver* resolver, ticket ticket) in suspended_task() argument
1479 : resolver_(resolver), ticket_(ticket) {} in suspended_task()
1518 ticket ticket_;
|
| /system/ulib/fit/ |
| A D | scheduler.cpp | 27 suspended_task::ticket ticket = next_ticket_++; in obtain_ticket() local
28 tickets_.emplace(ticket, ticket_record(initial_refs)); in obtain_ticket()
29 return ticket; in obtain_ticket()
32 void scheduler::finalize_ticket(suspended_task::ticket ticket, in finalize_ticket() argument
34 auto it = tickets_.find(ticket); in finalize_ticket()
56 void scheduler::duplicate_ticket(suspended_task::ticket ticket) { in duplicate_ticket() argument
57 auto it = tickets_.find(ticket); in duplicate_ticket()
65 pending_task scheduler::release_ticket(suspended_task::ticket ticket) { in release_ticket() argument
66 auto it = tickets_.find(ticket); in release_ticket()
83 bool scheduler::resume_task_with_ticket(suspended_task::ticket ticket) { in resume_task_with_ticket() argument
[all …]
|
| A D | single_threaded_executor.cpp | 38 suspended_task::ticket duplicate_ticket(
39 suspended_task::ticket ticket) override;
41 suspended_task::ticket ticket, bool resume_task) override;
50 suspended_task::ticket current_task_ticket_ = 0;
197 suspended_task::ticket single_threaded_executor::dispatcher_impl::duplicate_ticket( in duplicate_ticket()
198 suspended_task::ticket ticket) { in duplicate_ticket() argument
200 guarded_.scheduler_.duplicate_ticket(ticket); in duplicate_ticket()
201 return ticket; in duplicate_ticket()
205 suspended_task::ticket ticket, bool resume_task) { in resolve_ticket() argument
211 guarded_.scheduler_.resume_task_with_ticket(ticket); in resolve_ticket()
[all …]
|
| A D | promise.cpp | 30 ticket cached_ticket = ticket_; in resolve()
|
| /system/utest/fit/ |
| A D | suspended_task_tests.cpp | 24 fit::suspended_task::ticket obtain_ticket() { in obtain_ticket()
25 fit::suspended_task::ticket ticket = next_ticket_++; in obtain_ticket() local
27 return ticket; in obtain_ticket()
30 disposition get_disposition(fit::suspended_task::ticket ticket) { in get_disposition() argument
31 auto it = tickets_.find(ticket); in get_disposition()
36 fit::suspended_task::ticket duplicate_ticket( in duplicate_ticket()
37 fit::suspended_task::ticket ticket) override { in duplicate_ticket() argument
38 auto it = tickets_.find(ticket); in duplicate_ticket()
45 fit::suspended_task::ticket ticket, bool resume_task) override { in resolve_ticket() argument
46 auto it = tickets_.find(ticket); in resolve_ticket()
[all …]
|
| A D | scheduler_tests.cpp | 97 fit::suspended_task::ticket t = scheduler.obtain_ticket(); in ticket_obtain_finalize_without_task()
116 fit::suspended_task::ticket t = scheduler.obtain_ticket(); in ticket_obtain_finalize_with_task()
137 fit::suspended_task::ticket t = scheduler.obtain_ticket(2 /*initial_refs*/); in ticket_obtain2_duplicate_finalize_release()
171 fit::suspended_task::ticket t = scheduler.obtain_ticket(2 /*initial_refs*/); in ticket_obtain2_duplicate_finalize_resume()
212 fit::suspended_task::ticket t = scheduler.obtain_ticket(2 /*initial_refs*/); in ticket_obtain2_release_finalize()
239 fit::suspended_task::ticket t = scheduler.obtain_ticket(2 /*initial_refs*/); in ticket_obtain2_resume_finalize()
286 fit::suspended_task::ticket t1 = scheduler.obtain_ticket(); in take_all_tasks()
293 fit::suspended_task::ticket t2 = scheduler.obtain_ticket(); in take_all_tasks()
301 fit::suspended_task::ticket t3 = scheduler.obtain_ticket(); in take_all_tasks()
311 fit::suspended_task::ticket t4 = scheduler.obtain_ticket(); in take_all_tasks()
[all …]
|
Completed in 16 milliseconds