Home
last modified time | relevance | path

Searched refs:suspended_task (Results 1 – 17 of 17) sorted by relevance

/system/ulib/fit/
A Dpromise.cpp12 suspended_task::suspended_task(const suspended_task& other) in suspended_task() function in fit::suspended_task
16 suspended_task::suspended_task(suspended_task&& other) in suspended_task() function in fit::suspended_task
21 suspended_task::~suspended_task() { in ~suspended_task()
25 void suspended_task::resolve(bool resume_task) { in resolve()
36 suspended_task& suspended_task::operator=(const suspended_task& other) { in operator =()
45 suspended_task& suspended_task::operator=(suspended_task&& other) { in operator =()
55 void suspended_task::swap(suspended_task& other) { in swap()
A Dsingle_threaded_executor.cpp29 : public suspended_task::resolver {
36 suspended_task suspend_current_task();
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;
87 suspended_task single_threaded_executor::context_impl::suspend_task() { in suspend_task()
150 suspended_task single_threaded_executor::dispatcher_impl::suspend_current_task() { in suspend_current_task()
159 return suspended_task(this, current_task_ticket_); in suspend_current_task()
198 suspended_task::ticket ticket) { in duplicate_ticket()
[all …]
A Dscheduler.cpp26 suspended_task::ticket scheduler::obtain_ticket(uint32_t initial_refs) { in obtain_ticket()
27 suspended_task::ticket ticket = next_ticket_++; in obtain_ticket()
32 void scheduler::finalize_ticket(suspended_task::ticket ticket, in finalize_ticket()
56 void scheduler::duplicate_ticket(suspended_task::ticket ticket) { in duplicate_ticket()
65 pending_task scheduler::release_ticket(suspended_task::ticket ticket) { in release_ticket()
83 bool scheduler::resume_task_with_ticket(suspended_task::ticket ticket) { in resume_task_with_ticket()
/system/utest/fit/
A Dsuspended_task_tests.cpp20 class fake_resolver : public fit::suspended_task::resolver {
24 fit::suspended_task::ticket obtain_ticket() { in obtain_ticket()
36 fit::suspended_task::ticket duplicate_ticket( in duplicate_ticket()
37 fit::suspended_task::ticket ticket) override { in duplicate_ticket()
53 fit::suspended_task::ticket next_ticket_ = 1;
62 fit::suspended_task empty1; in test()
65 fit::suspended_task empty2(nullptr, 42); in test()
68 fit::suspended_task empty_copy(empty1); in test()
81 fit::suspended_task task_copy(task); in test()
95 fit::suspended_task x; in test()
[all …]
A Dscheduler_tests.cpp17 fit::suspended_task suspend_task() override { in suspend_task()
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()
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 …]
A Dpending_task_tests.cpp17 fit::suspended_task suspend_task() override { in suspend_task()
A Dsingle_threaded_executor_tests.cpp172 fit::suspended_task s[3]; in abandoning_tasks()
A Dscope_tests.cpp24 fit::suspended_task suspend_task() override { in suspend_task()
A Dfuture_tests.cpp17 fit::suspended_task suspend_task() override { in suspend_task()
A Dpromise_tests.cpp21 fit::suspended_task suspend_task() override { in suspend_task()
/system/ulib/fit/include/lib/fit/
A Dscheduler.h43 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 Dpromise.h1343 virtual suspended_task suspend_task() = 0;
1421 class suspended_task final {
1475 suspended_task() in suspended_task() function
1478 suspended_task(resolver* resolver, ticket ticket) in suspended_task() function
1481 suspended_task(const suspended_task& other);
1482 suspended_task(suspended_task&& other);
1487 ~suspended_task();
1509 void swap(suspended_task& other);
1511 suspended_task& operator=(const suspended_task& other);
1512 suspended_task& operator=(suspended_task&& other);
[all …]
A Dbridge_internal.h92 suspended_task task_ FIT_GUARDED(mutex_);
285 suspended_task task_to_notify; in drop_completion_ref()
310 suspended_task task_to_drop; in drop_consumption_ref()
349 suspended_task task_to_notify; in complete_or_abandon()
396 suspended_task task_to_drop; in await_result()
A Dsingle_threaded_executor.h57 suspended_task suspend_task() override;
A Dpromise_internal.h29 class suspended_task; variable
/system/utest/fit/examples/
A Dutils.h18 void resume_in_a_little_while(fit::suspended_task task);
A Dutils.cpp27 void resume_in_a_little_while(fit::suspended_task task) { in resume_in_a_little_while()

Completed in 28 milliseconds