| /drivers/hdf_core/framework/utils/src/ |
| D | hdf_message_task.c | 15 struct HdfMessageTask *task, struct HdfMessage *msg, bool sync, long delay) in HdfMessageTaskSendMessageLater() argument
19 msg->target = task; in HdfMessageTaskSendMessageLater()
22 if (task->messageHandler != NULL && task->messageHandler->Dispatch != NULL) { in HdfMessageTaskSendMessageLater()
23 int ret = task->messageHandler->Dispatch(task, msg); in HdfMessageTaskSendMessageLater()
28 HdfMessageQueueEnqueue(task->messageQueue, msg, delay); in HdfMessageTaskSendMessageLater()
36 int32_t HdfMessageTaskSendMessage(struct HdfMessageTask *task, struct HdfMessage *msg, bool sync) in HdfMessageTaskSendMessage() argument
38 return HdfMessageTaskSendMessageLater(task, msg, sync, 0); in HdfMessageTaskSendMessage()
41 void HdfMessageTaskDispatchMessage(struct HdfMessageTask *task, struct HdfMessage *msg) in HdfMessageTaskDispatchMessage() argument
43 struct IHdfMessageHandler *handler = task->messageHandler; in HdfMessageTaskDispatchMessage()
45 handler->Dispatch(task, msg); in HdfMessageTaskDispatchMessage()
|
| D | hdf_task_queue.c | 119 void HdfTaskEnqueue(struct HdfTaskQueue *queue, struct HdfTaskType *task) in HdfTaskEnqueue() argument
123 if (queue == NULL || task == NULL) { in HdfTaskEnqueue()
138 DListInsertTail(&task->node, &queue->head); in HdfTaskEnqueue()
154 struct HdfTaskType *task = NULL; in HdfTaskDequeue() local
157 task = DLIST_FIRST_ENTRY(&queue->head, struct HdfTaskType, node); in HdfTaskDequeue()
158 DListRemove(&task->node); in HdfTaskDequeue()
161 return task; in HdfTaskDequeue()
167 struct HdfTaskType *task = NULL; in HdfThreadTasker() local
180 task = HdfTaskDequeue(queue); in HdfThreadTasker()
181 while (task != NULL) { in HdfThreadTasker()
[all …]
|
| D | hdf_message_looper.c | 29 struct HdfMessageTask *task = message->target; in HdfMessageLooperStart() local
30 task->DispatchMessage(task, message); in HdfMessageLooperStart()
|
| /drivers/hdf_core/framework/utils/include/ |
| D | hdf_message_task.h | 22 int32_t (*Dispatch)(struct HdfMessageTask *task, struct HdfMessage *msg);
26 int32_t (*SendMessage)(struct HdfMessageTask *task, struct HdfMessage *msg, bool sync);
27 void (*RemoveMessage)(struct HdfMessageTask *task, struct HdfMessage *msg);
28 void (*SendMessageLater)(struct HdfMessageTask *task, struct HdfMessage *msg, long delay);
29 void (*DispatchMessage)(struct HdfMessageTask *task, struct HdfMessage *msg);
|
| D | hdf_task_queue.h | 35 void HdfTaskEnqueue(struct HdfTaskQueue *queue, struct HdfTaskType *task);
|
| /drivers/hdf_core/adapter/khdf/linux/osal/src/ |
| D | osal_thread.c | 38 struct task_struct *task; member
107 struct task_struct *task = NULL; in OsalThreadStart() local
127 task = kthread_create(osal_thread_entry, wrapper, param->name); in OsalThreadStart()
128 if (IS_ERR(task)) { in OsalThreadStart()
129 ret = PTR_ERR(task); in OsalThreadStart()
134 kthread_bind(task, wrapper->cpu_id); in OsalThreadStart()
136 wake_up_process(task); in OsalThreadStart()
138 if (sched_setscheduler(task, policy, &sched_para)) { in OsalThreadStart()
140 kthread_stop(task); in OsalThreadStart()
145 wrapper->task = task; in OsalThreadStart()
|
| /drivers/hdf_core/adapter/uhdf2/host/src/ |
| D | hdf_device_thread.c | 23 int32_t DeviceThreadMessageHandler(struct HdfMessageTask *task, struct HdfMessage *msg) in DeviceThreadMessageHandler() argument
25 (void)task; in DeviceThreadMessageHandler()
57 struct HdfMessageTask *task = &inst->task; in DeviceThreadAttach() local
66 return task->SendMessage(task, message, true); in DeviceThreadAttach()
87 HdfMessageTaskConstruct(&inst->task, &inst->looper, &handler); in DeviceThreadConstruct()
|
| D | devhost_service_full.c | 27 static int32_t DevHostServiceFullDispatchMessage(struct HdfMessageTask *task, struct HdfMessage *ms… in DevHostServiceFullDispatchMessage() argument
30 HDF_SLIST_CONTAINER_OF(struct HdfMessageTask, task, struct DevHostServiceFull, task); in DevHostServiceFullDispatchMessage()
66 struct HdfMessageTask *task = &inst->task; in DevHostServiceFullOpsDevice() local
75 return task->SendMessage(task, message, true); in DevHostServiceFullOpsDevice()
212 HdfMessageTaskConstruct(&inst->task, &inst->looper, &handler); in DevHostServiceFullConstruct()
|
| /drivers/external_device_manager/services/native/driver_extension/src/ |
| D | js_driver_extension_context.cpp | 71 [weak = context_](NativeEngine& engine, AsyncTask& task, int32_t status) { in OnUpdateDriverState() argument
76 … task.Reject(engine, CreateJsError(engine, ERROR_CODE_ONE, "Context is released")); in OnUpdateDriverState()
82 task.Resolve(engine, engine.CreateUndefined()); in OnUpdateDriverState()
84 task.Reject(engine, CreateJsErrorByNativeErr(engine, innerErrorCode)); in OnUpdateDriverState()
|
| /drivers/hdf_core/adapter/uhdf2/manager/src/ |
| D | devmgr_service_full.c | 84 int32_t DevmgrServiceFullDispatchMessage(struct HdfMessageTask *task, struct HdfMessage *msg) in DevmgrServiceFullDispatchMessage() argument
86 (void)task; in DevmgrServiceFullDispatchMessage()
108 return &fullService->task; in DevmgrServiceFullGetMessageTask()
120 HdfMessageTaskConstruct(&inst->task, &inst->looper, &handler); in DevmgrServiceFullConstruct()
|
| D | devhost_service_proxy.c | 76 struct HdfMessageTask *task = DevmgrServiceFullGetMessageTask(); in DevHostServiceProxyOnRemoteDied() local
77 if (task == NULL) { in DevHostServiceProxyOnRemoteDied()
90 task->SendMessage(task, message, false); in DevHostServiceProxyOnRemoteDied()
|
| /drivers/hdf_core/framework/core/host/src/ |
| D | hdf_power_manager.c | 57 pmRequest = CONTAINER_OF(para, struct HdfPmRequest, task); in PmTaskFunc()
90 pmRequest->task.func = PmTaskFunc; in HdfPmTaskPut()
91 HdfTaskEnqueue(pmTaskQueue->taskQueue, &pmRequest->task); in HdfPmTaskPut()
|
| /drivers/hdf_core/adapter/uhdf2/manager/include/ |
| D | devmgr_service_full.h | 26 struct HdfMessageTask task; member
|
| /drivers/hdf_core/adapter/uhdf2/host/include/ |
| D | devhost_service_full.h | 26 struct HdfMessageTask task; member
|
| D | hdf_device_thread.h | 27 struct HdfMessageTask task; member
|
| /drivers/hdf_core/framework/core/host/include/ |
| D | hdf_power_manager.h | 27 struct HdfTaskType task; member
|
| /drivers/external_device_manager/services/native/driver_extension_manager/src/device_manager/ |
| D | etx_device_mgr.cpp | 449 auto task = []() { in UnLoadSelf() local
461 unloadSelftimerId_ = unloadSelftimer_.Register(task, UNLOAD_SA_TIMER_INTERVAL, true); in UnLoadSelf()
|
| /drivers/peripheral/camera/test/ut/buffer_manager/ |
| D | buffer_manager_utest.cpp | 252 std::thread task([&bufferPool, &bufferVector] { in __anonbce123ec0702() variable
259 task.join();
|