| /kernel/linux/linux-5.10/net/sunrpc/ |
| D | sched.c | 45 static void rpc_release_task(struct rpc_task *task); 61 rpc_task_timeout(const struct rpc_task *task) in rpc_task_timeout() argument 63 unsigned long timeout = READ_ONCE(task->tk_timeout); in rpc_task_timeout() 80 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer() argument 82 if (list_empty(&task->u.tk_wait.timer_list)) in __rpc_disable_timer() 84 task->tk_timeout = 0; in __rpc_disable_timer() 85 list_del(&task->u.tk_wait.timer_list); in __rpc_disable_timer() 106 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task, in __rpc_add_timer() argument 109 task->tk_timeout = timeout; in __rpc_add_timer() 112 list_add(&task->u.tk_wait.timer_list, &queue->timer_list.list); in __rpc_add_timer() [all …]
|
| D | clnt.c | 57 static void call_start(struct rpc_task *task); 58 static void call_reserve(struct rpc_task *task); 59 static void call_reserveresult(struct rpc_task *task); 60 static void call_allocate(struct rpc_task *task); 61 static void call_encode(struct rpc_task *task); 62 static void call_decode(struct rpc_task *task); 63 static void call_bind(struct rpc_task *task); 64 static void call_bind_status(struct rpc_task *task); 65 static void call_transmit(struct rpc_task *task); 66 static void call_status(struct rpc_task *task); [all …]
|
| D | xprt.c | 73 static void xprt_request_init(struct rpc_task *task); 236 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt() argument 238 struct rpc_rqst *req = task->tk_rqstp; in xprt_reserve_xprt() 241 if (task == xprt->snd_task) in xprt_reserve_xprt() 247 xprt->snd_task = task; in xprt_reserve_xprt() 250 trace_xprt_reserve_xprt(xprt, task); in xprt_reserve_xprt() 256 task->tk_status = -EAGAIN; in xprt_reserve_xprt() 257 if (RPC_IS_SOFT(task)) in xprt_reserve_xprt() 258 rpc_sleep_on_timeout(&xprt->sending, task, NULL, in xprt_reserve_xprt() 261 rpc_sleep_on(&xprt->sending, task, NULL); in xprt_reserve_xprt() [all …]
|
| /kernel/linux/linux-5.10/drivers/infiniband/sw/rxe/ |
| D | rxe_task.c | 13 int __rxe_do_task(struct rxe_task *task) in __rxe_do_task() argument 18 while ((ret = task->func(task->arg)) == 0) in __rxe_do_task() 21 task->ret = ret; in __rxe_do_task() 36 struct rxe_task *task = from_tasklet(task, t, tasklet); in rxe_do_task() local 39 spin_lock_irqsave(&task->state_lock, flags); in rxe_do_task() 40 switch (task->state) { in rxe_do_task() 42 task->state = TASK_STATE_BUSY; in rxe_do_task() 43 spin_unlock_irqrestore(&task->state_lock, flags); in rxe_do_task() 47 task->state = TASK_STATE_ARMED; in rxe_do_task() 50 spin_unlock_irqrestore(&task->state_lock, flags); in rxe_do_task() [all …]
|
| /kernel/liteos_a/testsuites/kernel/sample/kernel_base/core/ |
| D | BUILD.gn | 123 "task/It_los_task.c", 124 "task/smoke/It_los_task_045.c", 125 "task/smoke/It_los_task_046.c", 126 "task/smoke/It_los_task_049.c", 127 "task/smoke/It_los_task_081.c", 128 "task/smoke/It_los_task_089.c", 129 "task/smoke/It_los_task_097.c", 130 "task/smoke/It_los_task_099.c", 131 "task/smoke/It_los_task_101.c", 132 "task/smoke/It_los_task_105.c", [all …]
|
| /kernel/linux/linux-5.10/kernel/livepatch/ |
| D | transition.c | 73 struct task_struct *g, *task; in klp_complete_transition() local 110 for_each_process_thread(g, task) { in klp_complete_transition() 111 WARN_ON_ONCE(test_tsk_thread_flag(task, TIF_PATCH_PENDING)); in klp_complete_transition() 112 task->patch_state = KLP_UNDEFINED; in klp_complete_transition() 117 task = idle_task(cpu); in klp_complete_transition() 118 WARN_ON_ONCE(test_tsk_thread_flag(task, TIF_PATCH_PENDING)); in klp_complete_transition() 119 task->patch_state = KLP_UNDEFINED; in klp_complete_transition() 163 void klp_update_patch_state(struct task_struct *task) in klp_update_patch_state() argument 183 if (test_and_clear_tsk_thread_flag(task, TIF_PATCH_PENDING)) in klp_update_patch_state() 184 task->patch_state = READ_ONCE(klp_target_state); in klp_update_patch_state() [all …]
|
| /kernel/linux/linux-5.10/drivers/gpu/drm/exynos/ |
| D | exynos_drm_ipp.c | 85 WARN_ON(ipp->task); in exynos_drm_ipp_unregister() 259 struct exynos_drm_ipp_task *task; in exynos_drm_ipp_task_alloc() local 261 task = kzalloc(sizeof(*task), GFP_KERNEL); in exynos_drm_ipp_task_alloc() 262 if (!task) in exynos_drm_ipp_task_alloc() 265 task->dev = ipp->dev; in exynos_drm_ipp_task_alloc() 266 task->ipp = ipp; in exynos_drm_ipp_task_alloc() 269 task->src.rect.w = task->dst.rect.w = UINT_MAX; in exynos_drm_ipp_task_alloc() 270 task->src.rect.h = task->dst.rect.h = UINT_MAX; in exynos_drm_ipp_task_alloc() 271 task->transform.rotation = DRM_MODE_ROTATE_0; in exynos_drm_ipp_task_alloc() 273 DRM_DEV_DEBUG_DRIVER(task->dev, "Allocated task %pK\n", task); in exynos_drm_ipp_task_alloc() [all …]
|
| /kernel/linux/linux-5.10/drivers/scsi/aic94xx/ |
| D | aic94xx_task.c | 36 static int asd_map_scatterlist(struct sas_task *task, in asd_map_scatterlist() argument 40 struct asd_ascb *ascb = task->lldd_task; in asd_map_scatterlist() 45 if (task->data_dir == DMA_NONE) in asd_map_scatterlist() 48 if (task->num_scatter == 0) { in asd_map_scatterlist() 49 void *p = task->scatter; in asd_map_scatterlist() 51 task->total_xfer_len, in asd_map_scatterlist() 52 task->data_dir); in asd_map_scatterlist() 54 sg_arr[0].size = cpu_to_le32(task->total_xfer_len); in asd_map_scatterlist() 61 if (sas_protocol_ata(task->task_proto)) in asd_map_scatterlist() 62 num_sg = task->num_scatter; in asd_map_scatterlist() [all …]
|
| /kernel/linux/linux-5.10/include/linux/ |
| D | cn_proc.h | 23 void proc_fork_connector(struct task_struct *task); 24 void proc_exec_connector(struct task_struct *task); 25 void proc_id_connector(struct task_struct *task, int which_id); 26 void proc_sid_connector(struct task_struct *task); 27 void proc_ptrace_connector(struct task_struct *task, int which_id); 28 void proc_comm_connector(struct task_struct *task); 29 void proc_coredump_connector(struct task_struct *task); 30 void proc_exit_connector(struct task_struct *task); 32 static inline void proc_fork_connector(struct task_struct *task) in proc_fork_connector() argument 35 static inline void proc_exec_connector(struct task_struct *task) in proc_exec_connector() argument [all …]
|
| /kernel/linux/linux-5.10/drivers/scsi/pm8001/ |
| D | pm8001_sas.c | 49 static int pm8001_find_tag(struct sas_task *task, u32 *tag) in pm8001_find_tag() argument 51 if (task->lldd_task) { in pm8001_find_tag() 53 ccb = task->lldd_task; in pm8001_find_tag() 304 u32 pm8001_get_ncq_tag(struct sas_task *task, u32 *tag) in pm8001_get_ncq_tag() argument 306 struct ata_queued_cmd *qc = task->uldd_task; in pm8001_get_ncq_tag() 380 static int pm8001_task_exec(struct sas_task *task, in pm8001_task_exec() argument 383 struct domain_device *dev = task->dev; in pm8001_task_exec() 387 struct sas_task *t = task; in pm8001_task_exec() 401 pm8001_ha = pm8001_find_ha_by_dev(task->dev); in pm8001_task_exec() 456 ccb->task = t; in pm8001_task_exec() [all …]
|
| /kernel/linux/linux-5.10/drivers/video/fbdev/ |
| D | uvesafb.c | 75 struct uvesafb_ktask *task; in uvesafb_cn_callback() local 84 task = uvfb_tasks[msg->seq]; in uvesafb_cn_callback() 86 if (!task || msg->ack != task->ack) { in uvesafb_cn_callback() 94 if (task->t.buf_len < utask->buf_len || in uvesafb_cn_callback() 103 memcpy(&task->t, utask, sizeof(*utask)); in uvesafb_cn_callback() 105 if (task->t.buf_len && task->buf) in uvesafb_cn_callback() 106 memcpy(task->buf, utask + 1, task->t.buf_len); in uvesafb_cn_callback() 108 complete(task->done); in uvesafb_cn_callback() 144 static int uvesafb_exec(struct uvesafb_ktask *task) in uvesafb_exec() argument 149 int len = sizeof(task->t) + task->t.buf_len; in uvesafb_exec() [all …]
|
| /kernel/liteos_a/testsuites/kernel/sample/kernel_base/core/task/full/ |
| D | It_los_task_timeslice_003.c | 121 TSK_INIT_PARAM_S task; in Testcase() local 123 task.pfnTaskEntry = (TSK_ENTRY_FUNC)TaskF01; in Testcase() 124 task.pcName = "TimesTsk003A"; in Testcase() 126 task.uwStackSize = TASK_STACK_SIZE_TEST * 2; in Testcase() 127 task.usTaskPrio = TASK_PRIO_TEST_TASK - 1; in Testcase() 128 task.uwResved = LOS_TASK_STATUS_DETACHED; in Testcase() 130 task.usCpuAffiMask = CPUID_TO_AFFI_MASK(ArchCurrCpuid()); in Testcase() 133 ret = LOS_TaskCreate(&g_testTaskID01, &task); in Testcase() 136 task.pfnTaskEntry = (TSK_ENTRY_FUNC)TaskF02; in Testcase() 137 task.pcName = "TimesTsk003B"; in Testcase() [all …]
|
| /kernel/linux/linux-5.10/drivers/scsi/isci/ |
| D | task.c | 76 static void isci_task_refuse(struct isci_host *ihost, struct sas_task *task, in isci_task_refuse() argument 85 __func__, task, response, status); in isci_task_refuse() 87 spin_lock_irqsave(&task->task_state_lock, flags); in isci_task_refuse() 89 task->task_status.resp = response; in isci_task_refuse() 90 task->task_status.stat = status; in isci_task_refuse() 93 task->task_state_flags |= SAS_TASK_STATE_DONE; in isci_task_refuse() 94 task->task_state_flags &= ~(SAS_TASK_AT_INITIATOR | in isci_task_refuse() 96 task->lldd_task = NULL; in isci_task_refuse() 97 spin_unlock_irqrestore(&task->task_state_lock, flags); in isci_task_refuse() 99 task->task_done(task); in isci_task_refuse() [all …]
|
| /kernel/liteos_m/components/signal/ |
| D | los_signal.c | 45 LosTaskCB *task = OsCurrTaskGet(); in OsSignalTaskContextRestore() local 46 OsSigCB *sigCB = (OsSigCB *)task->sig; in OsSignalTaskContextRestore() 112 STATIC VOID SignalHandle(LosTaskCB *task, BOOL cleanStatus) in SignalHandle() argument 118 sigCB = task->sig; in SignalHandle() 139 task->taskStatus &= ~OS_TASK_FLAG_SIGNAL; in SignalHandle() 148 LosTaskCB *task = OsCurrTaskGet(); in SignalEntry() local 149 OsSigCB *sigCB = (OsSigCB *)task->sig; in SignalEntry() 151 SignalHandle(task, FALSE); in SignalEntry() 153 task->stackPointer = sigCB->sigSaveSP; in SignalEntry() 155 sigCB->sigRestoreSP = task->stackPointer; in SignalEntry() [all …]
|
| /kernel/linux/linux-5.10/drivers/gpu/drm/lima/ |
| D | lima_sched.c | 111 int lima_sched_task_init(struct lima_sched_task *task, in lima_sched_task_init() argument 118 task->bos = kmemdup(bos, sizeof(*bos) * num_bos, GFP_KERNEL); in lima_sched_task_init() 119 if (!task->bos) in lima_sched_task_init() 125 err = drm_sched_job_init(&task->base, &context->base, vm); in lima_sched_task_init() 127 kfree(task->bos); in lima_sched_task_init() 131 task->num_bos = num_bos; in lima_sched_task_init() 132 task->vm = lima_vm_get(vm); in lima_sched_task_init() 134 xa_init_flags(&task->deps, XA_FLAGS_ALLOC); in lima_sched_task_init() 139 void lima_sched_task_fini(struct lima_sched_task *task) in lima_sched_task_fini() argument 145 drm_sched_job_cleanup(&task->base); in lima_sched_task_fini() [all …]
|
| /kernel/linux/linux-5.10/scripts/gdb/linux/ |
| D | tasks.py | 43 for task in task_lists(): 44 if int(task['pid']) == pid: 45 return task 59 task = get_task_by_pid(pid) 60 if task: 61 return task.dereference() 77 for task in task_lists(): 79 task.format_string().split()[0], 80 task["pid"].format_string(), 81 task["comm"].string())) [all …]
|
| /kernel/linux/linux-5.10/arch/mips/include/asm/ |
| D | syscall.h | 29 static inline bool mips_syscall_is_indirect(struct task_struct *task, in mips_syscall_is_indirect() argument 34 test_tsk_thread_flag(task, TIF_32BIT_REGS)) && in mips_syscall_is_indirect() 38 static inline long syscall_get_nr(struct task_struct *task, in syscall_get_nr() argument 44 static inline void mips_syscall_update_nr(struct task_struct *task, in mips_syscall_update_nr() argument 51 if (mips_syscall_is_indirect(task, regs)) in mips_syscall_update_nr() 52 task_thread_info(task)->syscall = regs->regs[4]; in mips_syscall_update_nr() 54 task_thread_info(task)->syscall = regs->regs[2]; in mips_syscall_update_nr() 58 struct task_struct *task, struct pt_regs *regs, unsigned int n) in mips_get_syscall_arg() argument 77 if (test_tsk_thread_flag(task, TIF_32BIT_REGS)) in mips_get_syscall_arg() 93 static inline long syscall_get_error(struct task_struct *task, in syscall_get_error() argument [all …]
|
| /kernel/linux/linux-5.10/kernel/bpf/ |
| D | task_iter.c | 28 struct task_struct *task = NULL; in task_seq_get_next() local 36 task = get_pid_task(pid, PIDTYPE_PID); in task_seq_get_next() 37 if (!task) { in task_seq_get_next() 40 } else if (skip_if_dup_files && task->tgid != task->pid && in task_seq_get_next() 41 task->files == task->group_leader->files) { in task_seq_get_next() 42 put_task_struct(task); in task_seq_get_next() 43 task = NULL; in task_seq_get_next() 50 return task; in task_seq_get_next() 56 struct task_struct *task; in task_seq_start() local 58 task = task_seq_get_next(info->common.ns, &info->tid, false); in task_seq_start() [all …]
|
| /kernel/linux/linux-5.10/drivers/scsi/ |
| D | libiscsi.c | 134 void iscsi_prep_data_out_pdu(struct iscsi_task *task, struct iscsi_r2t_info *r2t, in iscsi_prep_data_out_pdu() argument 137 struct iscsi_conn *conn = task->conn; in iscsi_prep_data_out_pdu() 140 task->hdr_len = sizeof(struct iscsi_data); in iscsi_prep_data_out_pdu() 147 hdr->lun = task->lun; in iscsi_prep_data_out_pdu() 148 hdr->itt = task->hdr_itt; in iscsi_prep_data_out_pdu() 164 static int iscsi_add_hdr(struct iscsi_task *task, unsigned len) in iscsi_add_hdr() argument 166 unsigned exp_len = task->hdr_len + len; in iscsi_add_hdr() 168 if (exp_len > task->hdr_max) { in iscsi_add_hdr() 174 task->hdr_len = exp_len; in iscsi_add_hdr() 181 static int iscsi_prep_ecdb_ahs(struct iscsi_task *task) in iscsi_prep_ecdb_ahs() argument [all …]
|
| /kernel/linux/linux-5.10/kernel/ |
| D | task_work.c | 32 int task_work_add(struct task_struct *task, struct callback_head *work, in task_work_add() argument 38 head = READ_ONCE(task->task_works); in task_work_add() 42 } while (cmpxchg(&task->task_works, head, work) != head); in task_work_add() 48 set_notify_resume(task); in task_work_add() 51 set_notify_signal(task); in task_work_add() 70 task_work_cancel_match(struct task_struct *task, in task_work_cancel_match() argument 74 struct callback_head **pprev = &task->task_works; in task_work_cancel_match() 78 if (likely(!task->task_works)) in task_work_cancel_match() 86 raw_spin_lock_irqsave(&task->pi_lock, flags); in task_work_cancel_match() 93 raw_spin_unlock_irqrestore(&task->pi_lock, flags); in task_work_cancel_match() [all …]
|
| /kernel/linux/linux-5.10/mm/ |
| D | lowmem_dbg.c | 43 struct task_struct *task = NULL; in tasks_dump() local 52 task = find_lock_task_mm(p); in tasks_dump() 53 if (!task) { in tasks_dump() 62 tsk_oom_adj = task->signal->oom_score_adj; in tasks_dump() 65 (get_mm_rss(task->mm) < LMK_PRT_TSK_RSS)) { in tasks_dump() 66 task_unlock(task); in tasks_dump() 70 tsk_nr_ptes = mm_pgtables_bytes(task->mm); in tasks_dump() 72 frozen_mark = frozen(task) ? '*' : ' '; in tasks_dump() 75 task->pid, from_kuid(&init_user_ns, task_uid(task)), in tasks_dump() 76 task->tgid, task->mm->total_vm, get_mm_rss(task->mm), in tasks_dump() [all …]
|
| /kernel/liteos_a/testsuites/kernel/sample/kernel_base/core/task/smp/ |
| D | It_smp_los_task_024.c | 73 TSK_INIT_PARAM_S task; in Testcase() local 83 ret = memset_s(&task, sizeof(TSK_INIT_PARAM_S), 0, sizeof(TSK_INIT_PARAM_S)); in Testcase() 85 task.pfnTaskEntry = (TSK_ENTRY_FUNC)ItTimeslice001F01; in Testcase() 86 task.usTaskPrio = TASK_PRIO_TEST_TASK + 1; in Testcase() 87 task.pcName = "it_timeslice_001_f01"; in Testcase() 88 task.uwStackSize = LOS_TASK_MIN_STACK_SIZE; in Testcase() 89 task.uwResved = LOS_TASK_STATUS_DETACHED; in Testcase() 90 task.processID = LOS_GetCurrProcessID(); in Testcase() 92 ret = LOS_TaskCreateOnly(&g_itTestTaskID01, &task); in Testcase() 96 task.pfnTaskEntry = (TSK_ENTRY_FUNC)ItTimeslice001F02; in Testcase() [all …]
|
| /kernel/liteos_a/testsuites/kernel/sample/kernel_base/core/task/smoke/ |
| D | It_los_task_timeslice_001.c | 70 TSK_INIT_PARAM_S task = { 0 }; in Testcase() local 72 task.pfnTaskEntry = (TSK_ENTRY_FUNC)TaskF01; in Testcase() 73 task.pcName = "TimesTsk001A"; in Testcase() 75 task.uwStackSize = TASK_STACK_SIZE_TEST * 2; in Testcase() 76 task.usTaskPrio = TASK_PRIO_TEST_TASK - 1; in Testcase() 77 task.uwResved = LOS_TASK_STATUS_DETACHED; in Testcase() 79 task.usCpuAffiMask = CPUID_TO_AFFI_MASK(ArchCurrCpuid()); in Testcase() 82 ret = LOS_TaskCreate(&g_testTaskID01, &task); in Testcase() 85 task.pfnTaskEntry = (TSK_ENTRY_FUNC)TaskF02; in Testcase() 86 task.pcName = "TimesTsk001B"; in Testcase() [all …]
|
| /kernel/linux/linux-5.10/fs/proc/ |
| D | base.c | 181 static int get_task_root(struct task_struct *task, struct path *root) in get_task_root() argument 185 task_lock(task); in get_task_root() 186 if (task->fs) { in get_task_root() 187 get_fs_root(task->fs, root); in get_task_root() 190 task_unlock(task); in get_task_root() 196 struct task_struct *task = get_proc_task(d_inode(dentry)); in proc_cwd_link() local 199 if (task) { in proc_cwd_link() 200 task_lock(task); in proc_cwd_link() 201 if (task->fs) { in proc_cwd_link() 202 get_fs_pwd(task->fs, path); in proc_cwd_link() [all …]
|
| D | namespaces.c | 47 struct task_struct *task; in proc_ns_get_link() local 54 task = get_proc_task(inode); in proc_ns_get_link() 55 if (!task) in proc_ns_get_link() 58 if (!ptrace_may_access(task, PTRACE_MODE_READ_FSCREDS)) in proc_ns_get_link() 61 error = ns_get_path(&ns_path, task, ns_ops); in proc_ns_get_link() 67 put_task_struct(task); in proc_ns_get_link() 75 struct task_struct *task; in proc_ns_readlink() local 79 task = get_proc_task(inode); in proc_ns_readlink() 80 if (!task) in proc_ns_readlink() 83 if (ptrace_may_access(task, PTRACE_MODE_READ_FSCREDS)) { in proc_ns_readlink() [all …]
|