| /foundation/resourceschedule/ffrt/test/ut/testcase/ |
| H A D | ut_queue_dump.cpp | 67 ffrt_task_attr_t task_attr; in QueueDumpTask1Test() local
68 (void)ffrt_task_attr_init(&task_attr); in QueueDumpTask1Test()
69 ffrt_task_attr_set_name(&task_attr, "task1"); in QueueDumpTask1Test()
71 ffrt_queue_submit(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr); in QueueDumpTask1Test()
74 ffrt_queue_submit_h(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr); in QueueDumpTask1Test()
103 ffrt_task_attr_destroy(&task_attr); in QueueDumpTask1Test()
108 ffrt_task_attr_t task_attr; in QueueDumpTask2Test() local
109 (void)ffrt_task_attr_init(&task_attr); in QueueDumpTask2Test()
110 ffrt_task_attr_set_name(&task_attr, "task2"); in QueueDumpTask2Test()
112 ffrt_queue_submit(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr); in QueueDumpTask2Test()
150 ffrt_task_attr_t task_attr; QueueDumpTask3Test() local
183 QueueDumpPriorityTest(ffrt_queue_t& queue_handle, ffrt_task_attr_t& task_attr, ffrt_inner_queue_priority_t priority, const char* name) QueueDumpPriorityTest() argument
245 ffrt_task_attr_t task_attr; QueueDumpMaxDumpSizeTest() local
[all...] |
| H A D | ut_queue.cpp | 109 ffrt_task_attr_t task_attr; in HWTEST_F() local
110 (void)ffrt_task_attr_init(&task_attr); // 初始化task属性，必须 in HWTEST_F()
111 ffrt_task_attr_set_delay(&task_attr, 1000); // 设置任务1ms后才执行，非必须 in HWTEST_F()
113 ffrt_queue_submit_h(queue_handle, create_function_wrapper(basicFunc, ffrt_function_kind_queue), &task_attr); in HWTEST_F()
163 ffrt_task_attr_t task_attr; in HWTEST_F() local
164 (void)ffrt_task_attr_init(&task_attr); // attr 缺少 init 无法看护 in HWTEST_F()
168 ffrt_task_attr_set_delay(&task_attr, delay); in HWTEST_F()
172 delay = ffrt_task_attr_get_delay(&task_attr); in HWTEST_F()
174 ffrt_task_attr_destroy(&task_attr); in HWTEST_F()
222 ffrt_task_attr_t task_attr; in HWTEST_F() local
[all...] |
| H A D | ut_execute_unit.cpp | 58 ffrt::submit([&]() { x.fetch_add(2); }, {}, {}, ffrt::task_attr().delay(1)); in HWTEST_F()
60 auto h2 = ffrt::submit_h([&]() { x.fetch_add(4); }, {}, {}, ffrt::task_attr().delay(2)); in HWTEST_F()
72 auto h2 = ffrt::submit_h([&]() { x += 2; }, {&x}, {&x}, ffrt::task_attr().delay(1)); in HWTEST_F()
|
| H A D | ut_dfx.cpp | 116 ffrt::submit(basic1Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_default))); in HWTEST_F()
119 ffrt::submit(basic3Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_default))); in HWTEST_F()
121 auto task = ffrt::submit_h(basic2Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_background))); in HWTEST_F()
158 auto task = ffrt::submit_h(basic3Func, {}, {}, ffrt::task_attr().qos(static_cast<int>(ffrt::qos_background))); in HWTEST_F()
|
| H A D | ut_scheduler.cpp | 114 task_attr_private task_attr; in HWTEST_F() local
115 task_attr.name_ = "root"; in HWTEST_F()
117 &task_attr, nullptr, 0); in HWTEST_F()
119 task_attr_private task_attr; in HWTEST_F() local
120 task_attr.name_ = "i"; in HWTEST_F()
122 &task_attr, root.get(), i)); in HWTEST_F()
|
| H A D | ut_dependency.cpp | 212 ffrt::task_attr tmpTask; in HWTEST_F()
264 {x0 + i}, {x1 + pingpong}, ffrt::task_attr().name(("UI" + std::to_string(i)).c_str())); in HWTEST_F()
270 {x1 + pingpong}, {x2 + pingpong}, ffrt::task_attr().name(("Render" + std::to_string(i)).c_str())); in HWTEST_F()
276 {x2 + pingpong}, {x3 + i}, ffrt::task_attr().name(("surfaceflinger" + std::to_string(i)).c_str())); in HWTEST_F()
|
| /foundation/resourceschedule/ffrt/test/testfunc/ |
| H A D | func_pool.cpp | 49 ffrt::task_attr().name(("n" + std::to_string(deepth)).c_str())); in NestedAddOne()
85 ffrt::task_attr() in NestedWhile()
95 ffrt::task_attr() in NestedWhile()
102 ffrt::task_attr() in NestedWhile()
111 ffrt::task_attr() in NestedWhile()
117 ffrt::task_attr() in NestedWhile()
126 ffrt::task_attr() in NestedWhile()
132 ffrt::task_attr() in NestedWhile()
141 ffrt::task_attr() in NestedWhile()
147 ffrt::task_attr() in NestedWhile()
[all...] |
| /foundation/resourceschedule/ffrt/interfaces/kits/cpp/ |
| H A D | task.h | 32 class task_attr : public ffrt_task_attr_t { class
35 task_attr(const char* func = __builtin_FUNCTION()) in task_attr() function in ffrt::task_attr
41 task_attr()
47 ~task_attr() in ~task_attr()
52 task_attr(const task_attr&) = delete;
53 task_attr& operator=(const task_attr&) = delete;
62 inline task_attr& name(const char* name) in name()
87 inline task_attr
[all...] |
| H A D | queue.h | 139 inline void submit(const std::function<void()>& func, const task_attr& attr = {}) in submit()
152 inline void submit(std::function<void()>&& func, const task_attr& attr = {}) in submit()
167 inline task_handle submit_h(const std::function<void()>& func, const task_attr& attr = {}) in submit_h()
182 inline task_handle submit_h(std::function<void()>&& func, const task_attr& attr = {}) in submit_h()
|
| /foundation/resourceschedule/ffrt/examples/ |
| H A D | submit.cpp | 30 ffrt::submit([&]() { x = 2; }, {}, {&x}, ffrt::task_attr().name("add2")); in ffrt_submit_example2()
32 ffrt::task_attr().name("mul3")); // default to CPU in ffrt_submit_example2()
|
| /foundation/communication/netmanager_base/services/netpolicymanager/src/core/ |
| H A D | net_policy_callback.cpp | 46 }, ffrt::task_attr().name("FfrtRegisterNetPolicyCallbackAsync")); in RegisterNetPolicyCallbackAsync()
87 }, ffrt::task_attr().name("FfrtUnregisterNetPolicyCallbackAsync")); in UnregisterNetPolicyCallbackAsync()
120 }, ffrt::task_attr().name("FfrtNotifyNetUidPolicyChangeAsync")); in NotifyNetUidPolicyChangeAsync()
149 }, ffrt::task_attr().name("FfrtNotifyNetUidRuleChangeAsync")); in NotifyNetUidRuleChangeAsync()
177 }, ffrt::task_attr().name("FfrtNotifyNetBackgroundPolicyChangeAsync")); in NotifyNetBackgroundPolicyChangeAsync()
208 }, ffrt::task_attr().name("FfrtNotifyNetQuotaPolicyChangeAsync")); in NotifyNetQuotaPolicyChangeAsync()
235 }, ffrt::task_attr().name("FfrtNotifyNetMeteredIfacesChangeAsync")); in NotifyNetMeteredIfacesChangeAsync()
|
| /foundation/communication/netmanager_base/services/netconnmanager/src/ |
| H A D | nat464_service.cpp | 54 ffrt::task_attr().name("UpdateNat464ServiceState")); in UpdateService()
94 ffrt::task_attr().name(("Prefix64DiscoveryIter" + std::to_string(discoveryIter_)).c_str())); in StartPrefixDiscovery()
119 ffrt::task_attr().name(("Prefix64DiscoveryIter" + std::to_string(discoveryIter_)).c_str())); in DiscoverPrefix()
|
| H A D | net_factoryreset_callback.cpp | 43 }, ffrt::task_attr().name("FfrtRegisterNetFactoryResetCallbackAsync")); in RegisterNetFactoryResetCallbackAsync()
83 }, ffrt::task_attr().name("FfrtUnregisterNetFactoryResetCallbackAsync")); in UnregisterNetFactoryResetCallbackAsync()
116 }, ffrt::task_attr().name("FfrtNotifyNetFactoryResetAsync")); in NotifyNetFactoryResetAsync()
|
| /foundation/ability/form_fwk/services/src/ |
| H A D | form_serial_queue.cpp | 46 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR));
in ScheduleTask()
60 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR));
in ScheduleDelayTask()
|
| /foundation/ability/form_fwk/services/form_render_service/src/ |
| H A D | form_render_serial_queue.cpp | 47 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR));
in ScheduleTask()
61 task_handle task_handle = queue_.submit_h(func, task_attr().delay(ms * CONVERSION_FACTOR));
in ScheduleDelayTask()
|
| /foundation/resourceschedule/ffrt/src/tm/ |
| H A D | scpu_task.h | 72 task_attr_private task_attr; in RootTaskCtxWrapper() local
73 root = new RootTask{&task_attr, nullptr, 0}; in RootTaskCtxWrapper()
|
| /foundation/systemabilitymgr/samgr/services/samgr/native/source/ |
| H A D | ffrt_handler.cpp | 73 task_handle handler = queue_->submit_h(func, task_attr().delay(delayTime * CONVERSION_FACTOR));
in PostTask()
88 task_handle handler = queue_->submit_h(func, task_attr().delay(delayTime * CONVERSION_FACTOR));
in PostTask()
|
| /foundation/resourceschedule/resource_schedule_service/ressched/scene_recognize/src/ |
| H A D | slide_recognizer.cpp | 139 }, {}, {}, ffrt::task_attr().delay(listFlingEndTime_)); in HandleListFlingStart()
145 }, {}, {}, ffrt::task_attr().delay(listFlingTimeOutTime_)); in HandleListFlingStart()
169 }, {}, {}, ffrt::task_attr().delay(listFlingEndTime_)); in HandleSendFrameEvent()
|
| H A D | continuous_app_install_recognizer.cpp | 57 }, {}, {}, ffrt::task_attr().delay(EXIT_INSTALL_DELAY_TIME)); in OnDispatchResource()
|
| /foundation/ability/ability_runtime/services/common/src/ |
| H A D | ffrt_task_utils_wrap.h | 40 void BuildFfrtTaskAttr(const TaskAttribute &taskAttr, ffrt::task_attr &result);
|
| H A D | ffrt_task_handler_wrap.cpp | 26 ffrt::task_attr ffrtTaskAttr; in SubmitTaskInner()
|
| /foundation/arkui/ace_engine/adapter/ohos/osal/ |
| H A D | long_frame_report_impl.cpp | 32 }, {}, {}, ffrt::task_attr().delay(LONG_FRAME_EVENT_DELAY)); in SubmitEvent()
|
| /foundation/resourceschedule/ffrt/src/core/ |
| H A D | task_attr_private.h | 31 explicit task_attr_private(const task_attr attr) in task_attr_private()
|
| /foundation/communication/netmanager_base/services/netpolicymanager/src/common/ |
| H A D | net_policy_event_handler.cpp | 42 ffrt::task_attr().delay(static_cast<uint64_t>(delayTime)).name("FfrtSendEvent")); in SendEvent()
|
| /foundation/resourceschedule/ffrt/interfaces/inner_api/cpp/ |
| H A D | thread.h | 37 }, {}, {}, ffrt::task_attr().name(name).qos(qos_)); in thread()
50 }, {}, {}, ffrt::task_attr().qos(qos_)); in thread()
|