| /foundation/communication/netstack/test/unittest/websocket_core_test/ |
| H A D | WebSocketTaskTaskTest.cpp | 64 auto task = session.CreateTask(httpReq); in HWTEST_F() local 76 auto task = session.CreateTask(httpReq); in HWTEST_F() local 88 auto task = session.CreateTask(httpReq); in HWTEST_F() local 111 auto task = session.CreateTask(httpReq); in HWTEST_F() local 131 auto task = session.CreateTask(httpReq); HWTEST_F() local 150 auto task = session.CreateTask(httpReq); HWTEST_F() local 170 auto task = session.CreateTask(httpReq); HWTEST_F() local 192 auto task = session.CreateTask(httpReq); HWTEST_F() local 208 auto task = session.CreateTask(httpReq, UPLOAD, filePath); HWTEST_F() local 223 auto task = session.CreateTask(httpReq, UPLOAD, filePath); HWTEST_F() local 238 auto task = session.CreateTask(httpReq, UPLOAD, filePath); HWTEST_F() local 250 auto task = session.CreateTask(httpReq); HWTEST_F() local 262 auto task = session.CreateTask(httpReq); HWTEST_F() local 279 auto task = session.CreateTask(httpReq, UPLOAD, filePath); HWTEST_F() local 292 auto task = session.CreateTask(httpReq); HWTEST_F() local 306 auto task = session.CreateTask(httpReq); HWTEST_F() local 320 auto task = session.CreateTask(httpReq); HWTEST_F() local 336 auto task = session.CreateTask(httpReq); HWTEST_F() local 351 auto task = session.CreateTask(httpReq, UPLOAD, filePath); HWTEST_F() local 362 auto task = session.CreateTask(httpReq); HWTEST_F() local 375 auto task = session.CreateTask(httpReq); HWTEST_F() local 388 auto task = session.CreateTask(httpReq); HWTEST_F() local 402 auto task = session.CreateTask(httpReq); HWTEST_F() local 417 auto task = session.CreateTask(httpReq); HWTEST_F() local 431 auto task = session.CreateTask(httpReq); HWTEST_F() local 447 auto task = session.CreateTask(httpReq); HWTEST_F() local 467 auto task = session.CreateTask(httpReq); HWTEST_F() local 485 auto task = session.CreateTask(httpReq); HWTEST_F() local 504 auto task = session.CreateTask(httpReq); HWTEST_F() local 524 auto task = session.CreateTask(httpReq); HWTEST_F() local 545 auto task = session.CreateTask(httpReq); HWTEST_F() local 564 auto task = session.CreateTask(httpReq); HWTEST_F() local 581 auto task = session.CreateTask(httpReq); HWTEST_F() local 599 auto task = session.CreateTask(httpReq); HWTEST_F() local 617 auto task = session.CreateTask(httpReq); HWTEST_F() local 633 auto task = session.CreateTask(httpReq); HWTEST_F() local 667 auto task = session.CreateTask(httpReq); HWTEST_F() local 691 auto task = session.CreateTask(httpReq); HWTEST_F() local 720 auto task = session.CreateTask(httpReq); HWTEST_F() local 741 auto task = session.CreateTask(httpReq); HWTEST_F() local 754 auto task = session.CreateTask(httpReq); HWTEST_F() local 766 auto task = session.CreateTask(httpReq); HWTEST_F() local 780 auto task = session.CreateTask(httpReq); HWTEST_F() local 794 auto task = session.CreateTask(httpReq); HWTEST_F() local 808 auto task = session.CreateTask(httpReq); HWTEST_F() local 824 auto task = session.CreateTask(httpReq); HWTEST_F() local 837 auto task = session.CreateTask(httpReq); HWTEST_F() local 862 auto task = session.CreateTask(httpReq); HWTEST_F() local [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/communicator/src/ |
| H A D | softbus_client.cpp | 110 auto task = [type = type_, clientSocket, listener, client = shared_from_this()]() { in OpenConnect() local
|
| /foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | executor_pool.h | 74 TaskId Execute(Task task) in Execute() argument 87 TaskId Schedule(Duration delay, Task task) in Schedule() argument 92 TaskId Schedule(Task task, Duration interval) in Schedule() argument 97 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule() argument 102 TaskId Schedule(Task task, Duratio argument 139 Execute(Task task, TaskId taskId) Execute() argument 202 NextTimer(InnerTask &task) NextTimer() argument [all...] |
| H A D | priority_queue.h | 39 PriorityQueue(const _Tsk &task, TskUpdater updater = nullptr) in PriorityQueue() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | task_pool_impl.cpp | 78 int TaskPoolImpl::Schedule(const Task &task) in Schedule() argument 99 Schedule(const std::string &queueTag, const Task &task) Schedule() argument 165 Task task = genericTasks_.GetTaskAutoLock(); ReapTask() local 187 GetTask(Task &task, TaskQueue *&queue) GetTask() argument 260 Task task = nullptr; TaskWorker() local [all...] |
| H A D | runtime_context_impl.cpp | 262 int RuntimeContextImpl::ScheduleTask(const TaskAction &task) in ScheduleTask() argument 285 ScheduleQueuedTask(const std::string &queueTag, const TaskAction &task) ScheduleQueuedTask() argument [all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/object/ |
| H A D | object_asset_loader.cpp | 76 TransferTask task = { .callback = callback }; in TransferAssetsAsync() local [all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | send_task_scheduler.cpp | 53 SendTask task; in Finalize() local 146 SendTask task = taskGroupByPrio_[lastSchedulePriority_][lastScheduleTarget_].front(); in FinalizeLastScheduleTask() local [all...] |
| /foundation/distributeddatamgr/preferences/frameworks/native/include/ |
| H A D | executor_pool.h | 77 TaskId Execute(Task task) in Execute() argument 91 TaskId Schedule(Duration delay, Task task) in Schedule() argument 96 TaskId Schedule(Task task, Duration interval) in Schedule() argument 101 TaskId Schedule(Task task, Duration delay, Duration interval) in Schedule() argument 106 Schedule(Task task, Duration delay, Duration interval, uint64_t times) Schedule() argument 143 Execute(Task task, TaskId taskId) Execute() argument 206 NextTimer(InnerTask &task) NextTimer() argument [all...] |
| H A D | priority_queue.h | 38 PriorityQueue(const _Tsk &task, TskUpdater updater = nullptr) in PriorityQueue() argument
|
| /foundation/distributedhardware/device_manager/test/commonunittest/ |
| H A D | UTTest_dm_device_state_manager.cpp | 199 std::shared_ptr<NotifyEvent> task = std::make_shared<NotifyEvent>(eventId, deviceId); in HWTEST_F() local 208 std::shared_ptr<NotifyEvent> task = std::make_shared<NotifyEvent>(eventId, deviceId); in HWTEST_F() local
|
| /foundation/distributeddatamgr/relational_store/frameworks/js/napi/common/src/ |
| H A D | js_uv_queue.cpp | 124 void UvQueue::Execute(UvQueue::Task task) in Execute() argument 189 Task *task = static_cast<Task *>(work->data); in DoExecute() local
|
| /foundation/distributedhardware/distributed_screen/services/screenservice/test/unittest/sourceservice/dscreenmgr/1.0/src/ |
| H A D | dscreen_test.cpp | 107 std::shared_ptr<Task> task = nullptr; in HWTEST_F() local 122 std::shared_ptr<Task> task = std::make_shared<Task>(TaskType::TASK_ENABLE, reqId, attrs); in HWTEST_F() local 143 std::shared_ptr<Task> task = std::make_shared<Task>(TaskType::TASK_ENABLE, reqId, attrs); HWTEST_F() local 162 std::shared_ptr<Task> task = std::make_shared<Task>(TaskType::TASK_DISCONNECT, reqId, attrs); HWTEST_F() local 183 std::shared_ptr<Task> task = std::make_shared<Task>(TaskType::TASK_DISCONNECT, reqId, attrs); HWTEST_F() local 203 std::shared_ptr<Task> task = std::make_shared<Task>(TaskType::TASK_DISCONNECT, reqId, attrs); HWTEST_F() local 223 std::shared_ptr<Task> task = std::make_shared<Task>(TaskType::TASK_DISCONNECT, reqId, attrs); HWTEST_F() local 247 std::shared_ptr<Task> task = std::make_shared<Task>(TaskType::TASK_DISCONNECT, reqId, attrs); HWTEST_F() local [all...] |
| /foundation/distributedhardware/distributed_screen/services/screenservice/test/unittest/sourceservice/dscreenmgr/2.0/src/ |
| H A D | dscreen_test.cpp | 76 std::shared_ptr<Task> task = nullptr; in HWTEST_F() local 91 std::shared_ptr<Task> task = std::make_shared<Task>(TaskType::TASK_DISCONNECT, reqId, attrs); in HWTEST_F() local [all...] |
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/transport/ |
| H A D | dh_comm_tool.cpp | 227 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ENABLE, taskParam, nullptr); in ProcessFullCapsRsp() local
|
| /foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/task/src/ |
| H A D | task_test.cpp | 159 std::shared_ptr<Task> task = nullptr; in HWTEST_F() local 173 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, taskParam, nullptr); in HWTEST_F() local 186 auto task = TaskFactory::GetInstance().CreateTask(TaskType::DISABLE, taskParam, nullptr); in HWTEST_F() local 199 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ON_LINE, taskParam, nullptr); in HWTEST_F() local 212 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr); in HWTEST_F() local 225 auto task = TaskFactory::GetInstance().CreateTask(TaskType::UNKNOWN, taskParam, nullptr); HWTEST_F() local 308 auto task = TaskFactory::GetInstance().CreateTask(TaskType::DISABLE, taskParam, nullptr); HWTEST_F() local 322 auto task = TaskFactory::GetInstance().CreateTask(TaskType::ENABLE, taskParam, nullptr); HWTEST_F() local 336 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr); HWTEST_F() local 353 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr); HWTEST_F() local 372 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr); HWTEST_F() local 393 auto task = TaskFactory::GetInstance().CreateTask(TaskType::META_ENABLE, taskParam, nullptr); HWTEST_F() local 401 auto task = TaskFactory::GetInstance().CreateTask(TaskType::OFF_LINE, taskParam, nullptr); HWTEST_F() local [all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_thread.c | 30 void (*task)(void *context); member 54 static void FreeTask(void *task) in FreeTask() argument 61 BtmTask *task = QueueTryDequeue((Queue *)context); in RunTask() local 92 BtmTask *task = QueueTryDequeue(context->queue); RunAllTaskInQueueTask() local [all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/platform/linux/ |
| H A D | thread_linux.c | 88 TaskItem *task = (TaskItem *)QueueTryDequeue(thread->taskQueue); in ThreadStartFunc() local 196 TaskItem *task = (TaskItem *)malloc(sizeof(TaskItem)); in ThreadPostTask() local [all...] |
| /foundation/window/window_manager/window_scene/session/host/src/ |
| H A D | sub_session.cpp | 54 auto task = [weakThis = wptr(this), property]() { in Show() local 81 auto task = [weakThis = wptr(this)]() { in Hide() local
|
| /foundation/window/window_manager/wm/include/ |
| H A D | ressched_report.h | 137 static auto task = []() { in StatusBarDrag() local
|
| /foundation/window/window_manager/wmserver/src/ |
| H A D | input_window_monitor.cpp | 80 auto task = [displayGroupInfo = displayGroupInfo_]() { in UpdateInputWindowByDisplayId() local
|
| /foundation/window/window_manager/wm/src/ |
| H A D | screen_scene.cpp | 60 auto task = [uiContent]() {
in Destroy() local
|
| /foundation/window/window_manager/wmserver/include/ |
| H A D | window_manager_service.h | 174 Return PostSyncTask(SyncTask&& task, const std::string& taskName = "WMSTask") in PostSyncTask() argument
|
| /test/xts/device_attest/services/devattest_ability/src/ |
| H A D | devattest_service.cpp | 121 auto task = []() { in DelayUnloadTask() local
|
| /third_party/ffmpeg/libavcodec/ |
| H A D | frame_thread_encoder.c | 85 Task *task; in worker() local
|