| /system/utest/fit/ |
| A D | pending_task_tests.cpp | 34 fit::pending_task empty(fit::promise<>(nullptr)); in empty_task()
40 fit::pending_task empty(fit::promise<double, int>(nullptr)); in empty_task()
94 fit::promise<> promise = task_movemove.take_promise(); in non_empty_task() local
95 EXPECT_TRUE(promise); in non_empty_task()
96 EXPECT_EQ(fit::result_state::pending, promise(context).state()); in non_empty_task()
99 EXPECT_EQ(fit::result_state::ok, promise(context).state()); in non_empty_task()
101 EXPECT_FALSE(promise); in non_empty_task()
|
| A D | bridge_tests.cpp | 294 bridge.consumer.promise()); in completer_bind_no_arg_callback()
308 bridge.consumer.promise()); in completer_bind_no_arg_callback()
328 bridge.consumer.promise()); in completer_bind_one_arg_callback()
343 bridge.consumer.promise()); in completer_bind_one_arg_callback()
364 bridge.consumer.promise()); in completer_bind_two_arg_callback()
457 fit::promise<int, const char*> promise = bridge.consumer.promise(); in consumer_promise() local
476 fit::promise<int, const char*> promise = bridge.consumer.promise(); in consumer_promise() local
494 fit::promise<int, const char*> promise = bridge.consumer.promise_or( in consumer_promise() local
514 fit::promise<int, const char*> promise = bridge.consumer.promise_or( in consumer_promise() local
549 consumer.promise() in schedule_for_consumer()
[all …]
|
| A D | promise_tests.cpp | 57 auto promise = in basics() local
92 fit::promise<> promise; in empty_promise() local
97 fit::promise<> promise(nullptr); in empty_promise() local
103 fit::promise<> promise(std::move(f)); in empty_promise() local
109 fit::promise<> promise(std::move(f)); in empty_promise() local
121 fit::promise<> promise([&](fit::context& context) -> fit::result<> { in invocation() local
147 fit::promise<> promise([&](fit::context& context) -> fit::result<> { in take_continuation() local
174 fit::promise<> promise([&](fit::context& context) -> fit::result<> { in assignment_and_swap() local
183 fit::promise<> y(std::move(promise)); in assignment_and_swap()
229 fit::promise<> promise; in comparison_with_nullptr() local
[all …]
|
| A D | scope_tests.cpp | 37 fit::promise<uint32_t> add(uint32_t value) { in add()
164 auto promise = in double_wrap() local
174 EXPECT_EQ(fit::result_state::pending, promise(context).state()); in double_wrap()
184 EXPECT_EQ(fit::result_state::pending, promise(context).state()); in double_wrap()
222 executor.schedule_task(bridge.consumer.promise()); in thread_safety()
|
| A D | sequencer_tests.cpp | 104 executor.schedule_task(bridge.consumer.promise()); in thread_safety()
|
| A D | future_tests.cpp | 57 fit::future<> nihil(fit::promise<>(nullptr)); in empty_future()
245 x = fit::promise<>(); in assignment_and_swap()
|
| /system/ulib/fit/include/lib/fit/ |
| A D | sequencer.h | 51 decltype(auto) wrap(Promise promise) { in decltype()
52 assert(promise); in decltype()
57 .then([promise = std::move(promise), in decltype()
65 return promise(context); in decltype()
|
| A D | scope.h | 101 decltype(auto) wrap(Promise promise) { in decltype()
102 assert(promise); in decltype()
106 new promise_holder<Promise>(std::move(promise))))); in decltype()
223 explicit promise_holder(Promise promise) in promise_holder() argument
224 : promise(std::move(promise)) {} in promise_holder()
227 Promise promise; variable
251 result = holder->promise(context); in operator()
|
| A D | promise.h | 961 using future = future_impl<promise<V, E>>;
990 explicit future_impl(promise_type promise) { in future_impl() argument
991 if (promise) { in future_impl()
1082 const promise_type& promise() const { in promise() function
1093 return promise; in take_promise()
1194 future_impl& operator=(promise_type promise) {
1195 if (promise) {
1271 using promise_type = promise<void, void>;
1278 pending_task(promise_type promise) in pending_task() argument
1279 : promise_(std::move(promise)) {} in pending_task()
[all …]
|
| A D | single_threaded_executor.h | 72 run_single_threaded(promise_impl<Continuation> promise) { in run_single_threaded() argument
76 exec.schedule_task(promise.then([&saved_result](result_type result) { in run_single_threaded()
|
| A D | bridge.h | 374 promise() { in promise() function
462 schedule_for_consumer(fit::executor* executor, Promise promise) { in schedule_for_consumer() argument
464 assert(promise); in schedule_for_consumer()
469 promise.then([completer = std::move(bridge.completer)]( in schedule_for_consumer()
|
| /system/utest/fit/examples/ |
| A D | promise_example1.cpp | 17 fit::promise<int, std::string> pick_bananas(int hours) { in pick_bananas()
46 fit::promise<void, std::string> eat_bananas(int appetite) { in eat_bananas()
63 fit::promise<> prepare_simulation() { in prepare_simulation()
|
| A D | utils.h | 14 fit::promise<> sleep_for_a_little_while();
|
| A D | utils.cpp | 16 fit::promise<> sleep_for_a_little_while() { in sleep_for_a_little_while()
|
| A D | promise_example2.cpp | 47 fit::promise<int> roll_die_until_successful( in roll_die_until_successful()
|
| /system/ulib/fit/ |
| A D | rules.mk | 8 $(LOCAL_DIR)/promise.cpp \
|
| A D | README.md | 142 ### fit::promise, fit::future, fit::executor, etc.
|
| /system/ulib/minfs/include/minfs/ |
| A D | allocator.h | 200 zx_status_t Reserve(WriteTxn* txn, size_t count, fbl::unique_ptr<AllocatorPromise>* promise);
|