Home
last modified time | relevance | path

Searched refs:ffrt (Results 1 - 25 of 591) sorted by relevance

12345678910>>...24

/foundation/resourceschedule/ffrt/src/util/
H A Dinit.cpp36 ffrt::TaskFactory::RegistCb( in ffrt_init()
37 [] () -> ffrt::CPUEUTask* { in ffrt_init()
38 return static_cast<ffrt::CPUEUTask*>(ffrt::SimpleAllocator<ffrt::SCPUEUTask>::AllocMem()); in ffrt_init()
40 [] (ffrt::CPUEUTask* task) { in ffrt_init()
41 ffrt::SimpleAllocator<ffrt::SCPUEUTask>::FreeMem(static_cast<ffrt::SCPUEUTask*>(task)); in ffrt_init()
43 ffrt in ffrt_init()
[all...]
H A Dffrt_cpu_boost.cpp34 int ret = ffrt::CpuBoostStart(ctx_id); in ffrt_cpu_boost_start()
36 ffrt::CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task; in ffrt_cpu_boost_start()
47 int ret = ffrt::CpuBoostEnd(ctx_id); in ffrt_cpu_boost_end()
49 ffrt::CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task; in ffrt_cpu_boost_end()
/foundation/resourceschedule/ffrt/test/testfunc/
H A Dfunc_pool.cpp27 using namespace ffrt;
36 ffrt::submit([&]() { NestedFib(num - 1, val1); }, {}, { &val1 }); in NestedFib()
37 ffrt::submit([&]() { NestedFib(num - 2, val2); }, {}, { &val2 }); in NestedFib()
38 ffrt::wait({ &val1, &val2 }); in NestedFib()
48 ffrt::submit([&]() { NestedAddOne(deepth - 1, val); }, { &val }, { &val }, in NestedAddOne()
49 ffrt::task_attr().name(("n" + std::to_string(deepth)).c_str())); in NestedAddOne()
50 ffrt::wait({ &val }); in NestedAddOne()
59 ffrt::submit( in NestedWhile()
61 ffrt::submit( in NestedWhile()
63 ffrt in NestedWhile()
[all...]
/foundation/resourceschedule/ffrt/test/ut/testcase/
H A Dut_dependency.cpp57 ffrt::submit([&]() { x = 2; }, {}, {&x}); in HWTEST_F()
58 ffrt::submit([&]() { x = x * 3; }, {&x}, {}); in HWTEST_F()
59 ffrt::wait(); in HWTEST_F()
69 ffrt_task_attr_set_qos(nullptr, static_cast<int>(ffrt::qos_user_initiated)); in HWTEST_F()
74 ffrt::submit([] { in HWTEST_F()
75 printf("return %d\n", ffrt::this_task::update_qos(static_cast<int>(ffrt::qos_user_initiated))); in HWTEST_F()
76 printf("id is %" PRIu64 "\n", ffrt::this_task::get_id()); in HWTEST_F()
79 ffrt::wait(); in HWTEST_F()
80 ffrt_this_task_update_qos(static_cast<int>(ffrt in HWTEST_F()
[all...]
H A Dut_csync.cpp107 ffrt::mutex lock; in HWTEST_F()
126 ffrt::recursive_mutex lock; in HWTEST_F()
145 ffrt::mutex lock; in HWTEST_F()
146 ffrt::submit([&]() { in HWTEST_F()
147 ffrt::this_task::sleep_for(10ms); in HWTEST_F()
150 ffrt::submit([&]() { in HWTEST_F()
153 ffrt::submit([&]() { in HWTEST_F()
157 ffrt::submit([&]() { in HWTEST_F()
160 ffrt::wait(); in HWTEST_F()
163 }, {}, {}, ffrt in HWTEST_F()
[all...]
H A Dut_execute_unit.cpp32 using namespace ffrt;
57 ffrt::submit([&]() { x.fetch_add(1); }); in HWTEST_F()
58 ffrt::submit([&]() { x.fetch_add(2); }, {}, {}, ffrt::task_attr().delay(1)); in HWTEST_F()
59 auto h1 = ffrt::submit_h([&]() { x.fetch_add(3); }); in HWTEST_F()
60 auto h2 = ffrt::submit_h([&]() { x.fetch_add(4); }, {}, {}, ffrt::task_attr().delay(2)); in HWTEST_F()
61 int cancel_ret = ffrt::skip(h2); in HWTEST_F()
63 ffrt::wait(); in HWTEST_F()
71 auto h1 = ffrt in HWTEST_F()
[all...]
H A Dut_condition.cpp22 using namespace ffrt;
50 ffrt::condition_variable cond; in HWTEST_F()
52 ffrt::mutex lock_; in HWTEST_F()
54 ffrt::submit( in HWTEST_F()
61 ffrt::submit( in HWTEST_F()
68 ffrt::wait(); in HWTEST_F()
73 ffrt::condition_variable cond; in HWTEST_F()
75 ffrt::mutex lock_; in HWTEST_F()
77 ffrt::submit( in HWTEST_F()
83 ffrt in HWTEST_F()
[all...]
H A Dut_dfx.cpp22 using namespace ffrt;
58 ffrt::submit( in HWTEST_F()
60 ffrt::set_trace_tag("task"); in HWTEST_F()
62 ffrt::clear_trace_tag(); in HWTEST_F()
64 ffrt::wait(); in HWTEST_F()
91 ffrt::mutex lock; in HWTEST_F()
116 ffrt::submit(basic1Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_default))); in HWTEST_F()
119 ffrt in HWTEST_F()
[all...]
H A Dut_core.cpp36 using namespace ffrt;
86 ffrt_function_header_t* basicFunc_ht = ffrt::create_function_wrapper((basicFunc)); in HWTEST_F()
152 ffrt::submit( in HWTEST_F()
162 ffrt::wait(); in HWTEST_F()
224 ffrt_task_handle_t handle = ffrt_submit_h_base(ffrt::create_function_wrapper(OnePlusFunc), {}, {}, &taskAttr); in HWTEST_F()
225 auto task = static_cast<ffrt::CPUEUTask*>(handle); in HWTEST_F()
231 ffrt::wait({handle}); in HWTEST_F()
238 * 测试用例描述：构造2个submit_h的任务，验证task_handle转成dependence后，调用ffrt::wait的场景
240 * 操作步骤：创建另外一个task_handle任务，并且先执行ffrt::wait保存的dependence的数组
245 std::vector<ffrt in HWTEST_F()
[all...]
H A Dut_ffrt_io.cpp61 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos; in SetUp()
62 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).flag_ = ffrt::EpollStatus::WAKE; in SetUp()
67 ffrt::QoS qos = ffrt::ExecuteCtx::Cur()->qos; in TearDown()
68 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).timerHandle_ = -1; in TearDown()
69 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).timerMap_.clear(); in TearDown()
70 ffrt::FFRTFacade::GetPPInstance().GetPoller(qos).executedHandle_.clear(); in TearDown()
71 ffrt in TearDown()
[all...]
H A Dut_flo.cpp38 using namespace ffrt;
48 bool ffrt; member
64 .ffrt = true, in InitCfg()
117 auto handle = ffrt::submit_h([] { in HWTEST_F()
121 ffrt::wait({handle}); in HWTEST_F()
127 auto handle = ffrt::submit_h([] { in HWTEST_F()
129 ffrt::this_task::yield(); in HWTEST_F()
132 ffrt::wait({handle}); in HWTEST_F()
/foundation/resourceschedule/ffrt/src/core/
H A Dtask_io.cpp31 namespace ffrt { namespace
53 task->status = ffrt::ExecTaskStatus::ET_PENDING; in ExecuteIOTask()
65 } /* namespace ffrt */
75 pthread_once(&ffrt::once, ffrt::InitIOTaskExecutor); in ffrt_submit_coroutine()
77 ffrt::task_attr_private *p = reinterpret_cast<ffrt::task_attr_private *>(const_cast<ffrt_task_attr_t *>(attr)); in ffrt_submit_coroutine()
78 ffrt::QoS qos = (p == nullptr ? ffrt::QoS() : ffrt in ffrt_submit_coroutine()
[all...]
H A Dtask.cpp42 namespace ffrt { namespace
58 CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task; in set_trace_tag()
67 CPUEUTask* curTask = ffrt::ExecuteCtx::Cur()->task; in clear_trace_tag()
90 } // namespace ffrt
102 static_assert(sizeof(ffrt::task_attr_private) <= ffrt_task_attr_storage_size, in ffrt_task_attr_init()
105 new (attr)ffrt::task_attr_private(); in ffrt_task_attr_init()
116 auto p = reinterpret_cast<ffrt::task_attr_private *>(attr); in ffrt_task_attr_destroy()
127 (reinterpret_cast<ffrt::task_attr_private *>(attr))->name_ = name; in ffrt_task_attr_set_name()
138 return (reinterpret_cast<ffrt::task_attr_private *>(p))->name_.c_str(); in ffrt_task_attr_get_name()
148 if (ffrt in ffrt_task_attr_set_qos()
[all...]
/foundation/resourceschedule/ffrt/src/sync/
H A Dpoller_api.cpp21 static bool QosConvert(ffrt_qos_t qos, ffrt::QoS& mappedQos) in QosConvert()
23 if (ffrt::GetFuncQosMap() == nullptr) { in QosConvert()
27 mappedQos = ffrt::GetFuncQosMap()(qos); in QosConvert()
28 if (mappedQos == ffrt::qos_inherit) { in QosConvert()
29 mappedQos = ffrt::ExecuteCtx::Cur()->qos(); in QosConvert()
37 ffrt::QoS ffrtQos; in ffrt_epoll_ctl()
42 return ffrt::FFRTFacade::GetPPInstance().GetPoller(ffrtQos).DelFdEvent(fd); in ffrt_epoll_ctl()
44 int ret = ffrt::FFRTFacade::GetPPInstance().GetPoller(ffrtQos).AddFdEvent(op, events, fd, data, cb); in ffrt_epoll_ctl()
46 ffrt::FFRTFacade::GetEUInstance().NotifyLocalTaskAdded(ffrtQos); in ffrt_epoll_ctl()
58 ffrt in ffrt_epoll_wait()
[all...]
H A Dtimer_api.cpp22 static bool QosConvert(ffrt_qos_t qos, ffrt::QoS& mappedQos) in QosConvert()
24 if (ffrt::GetFuncQosMap() == nullptr) { in QosConvert()
28 mappedQos = ffrt::GetFuncQosMap()(qos); in QosConvert()
29 if (mappedQos == ffrt::qos_inherit) { in QosConvert()
30 mappedQos = ffrt::ExecuteCtx::Cur()->qos(); in QosConvert()
38 ffrt::QoS pollerQos; in ffrt_timer_start()
48 int handle = ffrt::FFRTFacade::GetPPInstance().GetPoller(pollerQos).RegisterTimer(timeout, data, cb, repeat); in ffrt_timer_start()
50 ffrt::FFRTFacade::GetEUInstance().NotifyLocalTaskAdded(pollerQos); in ffrt_timer_start()
58 ffrt::QoS pollerQos; in ffrt_timer_stop()
63 return ffrt in ffrt_timer_stop()
[all...]
H A Dcondition_variable.cpp23 namespace ffrt { namespace
37 static_assert(sizeof(ffrt::condition_variable_private) <= ffrt_cond_storage_size, in ffrt_cond_init()
40 new (cond) ffrt::condition_variable_private(); in ffrt_cond_init()
51 auto p = reinterpret_cast<ffrt::condition_variable_private *>(cond); in ffrt_cond_signal()
63 auto p = reinterpret_cast<ffrt::condition_variable_private *>(cond); in ffrt_cond_broadcast()
75 auto pc = reinterpret_cast<ffrt::condition_variable_private *>(cond); in ffrt_cond_wait()
76 auto pm = reinterpret_cast<ffrt::mutexPrivate *>(mutex); in ffrt_cond_wait()
88 auto pc = reinterpret_cast<ffrt::condition_variable_private *>(cond); in ffrt_cond_timedwait()
89 auto pm = reinterpret_cast<ffrt::mutexPrivate *>(mutex); in ffrt_cond_timedwait()
93 auto tp = ffrt in ffrt_cond_timedwait()
[all...]
/foundation/resourceschedule/ffrt/examples/
H A Dsubmit.cpp21 ffrt::submit([&]() { x = 2; }, {}, {&x}); in ffrt_submit_example1()
22 ffrt::submit([&]() { x = x * 3; }, {&x}, {}); in ffrt_submit_example1()
23 ffrt::wait(); in ffrt_submit_example1()
24 printf("hello ffrt. x=%d\n", x); in ffrt_submit_example1()
30 ffrt::submit([&]() { x = 2; }, {}, {&x}, ffrt::task_attr().name("add2")); in ffrt_submit_example2()
31 ffrt::submit([&]() { x = x * 3; }, {&x}, {}, in ffrt_submit_example2()
32 ffrt::task_attr().name("mul3")); // default to CPU in ffrt_submit_example2()
33 ffrt::wait(); in ffrt_submit_example2()
34 printf("hello ffrt in ffrt_submit_example2()
[all...]
/foundation/resourceschedule/ffrt/benchmarks/fib/
H A Dfib.cpp19 using namespace ffrt;
41 ffrt::submit([&]() { FibFFRTChildWait(x - 1, y1); }, {}, {}); in FibFFRTChildWait()
42 ffrt::submit([&]() { FibFFRTChildWait(x - 2, y2); }, {}, {}); in FibFFRTChildWait()
43 ffrt::wait(); in FibFFRTChildWait()
56 ffrt::submit([&]() { FibFFRTDataWait(x - 1, y1); }, {}, {&y1}); in FibFFRTDataWait()
57 ffrt::submit([&]() { FibFFRTDataWait(x - 2, y2); }, {}, {&y2}); in FibFFRTDataWait()
58 ffrt::wait({&y1, &y2}); in FibFFRTDataWait()
77 ffrt::submit([&]() { FibFFRTDataWait(FIB_NUM, output); }, {}, {&output}); in FibDataWait()
78 ffrt::wait({&output}); in FibDataWait()
91 ffrt in FibFFRTNoWait()
[all...]
/foundation/ai/intelligent_voice_framework/utils/
H A Dthread_wrapper.cpp36 INTELL_VOICE_LOG_INFO("use ffrt"); in Start()
37 thread_ = std::make_unique<ffrt::thread>(name.c_str(), Convert2FfrtQos(qos), &ThreadWrapper::RunInThread, this); in Start()
39 INTELL_VOICE_LOG_INFO("do not use ffrt"); in Start()
74 ffrt::qos ThreadWrapper::Convert2FfrtQos(TaskQoS taskqos) in Convert2FfrtQos()
78 return ffrt::qos_inherit; in Convert2FfrtQos()
80 return ffrt::qos_background; in Convert2FfrtQos()
82 return ffrt::qos_utility; in Convert2FfrtQos()
84 return ffrt::qos_default; in Convert2FfrtQos()
86 return ffrt::qos_user_initiated; in Convert2FfrtQos()
88 return ffrt in Convert2FfrtQos()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dconcurrent_adapter.cpp23 ffrt::submit(action); in ScheduleTask()
25 ffrt::submit(action, {}, { outDeps }); in ScheduleTask()
27 ffrt::submit(action, { inDeps }, {}); in ScheduleTask()
29 ffrt::submit(action, { inDeps }, { outDeps }); in ScheduleTask()
41 return ffrt::submit_h(action); in ScheduleTaskH()
43 return ffrt::submit_h(action, {}, { outDeps }); in ScheduleTaskH()
45 return ffrt::submit_h(action, { inDeps }, {}); in ScheduleTaskH()
47 return ffrt::submit_h(action, { inDeps }, { outDeps }); in ScheduleTaskH()
/foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/src/
H A Dslide_recognizer.cpp32 static ffrt::recursive_mutex stateMutex;
34 std::lock_guard<ffrt::recursive_mutex> lock(stateMutex);
83 std::lock_guard<ffrt::recursive_mutex> lock(stateMutex); in HandleSlideOFFEvent()
88 ffrt::skip(listFlingEndTask_); in HandleSlideOFFEvent()
91 ffrt::skip(listFlingTimeOutTask_); in HandleSlideOFFEvent()
103 ffrt::skip(listFlingEndTask_); in HandleSlideDetecting()
106 ffrt::skip(listFlingTimeOutTask_); in HandleSlideDetecting()
126 std::lock_guard<ffrt::recursive_mutex> lock(stateMutex); in HandleListFlingStart()
135 ffrt::skip(listFlingEndTask_); in HandleListFlingStart()
137 listFlingEndTask_ = ffrt in HandleListFlingStart()
[all...]
/foundation/resourceschedule/ffrt/benchmarks/face_story/
H A Dface_story.cpp39 ffrt::submit( in FaceStory()
42 ffrt::submit([&]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {}, {}); in FaceStory()
45 ffrt::submit([&]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {}, {}); in FaceStory()
47 ffrt::wait(); // 同步下采样结果 in FaceStory()
55 ffrt::submit( in FaceStory()
66 ffrt::submit([&]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {&faceBboxes_}, {}); in FaceStory()
71 ffrt::submit( in FaceStory()
82 ffrt::submit( in FaceStory()
93 ffrt::submit( in FaceStory()
104 ffrt in FaceStory()
[all...]
/foundation/resourceschedule/ffrt/benchmarks/fork_join/
H A Dfork_join.cpp28 ffrt::submit([=]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {}, {}); in ForkJoin()
30 ffrt::wait(); in ForkJoin()
41 ffrt::submit( in ForkJoinWorker()
44 ffrt::submit([=]() { simulate_task_compute_time(COMPUTE_TIME_US); }, {}, {}); in ForkJoinWorker()
46 ffrt::wait(); in ForkJoinWorker()
49 ffrt::wait({&r}); in ForkJoinWorker()
/foundation/filemanagement/dfs_service/utils/ffrt/src/
H A Dffrt_timer.cpp33 unique_lock<ffrt::mutex> lock(taskMutex_); in Start()
46 unique_lock<ffrt::mutex> lock(sleepMutex_); in Start()
57 ffrt::submit(task, {}, {isJoinable_.get()}, ffrt::task_attr().name(name_.c_str())); in Start()
62 unique_lock<ffrt::mutex> lock(taskMutex_); in Stop()
70 std::unique_lock<ffrt::mutex> lock(sleepMutex_); in Stop()
76 ffrt::wait({isJoinable_.get()}); in Stop()
/foundation/communication/wifi/wifi/utils/src/
H A Dwifi_event_handler.cpp109 std::lock_guard<ffrt::mutex> lock(eventQurueMutex); in WifiEventHandlerImpl()
115 eventQueue = std::make_shared<ffrt::queue>(threadName.c_str()); in WifiEventHandlerImpl()
118 eventQueue = std::make_shared<ffrt::queue>(threadName.c_str(), in WifiEventHandlerImpl()
119 ffrt::queue_attr().callback(timeOutFunc)); in WifiEventHandlerImpl()
128 std::lock_guard<ffrt::mutex> lock(eventQurueMutex); in ~WifiEventHandlerImpl()
145 std::lock_guard<ffrt::mutex> lock(eventQurueMutex); in PostSyncTask()
151 ffrt::task_handle handle = eventQueue->submit_h(callback); in PostSyncTask()
160 std::lock_guard<ffrt::mutex> lock(eventQurueMutex); in PostAsyncTask()
167 ffrt::task_handle handle = eventQueue->submit_h(callback, ffrt in PostAsyncTask()
[all...]

Completed in 9 milliseconds

12345678910>>...24