/linux-6.6.21/drivers/infiniband/sw/rxe/ |
D | rxe_task.c | 36 static bool __reserve_if_idle(struct rxe_task *task) in __reserve_if_idle() argument 38 WARN_ON(rxe_read(task->qp) <= 0); in __reserve_if_idle() 40 if (task->state == TASK_STATE_IDLE) { in __reserve_if_idle() 41 rxe_get(task->qp); in __reserve_if_idle() 42 task->state = TASK_STATE_BUSY; in __reserve_if_idle() 43 task->num_sched++; in __reserve_if_idle() 47 if (task->state == TASK_STATE_BUSY) in __reserve_if_idle() 48 task->state = TASK_STATE_ARMED; in __reserve_if_idle() 60 static bool __is_done(struct rxe_task *task) in __is_done() argument 62 if (work_pending(&task->work)) in __is_done() [all …]
|
/linux-6.6.21/net/sunrpc/ |
D | sched.c | 45 static void rpc_release_task(struct rpc_task *task); 68 bool rpc_task_set_rpc_status(struct rpc_task *task, int rpc_status) in rpc_task_set_rpc_status() argument 70 if (cmpxchg(&task->tk_rpc_status, 0, rpc_status) == 0) in rpc_task_set_rpc_status() 76 rpc_task_timeout(const struct rpc_task *task) in rpc_task_timeout() argument 78 unsigned long timeout = READ_ONCE(task->tk_timeout); in rpc_task_timeout() 95 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer() argument 97 if (list_empty(&task->u.tk_wait.timer_list)) in __rpc_disable_timer() 99 task->tk_timeout = 0; in __rpc_disable_timer() 100 list_del(&task->u.tk_wait.timer_list); in __rpc_disable_timer() 121 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task, in __rpc_add_timer() argument [all …]
|
D | clnt.c | 58 static void call_start(struct rpc_task *task); 59 static void call_reserve(struct rpc_task *task); 60 static void call_reserveresult(struct rpc_task *task); 61 static void call_allocate(struct rpc_task *task); 62 static void call_encode(struct rpc_task *task); 63 static void call_decode(struct rpc_task *task); 64 static void call_bind(struct rpc_task *task); 65 static void call_bind_status(struct rpc_task *task); 66 static void call_transmit(struct rpc_task *task); 67 static void call_status(struct rpc_task *task); [all …]
|
D | xprt.c | 75 static void xprt_request_init(struct rpc_task *task); 265 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt() argument 267 struct rpc_rqst *req = task->tk_rqstp; in xprt_reserve_xprt() 270 if (task == xprt->snd_task) in xprt_reserve_xprt() 276 xprt->snd_task = task; in xprt_reserve_xprt() 279 trace_xprt_reserve_xprt(xprt, task); in xprt_reserve_xprt() 285 task->tk_status = -EAGAIN; in xprt_reserve_xprt() 286 if (RPC_IS_SOFT(task)) in xprt_reserve_xprt() 287 rpc_sleep_on_timeout(&xprt->sending, task, NULL, in xprt_reserve_xprt() 290 rpc_sleep_on(&xprt->sending, task, NULL); in xprt_reserve_xprt() [all …]
|
/linux-6.6.21/tools/testing/selftests/bpf/progs/ |
D | rcu_read_lock.c | 32 struct task_struct *task; in get_cgroup_id() local 35 task = bpf_get_current_task_btf(); in get_cgroup_id() 36 if (task->pid != target_pid) in get_cgroup_id() 41 cgroups = task->cgroups; in get_cgroup_id() 53 struct task_struct *task, *real_parent; in task_succ() local 57 task = bpf_get_current_task_btf(); in task_succ() 58 if (task->pid != target_pid) in task_succ() 63 real_parent = task->real_parent; in task_succ() 82 struct task_struct *task, *real_parent; in no_lock() local 85 task = bpf_get_current_task_btf(); in no_lock() [all …]
|
D | task_kfunc_failure.c | 19 static struct __tasks_kfunc_map_value *insert_lookup_task(struct task_struct *task) in insert_lookup_task() argument 23 status = tasks_kfunc_map_insert(task); in insert_lookup_task() 27 return tasks_kfunc_map_value_lookup(task); in insert_lookup_task() 32 int BPF_PROG(task_kfunc_acquire_untrusted, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument 37 v = insert_lookup_task(task); in BPF_PROG() 42 acquired = bpf_task_acquire(v->task); in BPF_PROG() 53 int BPF_PROG(task_kfunc_acquire_fp, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument 69 int BPF_PROG(task_kfunc_acquire_unsafe_kretprobe, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument 74 acquired = bpf_task_acquire(task); in BPF_PROG() 84 int BPF_PROG(task_kfunc_acquire_unsafe_kretprobe_rcu, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument [all …]
|
D | task_kfunc_success.c | 22 struct task_struct *bpf_task_acquire___one(struct task_struct *task) __ksym __weak; 38 static int test_acquire_release(struct task_struct *task) in test_acquire_release() argument 56 acquired = bpf_task_acquire(task); in test_acquire_release() 66 int BPF_PROG(test_task_kfunc_flavor_relo, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument 72 acquired = bpf_task_acquire___one(task); in BPF_PROG() 78 acquired = bpf_task_acquire___two(task, &fake_ctx); in BPF_PROG() 96 int BPF_PROG(test_task_kfunc_flavor_relo_not_found, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument 110 int BPF_PROG(test_task_acquire_release_argument, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument 115 return test_acquire_release(task); in BPF_PROG() 119 int BPF_PROG(test_task_acquire_release_current, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument [all …]
|
/linux-6.6.21/kernel/livepatch/ |
D | transition.c | 94 struct task_struct *g, *task; in klp_complete_transition() local 131 for_each_process_thread(g, task) { in klp_complete_transition() 132 WARN_ON_ONCE(test_tsk_thread_flag(task, TIF_PATCH_PENDING)); in klp_complete_transition() 133 task->patch_state = KLP_UNDEFINED; in klp_complete_transition() 138 task = idle_task(cpu); in klp_complete_transition() 139 WARN_ON_ONCE(test_tsk_thread_flag(task, TIF_PATCH_PENDING)); in klp_complete_transition() 140 task->patch_state = KLP_UNDEFINED; in klp_complete_transition() 184 void klp_update_patch_state(struct task_struct *task) in klp_update_patch_state() argument 204 if (test_and_clear_tsk_thread_flag(task, TIF_PATCH_PENDING)) in klp_update_patch_state() 205 task->patch_state = READ_ONCE(klp_target_state); in klp_update_patch_state() [all …]
|
/linux-6.6.21/kernel/bpf/ |
D | task_iter.c | 38 struct task_struct *task, *next_task; in task_group_seq_get_next() local 48 task = get_pid_task(pid, PIDTYPE_TGID); in task_group_seq_get_next() 49 if (!task) in task_group_seq_get_next() 55 return task; in task_group_seq_get_next() 64 task = get_pid_task(pid, PIDTYPE_PID); in task_group_seq_get_next() 66 return task; in task_group_seq_get_next() 73 task = get_pid_task(pid, PIDTYPE_PID); in task_group_seq_get_next() 74 if (!task) in task_group_seq_get_next() 78 if (!pid_alive(task)) { in task_group_seq_get_next() 79 put_task_struct(task); in task_group_seq_get_next() [all …]
|
D | bpf_task_storage.c | 51 struct task_struct *task = owner; in task_storage_ptr() local 53 return &task->bpf_storage; in task_storage_ptr() 57 task_storage_lookup(struct task_struct *task, struct bpf_map *map, in task_storage_lookup() argument 64 rcu_dereference_check(task->bpf_storage, bpf_rcu_lock_held()); in task_storage_lookup() 72 void bpf_task_storage_free(struct task_struct *task) in bpf_task_storage_free() argument 78 local_storage = rcu_dereference(task->bpf_storage); in bpf_task_storage_free() 93 struct task_struct *task; in bpf_pid_task_storage_lookup_elem() local 107 task = pid_task(pid, PIDTYPE_PID); in bpf_pid_task_storage_lookup_elem() 108 if (!task) { in bpf_pid_task_storage_lookup_elem() 114 sdata = task_storage_lookup(task, map, true); in bpf_pid_task_storage_lookup_elem() [all …]
|
/linux-6.6.21/drivers/scsi/libsas/ |
D | sas_scsi_host.c | 37 static void sas_end_task(struct scsi_cmnd *sc, struct sas_task *task) in sas_end_task() argument 39 struct task_status_struct *ts = &task->task_status; in sas_end_task() 78 task->dev->port->ha->sas_ha_name); in sas_end_task() 96 sas_free_task(task); in sas_end_task() 99 static void sas_scsi_task_done(struct sas_task *task) in sas_scsi_task_done() argument 101 struct scsi_cmnd *sc = task->uldd_task; in sas_scsi_task_done() 102 struct domain_device *dev = task->dev; in sas_scsi_task_done() 108 task = NULL; in sas_scsi_task_done() 113 if (unlikely(!task)) { in sas_scsi_task_done() 121 sas_free_task(task); in sas_scsi_task_done() [all …]
|
/linux-6.6.21/drivers/gpu/drm/exynos/ |
D | exynos_drm_ipp.c | 86 WARN_ON(ipp->task); in exynos_drm_ipp_unregister() 260 struct exynos_drm_ipp_task *task; in exynos_drm_ipp_task_alloc() local 262 task = kzalloc(sizeof(*task), GFP_KERNEL); in exynos_drm_ipp_task_alloc() 263 if (!task) in exynos_drm_ipp_task_alloc() 266 task->dev = ipp->dev; in exynos_drm_ipp_task_alloc() 267 task->ipp = ipp; in exynos_drm_ipp_task_alloc() 270 task->src.rect.w = task->dst.rect.w = UINT_MAX; in exynos_drm_ipp_task_alloc() 271 task->src.rect.h = task->dst.rect.h = UINT_MAX; in exynos_drm_ipp_task_alloc() 272 task->transform.rotation = DRM_MODE_ROTATE_0; in exynos_drm_ipp_task_alloc() 274 DRM_DEV_DEBUG_DRIVER(task->dev, "Allocated task %pK\n", task); in exynos_drm_ipp_task_alloc() [all …]
|
/linux-6.6.21/arch/powerpc/kernel/ |
D | signal.h | 39 struct task_struct *task); 41 struct task_struct *task); 42 extern unsigned long copy_vsx_from_user(struct task_struct *task, 44 extern unsigned long copy_ckvsx_from_user(struct task_struct *task, 46 unsigned long copy_fpr_to_user(void __user *to, struct task_struct *task); 47 unsigned long copy_ckfpr_to_user(void __user *to, struct task_struct *task); 48 unsigned long copy_fpr_from_user(struct task_struct *task, void __user *from); 49 unsigned long copy_ckfpr_from_user(struct task_struct *task, void __user *from); 51 #define unsafe_copy_fpr_to_user(to, task, label) do { \ argument 52 struct task_struct *__t = task; \ [all …]
|
/linux-6.6.21/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() 57 sg_arr[0].size = cpu_to_le32(task->total_xfer_len); in asd_map_scatterlist() 64 if (sas_protocol_ata(task->task_proto)) in asd_map_scatterlist() 65 num_sg = task->num_scatter; in asd_map_scatterlist() [all …]
|
/linux-6.6.21/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 …]
|
/linux-6.6.21/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 …]
|
/linux-6.6.21/drivers/scsi/ |
D | libiscsi.c | 146 void iscsi_prep_data_out_pdu(struct iscsi_task *task, struct iscsi_r2t_info *r2t, in iscsi_prep_data_out_pdu() argument 149 struct iscsi_conn *conn = task->conn; in iscsi_prep_data_out_pdu() 152 task->hdr_len = sizeof(struct iscsi_data); in iscsi_prep_data_out_pdu() 159 hdr->lun = task->lun; in iscsi_prep_data_out_pdu() 160 hdr->itt = task->hdr_itt; in iscsi_prep_data_out_pdu() 176 static int iscsi_add_hdr(struct iscsi_task *task, unsigned len) in iscsi_add_hdr() argument 178 unsigned exp_len = task->hdr_len + len; in iscsi_add_hdr() 180 if (exp_len > task->hdr_max) { in iscsi_add_hdr() 186 task->hdr_len = exp_len; in iscsi_add_hdr() 193 static int iscsi_prep_ecdb_ahs(struct iscsi_task *task) in iscsi_prep_ecdb_ahs() argument [all …]
|
/linux-6.6.21/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_STATE_PENDING; in isci_task_refuse() 95 task->lldd_task = NULL; in isci_task_refuse() 96 spin_unlock_irqrestore(&task->task_state_lock, flags); in isci_task_refuse() 98 task->task_done(task); in isci_task_refuse() [all …]
|
/linux-6.6.21/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 41 return task_thread_info(task)->syscall; in syscall_get_nr() 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() [all …]
|
/linux-6.6.21/fs/proc/ |
D | base.c | 173 static int get_task_root(struct task_struct *task, struct path *root) in get_task_root() argument 177 task_lock(task); in get_task_root() 178 if (task->fs) { in get_task_root() 179 get_fs_root(task->fs, root); in get_task_root() 182 task_unlock(task); in get_task_root() 188 struct task_struct *task = get_proc_task(d_inode(dentry)); in proc_cwd_link() local 191 if (task) { in proc_cwd_link() 192 task_lock(task); in proc_cwd_link() 193 if (task->fs) { in proc_cwd_link() 194 get_fs_pwd(task->fs, path); in proc_cwd_link() [all …]
|
D | array.c | 406 static void task_cpus_allowed(struct seq_file *m, struct task_struct *task) in task_cpus_allowed() argument 409 cpumask_pr_args(&task->cpus_mask)); in task_cpus_allowed() 411 cpumask_pr_args(&task->cpus_mask)); in task_cpus_allowed() 414 static inline void task_core_dumping(struct seq_file *m, struct task_struct *task) in task_core_dumping() argument 416 seq_put_decimal_ull(m, "CoreDumping:\t", !!task->signal->core_state); in task_core_dumping() 435 struct task_struct *task) in arch_proc_pid_thread_features() argument 440 struct pid *pid, struct task_struct *task) in proc_pid_status() argument 442 struct mm_struct *mm = get_task_mm(task); in proc_pid_status() 445 proc_task_name(m, task, true); in proc_pid_status() 448 task_state(m, ns, pid, task); in proc_pid_status() [all …]
|
D | fd.c | 28 struct task_struct *task; in seq_show() local 30 task = get_proc_task(m->private); in seq_show() 31 if (!task) in seq_show() 34 task_lock(task); in seq_show() 35 files = task->files; in seq_show() 53 task_unlock(task); in seq_show() 54 put_task_struct(task); in seq_show() 80 struct task_struct *task = get_proc_task(inode); in proc_fdinfo_access_allowed() local 82 if (!task) in proc_fdinfo_access_allowed() 85 allowed = ptrace_may_access(task, PTRACE_MODE_READ_FSCREDS); in proc_fdinfo_access_allowed() [all …]
|
/linux-6.6.21/kernel/ |
D | task_work.c | 42 int task_work_add(struct task_struct *task, struct callback_head *work, in task_work_add() argument 50 head = READ_ONCE(task->task_works); in task_work_add() 55 } while (!try_cmpxchg(&task->task_works, &head, work)); in task_work_add() 61 set_notify_resume(task); in task_work_add() 64 set_notify_signal(task); in task_work_add() 67 __set_notify_signal(task); in task_work_add() 87 task_work_cancel_match(struct task_struct *task, in task_work_cancel_match() argument 91 struct callback_head **pprev = &task->task_works; in task_work_cancel_match() 95 if (likely(!task_work_pending(task))) in task_work_cancel_match() 103 raw_spin_lock_irqsave(&task->pi_lock, flags); in task_work_cancel_match() [all …]
|
/linux-6.6.21/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 …]
|
/linux-6.6.21/drivers/scsi/pm8001/ |
D | pm8001_sas.c | 50 static int pm8001_find_tag(struct sas_task *task, u32 *tag) in pm8001_find_tag() argument 52 if (task->lldd_task) { in pm8001_find_tag() 54 ccb = task->lldd_task; in pm8001_find_tag() 317 u32 pm8001_get_ncq_tag(struct sas_task *task, u32 *tag) in pm8001_get_ncq_tag() argument 319 struct ata_queued_cmd *qc = task->uldd_task; in pm8001_get_ncq_tag() 399 struct sas_task *task = ccb->task; in pm8001_deliver_command() local 400 enum sas_protocol task_proto = task->task_proto; in pm8001_deliver_command() 401 struct sas_tmf_task *tmf = task->tmf; in pm8001_deliver_command() 430 int pm8001_queue_command(struct sas_task *task, gfp_t gfp_flags) in pm8001_queue_command() argument 432 struct task_status_struct *ts = &task->task_status; in pm8001_queue_command() [all …]
|