| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/task/src/ |
| D | task_test.cpp | 159 std::shared_ptr<Task> task = nullptr; variable
173 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, taskParam, nullptr); variable
186 auto task = TaskFactory::GetInstance().CreateTask(TaskType::DISABLE, taskParam, nullptr); variable
199 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, taskParam, nullptr); variable
212 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr); variable
225 auto task = TaskFactory::GetInstance().CreateTask(TaskType::UNKNOWN, taskParam, nullptr); variable
308 auto task = TaskFactory::GetInstance().CreateTask(TaskType::DISABLE, taskParam, nullptr); variable
322 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ENABLE, taskParam, nullptr); variable
336 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr); variable
353 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr); variable
[all …]
|
| /foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/canvas/ |
| D | canvas_pattern.cpp | 182 auto task = [isEnabled](CanvasPaintMethod& paintMethod) { in SetAntiAlias() local
194 auto task = [rect](CanvasPaintMethod& paintMethod) { in FillRect() local
206 auto task = [rect](CanvasPaintMethod& paintMethod) { in StrokeRect() local
218 auto task = [rect](CanvasPaintMethod& paintMethod) { in ClearRect() local
230 auto task = [](CanvasPaintMethod& paintMethod) { in Fill() local
242 auto task = [path](CanvasPaintMethod& paintMethod) { in Fill() local
254 auto task = [](CanvasPaintMethod& paintMethod) { in Stroke() local
266 auto task = [path](CanvasPaintMethod& paintMethod) { in Stroke() local
278 auto task = [](CanvasPaintMethod& paintMethod) { in Clip() local
290 auto task = [path](CanvasPaintMethod& paintMethod) { in Clip() local
[all …]
|
| /foundation/arkui/ace_engine/frameworks/core/components/custom_paint/ |
| D | custom_paint_component.cpp | 50 auto task = [offscreenCanvas](RenderCustomPaint& interface, const Offset&) { in TransferFromImageBitmap() local
59 auto task = [offscreenCanvas, mesh, column, row](RenderCustomPaint& interface, const Offset&) { in DrawBitmapMesh() local
87 auto task = [](RenderCustomPaint& interface, const Offset& offset) { interface.WebGLUpdate(); }; in WebGLUpdate() local
93 …auto task = [isEnabled](RenderCustomPaint& interface, const Offset&) { interface.SetAntiAlias(isEn… in SetAntiAlias() local
99 …auto task = [rect](RenderCustomPaint& interface, const Offset& offset) { interface.FillRect(offset… in FillRect() local
105 …auto task = [rect](RenderCustomPaint& interface, const Offset& offset) { interface.StrokeRect(offs… in StrokeRect() local
111 …auto task = [rect](RenderCustomPaint& interface, const Offset& offset) { interface.ClearRect(offse… in ClearRect() local
117 auto task = [text, textOffset](RenderCustomPaint& interface, const Offset& offset) { in FillText() local
125 auto task = [text, textOffset](RenderCustomPaint& interface, const Offset& offset) { in StrokeText() local
160 …auto task = [x, y](RenderCustomPaint& interface, const Offset& offset) { interface.MoveTo(offset, … in MoveTo() local
[all …]
|
| /foundation/communication/netstack/test/unittest/http_client/ |
| D | HttpClientTaskTest.cpp | 64 auto task = session.CreateTask(httpReq); variable
76 auto task = session.CreateTask(httpReq); variable
88 auto task = session.CreateTask(httpReq); variable
111 auto task = session.CreateTask(httpReq); variable
131 auto task = session.CreateTask(httpReq); variable
150 auto task = session.CreateTask(httpReq); variable
170 auto task = session.CreateTask(httpReq); variable
192 auto task = session.CreateTask(httpReq); variable
208 auto task = session.CreateTask(httpReq, UPLOAD, filePath); variable
223 auto task = session.CreateTask(httpReq, UPLOAD, filePath); variable
[all …]
|
| /foundation/resourceschedule/ffrt/src/eu/ |
| D | co_routine.cpp | 91 bool IsTaskLocalEnable(ffrt::CPUEUTask* task) in IsTaskLocalEnable()
118 void SwitchTsdAddrToTask(ffrt::CPUEUTask* task) in SwitchTsdAddrToTask()
125 void SwitchTsdToTask(ffrt::CPUEUTask* task) in SwitchTsdToTask()
139 bool SwitchTsdAddrToThread(ffrt::CPUEUTask* task) in SwitchTsdAddrToThread()
169 void SwitchTsdToThread(ffrt::CPUEUTask* task) in SwitchTsdToThread()
185 void TaskTsdRunDtors(ffrt::CPUEUTask* task) in TaskTsdRunDtors()
193 void TaskTsdDeconstruct(ffrt::CPUEUTask* task) in TaskTsdDeconstruct()
239 ffrt::CPUEUTask* task = co->task; in CoStartEntry() local
338 static inline void BindNewCoRoutione(ffrt::CPUEUTask* task) in BindNewCoRoutione()
345 static inline void UnbindCoRoutione(ffrt::CPUEUTask* task) in UnbindCoRoutione()
[all …]
|
| D | cpu_worker.cpp | 41 void CPUWorker::Run(CPUEUTask* task, CoRoutineEnv* coRoutineEnv, CPUWorker* worker) in Run()
75 void CPUWorker::Run(ffrt_executor_task_t* task, ffrt_qos_t qos) in Run()
118 CPUEUTask* task = reinterpret_cast<CPUEUTask*>(curtask); in RunTask() local
145 void CPUWorker::RunTaskLifo(ffrt_executor_task_t* task, CPUWorker* worker) in RunTaskLifo()
166 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker); in GetTask() local
180 void* task = worker->priority_task; in GetTask() local
262 CPUEUTask* task = worker->ops.PickUpTaskBatch(worker); in WorkerLooperDefault() local
|
| /foundation/arkui/ace_engine/frameworks/base/thread/ |
| D | task_executor.h | 102 bool PostTaskWithTraceId(Task&& task, TaskType type, int32_t id, const std::string& name) const in PostTaskWithTraceId()
117 …bool PostTaskWithTraceId(const Task& task, TaskType type, int32_t id, const std::string& name) con… in PostTaskWithTraceId()
189 …bool PostSyncTaskTimeout(const Task& task, TaskType type, uint32_t timeoutMs, const std::string& n… in PostSyncTaskTimeout()
210 bool PostSyncTask(const Task& task, TaskType type, const std::string& name) const in PostSyncTask()
224 bool PostSyncTask(CancelableTask&& task, TaskType type, const std::string& name) const in PostSyncTask()
245 bool PostSyncTask(const CancelableTask& task, TaskType type, const std::string& name) const in PostSyncTask()
359 bool PostTask(Task&& task, const std::string& name) const in PostTask()
371 bool PostTask(const Task& task, const std::string& name) const in PostTask()
385 bool PostDelayedTask(Task&& task, uint32_t delayTime, const std::string& name) const in PostDelayedTask()
399 bool PostDelayedTask(const Task& task, uint32_t delayTime, const std::string& name) const in PostDelayedTask()
[all …]
|
| /foundation/resourceschedule/ffrt/src/sync/ |
| D | wait_queue.cpp | 31 void WaitQueue::ThreadWait(WaitUntilEntry* wn, mutexPrivate* lk, bool legacyMode, CPUEUTask* task) in ThreadWait()
49 const TimePoint& tp, bool legacyMode, CPUEUTask* task) in ThreadWaitUntil()
83 CPUEUTask* task = ctx->task; in SuspendAndWait() local
91 CoWait([&](CPUEUTask* task) -> bool { in SuspendAndWait()
129 CPUEUTask* task = ctx->task; in SuspendAndWaitUntil() local
138 ffrt::CPUEUTask* task = wue->task; in SuspendAndWaitUntil() local
146 CoWait([&](CPUEUTask* task) -> bool { in SuspendAndWaitUntil()
212 CPUEUTask* task = we->task; in Notify() local
|
| D | mutex.cpp | 40 …uint64_t task = ExecuteCtx::Cur()->task ? reinterpret_cast<uint64_t>(ExecuteCtx::Cur()->task) : Ge… in try_lock() local
51 uint64_t task; in lock() local
82 auto task = ctx->task; in try_lock() local
133 auto task = ctx->task; in lock() local
167 auto task = ctx->task; in unlock() local
219 auto task = ctx->task; in wait() local
237 CoWait([this](CPUEUTask* task) -> bool { in wait()
263 CPUEUTask* task = we->task; in wake() local
|
| /foundation/window/window_manager/wmserver/src/ |
| D | window_manager_service.cpp | 92 rsUiDirector_->SetUITaskRunner([this](const std::function<void()>& task, uint32_t delay) { in __anon9d33a92d0402()
126 void WindowManagerService::PostAsyncTask(Task task, const std::string& taskName, uint32_t delay) in PostAsyncTask()
136 void WindowManagerService::PostVoidSyncTask(Task task, const std::string& taskName) in PostVoidSyncTask()
184 auto task = [this, accountId]() { in OnAccountSwitched() local
195 auto task = [this, weak]() { in WindowVisibilityChangeCallback() local
328 auto task = [this, fd, &args]() { in Dump() local
801 auto task = [this, fromInfo, toInfo]() mutable { in NotifyWindowTransition() local
808 auto task = [this, &fromInfo, &toInfo]() { in NotifyWindowTransition() local
817 auto task = [this, info]() mutable { in NotifyAnimationAbilityDied() local
825 auto task = [this, &abilityToken]() { in GetFocusWindowInfo() local
[all …]
|
| /foundation/arkui/ace_engine/frameworks/core/components/text_field/ |
| D | on_text_changed_listener_impl.cpp | 30 auto task = [textField = field_, text] { in InsertText() local
69 auto task = [textField = field_, length] { in DeleteForward() local
93 auto task = [textField = field_, &leftResult, number] { in GetLeftTextOfCursor() local
107 auto task = [textField = field_, &rightResult, number] { in GetRightTextOfCursor() local
121 auto task = [textField = field_, &index] { in GetTextIndexAtCursor() local
139 auto task = [textField = field_, length] { in DeleteBackward() local
162 auto task = [textField = field_, status] { in SetKeyboardStatus() local
192 auto task = [textField = field_, functionKey] { in HandleFunctionKey() local
218 auto task = [textField = field_, direction] { in MoveCursor() local
247 auto task = [textField = field_, start, end] { in HandleSetSelection() local
[all …]
|
| /foundation/arkui/ace_engine/frameworks/core/components_ng/pattern/text_field/ |
| D | on_text_changed_listener_impl.cpp | 40 auto task = [textFieldPattern = pattern_, text] { in InsertText() local
58 auto task = [textFieldPattern = pattern_, length] { in DeleteBackward() local
75 auto task = [textFieldPattern = pattern_, length] { in DeleteForward() local
87 auto task = [textField = pattern_, status] { in SetKeyboardStatus() local
100 auto task = [textField = pattern_, &leftResult, number] { in GetLeftTextOfCursor() local
114 auto task = [textField = pattern_, &rightResult, number] { in GetRightTextOfCursor() local
128 auto task = [textField = pattern_, &index] { in GetTextIndexAtCursor() local
150 auto task = [textField = pattern_, height] { in NotifyKeyboardHeight() local
174 auto task = [textField = pattern_, functionKey] { in HandleFunctionKey() local
200 auto task = [textField = pattern_, direction] { in MoveCursor() local
[all …]
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/src/ |
| D | task_executor_adapter.cpp | 18 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Execute(const TaskExecutorAdapter::Task &task) in Execute()
22 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Execute(const TaskExecutorAdapter::Task &task, in Execute()
27 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Schedule(const TaskExecutorAdapter::Task &task, in Schedule()
32 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Schedule(const TaskExecutorAdapter::Task &task, in Schedule()
37 TaskExecutorAdapter::TaskId TaskExecutorAdapter::Schedule(const TaskExecutorAdapter::Task &task, in Schedule()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/app/src/ |
| D | task_manager.cpp | 26 TaskManager::TaskId TaskManager::Execute(const Task &task) in Execute()
30 TaskManager::TaskId TaskManager::Execute(const Task &task, Duration delay) in Execute()
34 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration interval) in Schedule()
38 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval) in Schedule()
42 TaskManager::TaskId TaskManager::Schedule(const Task &task, Duration delay, Duration interval, uint… in Schedule()
|
| /foundation/resourceschedule/ffrt/src/sched/ |
| D | sched_deadline.cpp | 33 void Begin(CPUEUTask* task) in Begin()
39 void End(CPUEUTask* task) in End()
47 uint64_t GetLoad(CPUEUTask* task) in GetLoad()
|
| /foundation/distributeddatamgr/relational_store/frameworks/native/rdb/mock/include/ |
| D | task_executor.h | 38 TaskId Execute(Task task) in Execute()
43 TaskId Schedule(Duration delay, Task task) in Schedule()
48 TaskId Schedule(Task task, Duration interval) in Schedule()
53 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule()
58 TaskId Schedule(Task task, Duration delay, Duration interval, uint64_t times) in Schedule()
|
| /foundation/multimedia/player_framework/services/services/recorder/server/ |
| D | recorder_server.cpp | 84 auto task = std::make_shared<TaskHandler<void>>([&, this] { in ~RecorderServer() local
105 auto task = std::make_shared<TaskHandler<MediaServiceErrCode>>([&, this] { in Init() local
173 auto task = std::make_shared<TaskHandler<int32_t>>([&, this] { in SetVideoSource() local
192 auto task = std::make_shared<TaskHandler<int32_t>>([&, this] { in SetVideoEncoder() local
212 auto task = std::make_shared<TaskHandler<int32_t>>([&, this] { in SetVideoSize() local
231 auto task = std::make_shared<TaskHandler<int32_t>>([&, this] { in SetVideoFrameRate() local
250 auto task = std::make_shared<TaskHandler<int32_t>>([&, this] { in SetVideoEncodingBitRate() local
269 auto task = std::make_shared<TaskHandler<int32_t>>([&, this] { in SetVideoIsHdr() local
288 auto task = std::make_shared<TaskHandler<int32_t>>([&, this] { in SetVideoEnableTemporalScale() local
308 auto task = std::make_shared<TaskHandler<int32_t>>([&, this] { in SetMetaSource() local
[all …]
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
| D | sys_epoll.c | 23 int32_t RefreshEpollTask(EpollTask *task, uint32_t events) in RefreshEpollTask()
40 int32_t RegisterEpollTask(EpollTask *task, uint32_t events) in RegisterEpollTask()
55 int32_t DeRegisterEpollTask(EpollTask *task) in DeRegisterEpollTask()
76 EpollTask *task = NULL; in EpollLoop() local
|
| /foundation/arkui/ace_engine/frameworks/core/pipeline_ng/ |
| D | ui_task_scheduler.cpp | 106 for (auto& task : tasks) { in FlushSyncGeometryNodeTasks() local
177 auto task = node->CreateRenderTask(forceUseMainThread); in FlushRenderTask() local
347 void UITaskScheduler::AddPredictTask(PredictTask&& task) in AddPredictTask()
355 for (const auto& task : tasks) { in FlushPredictTask() local
378 void UITaskScheduler::AddAfterLayoutTask(std::function<void()>&& task, bool isFlushInImplicitAnimat… in AddAfterLayoutTask()
387 void UITaskScheduler::AddPersistAfterLayoutTask(std::function<void()>&& task) in AddPersistAfterLayoutTask()
396 for (const auto& task : tasks) { in FlushAfterLayoutTask() local
409 for (const auto& task : tasks) { in FlushAfterLayoutCallbackInImplicitAnimationTask() local
423 for (const auto& task : persistAfterLayoutTasks_) { in FlushPersistAfterLayoutTask() local
430 void UITaskScheduler::AddAfterRenderTask(std::function<void()>&& task) in AddAfterRenderTask()
[all …]
|
| /foundation/resourceschedule/ffrt/src/util/ |
| D | init.cpp | 37 [] (ffrt::CPUEUTask* task) { in ffrt_init()
41 [] (ffrt::CPUEUTask* task) { in ffrt_init()
50 [] (ffrt::CPUEUTask* task, bool timeOut) -> void {CoWake(task, timeOut);}); in ffrt_init()
|
| /foundation/multimedia/media_library/frameworks/services/media_cloud_enhancement/src/utils/ |
| D | enhancement_thread_manager.cpp | 55 void EnhancementThreadManager::OnProducerCallback(CloudEnhancementThreadTask& task) in OnProducerCallback()
71 CloudEnhancementThreadTask task("", 0, nullptr, 0, false); in DealWithTasks() local
104 void EnhancementThreadManager::ExecSuccessedTask(CloudEnhancementThreadTask& task) in ExecSuccessedTask()
111 void EnhancementThreadManager::ExecFailedTask(CloudEnhancementThreadTask& task) in ExecFailedTask()
|
| /foundation/graphic/graphic_2d/rosen/test/render_service/render_service_base/unittest/common/ |
| D | rs_thread_handler_generic_test.cpp | 62 RSTaskMessage::RSTask task = []() -> void {}; in __anon75add2090102() variable
75 RSTaskMessage::RSTask task = []() -> void {}; in __anon75add2090202() variable
94 RSTaskMessage::RSTask task = []() -> void {}; in __anon75add2090302() variable
113 RSTaskMessage::RSTask task = []() -> void {}; in __anon75add2090402() variable
132 RSTaskMessage::RSTask task = []() -> void {}; in __anon75add2090502() variable
|
| /foundation/distributeddatamgr/pasteboard/framework/framework/ffrt/ |
| D | ffrt_utils.cpp | 21 void FFRTUtils::SubmitTask(const FFRTTask& task) in SubmitTask()
31 for (auto task : tasks) { in SubmitQueueTasks() local
36 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, FFRTQueue& queue) in SubmitDelayTask()
44 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, std::shared_ptr<FFRTQueue> … in SubmitDelayTask()
52 bool FFRTUtils::SubmitTimeoutTask(const FFRTTask& task, uint32_t timeoutMs) in SubmitTimeoutTask()
106 void FFRTTimer::SetTimer(const std::string &timerId, FFRTTask& task) in SetTimer()
117 void FFRTTimer::SetTimer(const std::string &timerId, FFRTTask& task, uint32_t delayMs) in SetTimer()
|
| /foundation/ability/ability_lite/frameworks/ability_lite/src/ |
| D | ability_event_handler.cpp | 46 Task task = std::move(taskQueue_.front()); in Run() local
55 void AbilityEventHandler::PostTask(const Task& task) in PostTask()
69 Task task = [this]() { in PostQuit() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| D | thread_pool_test_stub.cpp | 32 TaskId ThreadPoolTestStub::Execute(const Task &task) in Execute()
68 TaskId ThreadPoolTestStub::Execute(const Task &task, Duration delay) in Execute()
76 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration interval) in Schedule()
81 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval) in Schedule()
86 TaskId ThreadPoolTestStub::Schedule(const Task &task, Duration delay, Duration interval, uint64_t t… in Schedule()
|