Home
last modified time | relevance | path

Searched refs:task (Results 1 - 20 of 20) sorted by relevance

/drivers/hdf_core/framework/utils/src/
H A Dhdf_message_task.c15 struct HdfMessageTask *task, struct HdfMessage *msg, bool sync, long delay) in HdfMessageTaskSendMessageLater()
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, struc argument
14 HdfMessageTaskSendMessageLater( struct HdfMessageTask *task, struct HdfMessage *msg, bool sync, long delay) HdfMessageTaskSendMessageLater() argument
[all...]
H A Dhdf_task_queue.c119 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 ! in HdfThreadTasker()
[all...]
H A Dhdf_message_looper.c31 struct HdfMessageTask *task = message->target; in HdfMessageLooperStart() local
32 task->DispatchMessage(task, message); in HdfMessageLooperStart()
/drivers/hdf_core/framework/utils/include/
H A Dhdf_message_task.h22 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);
H A Dhdf_task_queue.h35 void HdfTaskEnqueue(struct HdfTaskQueue *queue, struct HdfTaskType *task);
/drivers/peripheral/usb/ddk/host/src/
H A Dddk_uevent_queue.cpp60 int32_t AddTask(const DdkUeventTaskInfo &task);
69 static bool DdkUeventCopyTask(DdkUeventTaskInfo &task, const struct DdkUeventInfo *info) in DdkUeventCopyTask() argument
71 int32_t ret = memcpy_s(task.action, MAX_ACTION_LEN, info->action, strlen(info->action)); in DdkUeventCopyTask()
77 ret = memcpy_s(task.devPath, MAX_DEVPATH_LEN, info->devPath, strlen(info->devPath)); in DdkUeventCopyTask()
83 ret = memcpy_s(task.subSystem, MAX_SUBSYSTEM_LEN, info->subSystem, strlen(info->subSystem)); in DdkUeventCopyTask()
89 ret = memcpy_s(task.devType, MAX_DEVTYPE_LEN, info->devType, strlen(info->devType)); in DdkUeventCopyTask()
95 ret = memcpy_s(task.devNum, MAX_DEVNUM_LEN, info->devNum, strlen(info->devNum)); in DdkUeventCopyTask()
101 ret = memcpy_s(task.busNum, MAX_BUSNUM_LEN, info->busNum, strlen(info->busNum)); in DdkUeventCopyTask()
163 DdkUeventTaskInfo task = taskQueue_.front(); in Init()
166 DdkDispatchUevent(&task); in Init()
193 AddTask(const DdkUeventTaskInfo &task) AddTask() argument
[all...]
/drivers/hdf_core/adapter/uhdf2/host/src/
H A Dhdf_device_thread.c23 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()
H A Ddevhost_service_full.c27 static int32_t DevHostServiceFullDispatchMessage(struct HdfMessageTask *task, struct HdfMessage *msg) 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/hdf_core/adapter/khdf/linux/osal/src/
H A Dosal_thread.c38 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 in OsalThreadStart()
[all...]
/drivers/external_device_manager/services/native/driver_extension/src/
H A Djs_driver_extension_context.cpp76 auto asyncTask = [weak = context_, env, task = napiAsyncTask.get()]() { in OnUpdateDriverState()
81 task->Reject(env, CreateJsError(env, ERROR_CODE_ONE, "Context is released")); in OnUpdateDriverState()
82 delete task; in OnUpdateDriverState()
90 task->Resolve(env, result); in OnUpdateDriverState()
92 task->Reject(env, CreateJsErrorByNativeErr(env, innerErrorCode)); in OnUpdateDriverState()
94 delete task; in OnUpdateDriverState()
/drivers/hdf_core/framework/core/host/src/
H A Dhdf_power_manager.c57 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/src/
H A Ddevhost_service_proxy.c76 struct HdfMessageTask *task = DevmgrServiceFullGetMessageTask(); in DevHostServiceProxyOnRemoteDied() local
77 if (task == NULL) { in DevHostServiceProxyOnRemoteDied()
90 task->SendMessage(task, message, false); in DevHostServiceProxyOnRemoteDied()
H A Ddevmgr_service_full.c84 int32_t DevmgrServiceFullDispatchMessage(struct HdfMessageTask *task, struct HdfMessage *msg) in DevmgrServiceFullDispatchMessage() argument
86 (void)task; in DevmgrServiceFullDispatchMessage()
108 return &fullService->task; in DevmgrServiceFullGetMessageTask()
110 HDF_LOGE("Get message task failed, fullService is null"); in DevmgrServiceFullGetMessageTask()
120 HdfMessageTaskConstruct(&inst->task, &inst->looper, &handler); in DevmgrServiceFullConstruct()
/drivers/hdf_core/adapter/uhdf2/host/include/
H A Ddevhost_service_full.h26 struct HdfMessageTask task; member
H A Dhdf_device_thread.h27 struct HdfMessageTask task; member
/drivers/hdf_core/adapter/uhdf2/manager/include/
H A Ddevmgr_service_full.h26 struct HdfMessageTask task; member
/drivers/hdf_core/framework/core/host/include/
H A Dhdf_power_manager.h27 struct HdfTaskType task; member
/drivers/external_device_manager/frameworks/js/napi/device_manager/
H A Ddevice_manager_middle.cpp59 auto task = [this]() { in DeleteNapiRef() local
60 EDM_LOGE(MODULE_DEV_MGR, "DeleteNapiRef async task is run."); in DeleteNapiRef()
71 if (napi_status::napi_ok != napi_send_event(env, task, napi_eprio_immediate)) { in DeleteNapiRef()
89 auto task = [data, drvExtObj, errMsg]() { in OnConnect() local
90 EDM_LOGE(MODULE_DEV_MGR, "OnConnect async task is run."); in OnConnect()
109 if (napi_status::napi_ok != napi_send_event(data->env, task, napi_eprio_immediate)) { in OnConnect()
130 auto task = [data, errMsg]() { in OnDisconnect() local
131 EDM_LOGE(MODULE_DEV_MGR, "OnDisconnect async task is run."); in OnDisconnect()
160 if (napi_status::napi_ok != napi_send_event(data->env, task, napi_eprio_immediate)) { in OnDisconnect()
/drivers/external_device_manager/services/native/driver_extension_manager/src/device_manager/
H A Detx_device_mgr.cpp408 auto task = []() { in UnLoadSelf() local
426 unloadSelftimerId_ = unloadSelftimer_.Register(task, UNLOAD_SA_TIMER_INTERVAL, true); in UnLoadSelf()
/drivers/peripheral/camera/test/ut/buffer_manager/
H A Dbuffer_manager_utest.cpp252 std::thread task([&bufferPool, &bufferVector] { in HWTEST_F()
259 task.join(); in HWTEST_F()

Completed in 11 milliseconds