| /linux/net/sunrpc/ |
| H A 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 …]
|
| H A D | clnt.c | 53 static void call_start(struct rpc_task *task); 54 static void call_reserve(struct rpc_task *task); 55 static void call_reserveresult(struct rpc_task *task); 56 static void call_allocate(struct rpc_task *task); 57 static void call_encode(struct rpc_task *task); 58 static void call_decode(struct rpc_task *task); 59 static void call_bind(struct rpc_task *task); 60 static void call_bind_status(struct rpc_task *task); 61 static void call_transmit(struct rpc_task *task); 62 static void call_status(struct rpc_task *task); [all …]
|
| H A 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) || RPC_IS_SOFTCONN(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/kernel/livepatch/ |
| H A D | transition.c | 85 struct task_struct *g, *task; 122 for_each_process_thread(g, task) { in klp_complete_transition() 123 WARN_ON_ONCE(test_tsk_thread_flag(task, TIF_PATCH_PENDING)); in klp_complete_transition() 124 task->patch_state = KLP_TRANSITION_IDLE; in klp_complete_transition() 129 task = idle_task(cpu); in klp_complete_transition() 130 WARN_ON_ONCE(test_tsk_thread_flag(task, TIF_PATCH_PENDING)); in klp_complete_transition() 131 task->patch_state = KLP_TRANSITION_IDLE; in klp_complete_transition() 169 * Switch the patched state of the task to the set of functions in the target in klp_cancel_transition() 172 * NOTE: If task is not 'current', the caller must ensure the task i in klp_cancel_transition() 94 struct task_struct *g, *task; klp_complete_transition() local 184 klp_update_patch_state(struct task_struct * task) klp_update_patch_state() argument 263 klp_check_stack(struct task_struct * task,const char ** oldname) klp_check_stack() argument 293 klp_check_and_switch_task(struct task_struct * task,void * arg) klp_check_and_switch_task() argument 314 klp_try_switch_task(struct task_struct * task) klp_try_switch_task() argument 410 struct task_struct *g, *task; klp_send_signals() local 454 struct task_struct *g, *task; klp_try_complete_transition() local 532 struct task_struct *g, *task; klp_start_transition() local 575 struct task_struct *g, *task; klp_init_transition() local 651 struct task_struct *g, *task; klp_reverse_transition() local 730 struct task_struct *g, *task; klp_force_transition() local [all...] |
| /linux/drivers/gpu/drm/exynos/ |
| H A D | exynos_drm_ipp.c | 87 WARN_ON(ipp->task); in exynos_drm_ipp_unregister() 261 struct exynos_drm_ipp_task *task; in exynos_drm_ipp_task_alloc() local 263 task = kzalloc_obj(*task); in exynos_drm_ipp_task_alloc() 264 if (!task) in exynos_drm_ipp_task_alloc() 267 task->dev = ipp->dev; in exynos_drm_ipp_task_alloc() 268 task->ipp = ipp; in exynos_drm_ipp_task_alloc() 271 task->src.rect.w = task->dst.rect.w = UINT_MAX; in exynos_drm_ipp_task_alloc() 272 task->src.rect.h = task->dst.rect.h = UINT_MAX; in exynos_drm_ipp_task_alloc() 273 task->transform.rotation = DRM_MODE_ROTATE_0; in exynos_drm_ipp_task_alloc() 275 DRM_DEV_DEBUG_DRIVER(task->dev, "Allocated task %p\n", task); in exynos_drm_ipp_task_alloc() [all …]
|
| /linux/drivers/md/dm-vdo/indexer/ |
| H A D | radix-sort.c | 45 struct task { struct 60 struct task *end_of_stack; argument 61 struct task insertion_list[256]; 62 struct task stack[]; 72 static inline void insert_key(const struct task task, sort_key_t *next) in insert_key() argument 78 while ((--next >= task.first_key) && in insert_key() 79 (compare(unsorted, next[0], task.offset, task.length) < 0)) in insert_key() 90 static inline void insertion_sort(const struct task task) in insertion_sort() argument 94 for (next = task.first_key + 1; next <= task.last_key; next++) in insertion_sort() 95 insert_key(task, next); in insertion_sort() [all …]
|
| /linux/kernel/bpf/ |
| H A D | task_iter.c | 39 struct task_struct *task; in task_group_seq_get_next() local 46 task = get_pid_task(pid, PIDTYPE_TGID); in task_group_seq_get_next() 47 if (!task) in task_group_seq_get_next() 53 return task; in task_group_seq_get_next() 62 task = get_pid_task(pid, PIDTYPE_PID); in task_group_seq_get_next() 64 return task; in task_group_seq_get_next() 67 task = find_task_by_pid_ns(common->pid_visiting, common->ns); in task_group_seq_get_next() 68 if (!task) in task_group_seq_get_next() 72 task = __next_thread(task); in task_group_seq_get_next() 73 if (!task) in task_group_seq_get_next() [all …]
|
| /linux/tools/testing/selftests/bpf/progs/ |
| H A D | rcu_read_lock.c | 43 struct task_struct *task; in get_cgroup_id() 46 task = bpf_get_current_task_btf(); in get_cgroup_id() 47 if (task->pid != target_pid) in get_cgroup_id() 52 cgroups = task->cgroups; in task_succ() 64 struct task_struct *task, *real_parent; in task_succ() 68 task = bpf_get_current_task_btf(); in task_succ() 69 if (task->pid != target_pid) in task_succ() 74 real_parent = task->real_parent; in task_succ() 93 struct task_struct *task, *real_parent; in two_regions() 96 task in two_regions() 33 struct task_struct *task; get_cgroup_id() local 54 struct task_struct *task, *real_parent; task_succ() local 83 struct task_struct *task, *real_parent; no_lock() local 95 struct task_struct *task, *real_parent; two_regions() local 114 struct task_struct *task, *real_parent; non_sleepable_1() local 130 struct task_struct *task, *real_parent; non_sleepable_2() local 149 struct task_struct *task, *real_parent, *gparent; task_acquire() local 177 struct task_struct *task; miss_lock() local 191 struct task_struct *task; miss_unlock() local 203 struct task_struct *task, *real_parent; non_sleepable_rcu_mismatch() local 221 struct task_struct *task, *real_parent; inproper_sleepable_helper() local 265 struct task_struct *task, *real_parent; nested_rcu_region() local 284 struct task_struct *task, *group_leader; task_trusted_non_rcuptr() local 298 struct task_struct *task, *real_parent; task_untrusted_rcuptr() local 312 struct task_struct *task, *real_parent; cross_rcu_region() local [all...] |
| H A D | task_kfunc_success.c | 23 struct task_struct *bpf_task_acquire___one(struct task_struct *task) __ksym __weak; 39 static int test_acquire_release(struct task_struct *task) in test_acquire_release() argument 57 acquired = bpf_task_acquire(task); in test_acquire_release() 67 int BPF_PROG(test_task_kfunc_flavor_relo, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument 73 acquired = bpf_task_acquire___one(task); in BPF_PROG() 79 acquired = bpf_task_acquire___two(task, &fake_ctx); in BPF_PROG() 97 int BPF_PROG(test_task_kfunc_flavor_relo_not_found, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument 111 int BPF_PROG(test_task_acquire_release_argument, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument 116 return test_acquire_release(task); in BPF_PROG() 120 int BPF_PROG(test_task_acquire_release_current, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument [all …]
|
| H A D | verifier_global_ptr_args.c | 15 __weak int subprog_trusted_task_nullable(struct task_struct *task __arg_trusted __arg_nullable) in subprog_trusted_task_nullable() 17 if (!task) in subprog_trusted_task_nullable() 19 return task->pid + task->tgid; in subprog_trusted_task_nullable() 22 __weak int subprog_trusted_task_nullable_extra_layer(struct task_struct *task __arg_trusted __arg_nullable) in subprog_trusted_task_nullable_extra_layer() 24 return subprog_trusted_task_nullable(task) + subprog_trusted_task_nullable(NULL); in subprog_trusted_task_nullable_extra_layer() 59 __weak int subprog_trusted_task_nonnull(struct task_struct *task __arg_trusted) in subprog_trusted_task_nonnull() 61 return task->pid + task->tgid; in subprog_trusted_task_nonnull() 108 struct task_struct___local *task __arg_truste in subprog_nullable_task_flavor() 157 BPF_PROG(trusted_destroy_fail,struct task_struct * task,u64 clone_flags) BPF_PROG() argument 177 BPF_PROG(trusted_acq_rel,struct task_struct * task,u64 clone_flags) BPF_PROG() argument [all...] |
| /linux/drivers/video/fbdev/ |
| H A 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/arch/powerpc/kernel/ |
| H A D | signal.h | 36 struct task_struct *task); 38 struct task_struct *task); 39 extern unsigned long copy_vsx_from_user(struct task_struct *task, 41 extern unsigned long copy_ckvsx_from_user(struct task_struct *task, 43 unsigned long copy_fpr_to_user(void __user *to, struct task_struct *task); 44 unsigned long copy_ckfpr_to_user(void __user *to, struct task_struct *task); 45 unsigned long copy_fpr_from_user(struct task_struct *task, void __user *from); 46 unsigned long copy_ckfpr_from_user(struct task_struct *task, void __user *from); 48 #define unsafe_copy_fpr_to_user(to, task, label) do { \ argument 49 struct task_struct *__t = task; \ [all …]
|
| /linux/arch/mips/include/asm/ |
| H A 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 syscall_set_nr(struct task_struct *task, in syscall_set_nr() argument 56 task_thread_info(task)->syscall = regs->regs[2] = nr; in syscall_set_nr() 59 static inline void mips_syscall_update_nr(struct task_struct *task, in mips_syscall_update_nr() argument 66 if (mips_syscall_is_indirect(task, regs)) in mips_syscall_update_nr() 67 task_thread_info(task)->syscall = regs->regs[4]; in mips_syscall_update_nr() 69 task_thread_info(task)->syscall = regs->regs[2]; in mips_syscall_update_nr() [all …]
|
| /linux/include/rv/ |
| H A D | ltl_monitor.h | 24 static void ltl_atoms_fetch(struct task_struct *task, struct ltl_monitor *mon); 25 static void ltl_atoms_init(struct task_struct *task, struct ltl_monitor *mon, bool task_creation); 27 static struct ltl_monitor *ltl_get_monitor(struct task_struct *task) in ltl_get_monitor() argument 29 return &task->rv[ltl_monitor_slot].ltl_mon; in ltl_get_monitor() 32 static void ltl_task_init(struct task_struct *task, bool task_creation) in ltl_task_init() argument 34 struct ltl_monitor *mon = ltl_get_monitor(task); in ltl_task_init() 41 ltl_atoms_init(task, mon, task_creation); in ltl_task_init() 42 ltl_atoms_fetch(task, mon); in ltl_task_init() 45 static void handle_task_newtask(void *data, struct task_struct *task, u64 flags) in handle_task_newtask() argument 47 ltl_task_init(task, true); in handle_task_newtask() [all …]
|
| /linux/fs/proc/ |
| H A D | base.c | 208 static int get_task_root(struct task_struct *task, struct path *root) in get_task_root() argument 212 task_lock(task); in get_task_root() 213 if (task->fs) { in get_task_root() 214 get_fs_root(task->fs, root); in get_task_root() 217 task_unlock(task); in get_task_root() 223 struct task_struct *task = get_proc_task(d_inode(dentry)); in proc_cwd_link() local 226 if (task) { in proc_cwd_link() 227 task_lock(task); in proc_cwd_link() 228 if (task->fs) { in proc_cwd_link() 229 get_fs_pwd(task->fs, path); in proc_cwd_link() [all …]
|
| H A 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() 51 task_unlock(task); in seq_show() 52 put_task_struct(task); in seq_show() 89 struct task_struct *task = get_proc_task(inode); in proc_fdinfo_permission() local 91 if (!task) in proc_fdinfo_permission() 94 allowed = ptrace_may_access(task, PTRACE_MODE_READ_FSCREDS); in proc_fdinfo_permission() [all …]
|
| H A 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 …]
|
| /linux/drivers/scsi/pm8001/ |
| H A 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() 104 static void pm80xx_get_tag_opcodes(struct sas_task *task, int *ata_op, in pm80xx_get_tag_opcodes() argument 114 if (!task) in pm80xx_get_tag_opcodes() 117 spin_lock_irqsave(&task->task_state_lock, flags); in pm80xx_get_tag_opcodes() 118 if (unlikely((task->task_state_flags & SAS_TASK_STATE_ABORTED))) in pm80xx_get_tag_opcodes() 120 spin_unlock_irqrestore(&task->task_state_lock, flags); in pm80xx_get_tag_opcodes() 122 if (task->task_proto == SAS_PROTOCOL_STP) { in pm80xx_get_tag_opcodes() 125 qc = task->uldd_task; in pm80xx_get_tag_opcodes() [all …]
|
| /linux/drivers/scsi/isci/ |
| H A 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/include/linux/ |
| H A 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/tools/perf/util/bpf_skel/ |
| H A D | kwork_top.bpf.c | 105 static __always_inline void update_task_info(struct task_struct *task, __u32 cpu) in update_task_info() argument 108 .pid = task->pid, in update_task_info() 114 .tgid = task->tgid, in update_task_info() 115 .is_kthread = task->flags & PF_KTHREAD ? 1 : 0, in update_task_info() 117 BPF_CORE_READ_STR_INTO(&data.comm, task, comm); in update_task_info() 139 static void on_sched_out(struct task_struct *task, __u64 ts, __u32 cpu) in on_sched_out() argument 144 pelem = bpf_task_storage_get(&kwork_top_task_time, task, NULL, 0); in on_sched_out() 152 .pid = task->pid, in on_sched_out() 153 .task_p = (__u64)task, in on_sched_out() 157 update_task_info(task, cpu); in on_sched_out() [all …]
|
| /linux/scripts/gdb/linux/ |
| H A D | tasks.py | 4 # task & thread tools 39 for task in task_lists(): 40 if int(task['pid']) == pid: 41 return task 46 """Find Linux task by PID and return the task_struct variable. 55 task = get_task_by_pid(pid) 56 if task: 57 return task.dereference() 59 raise gdb.GdbError("No task of PID " + str(pid)) 73 for task i 86 get_thread_info(task) global() argument 103 invoke(self, task) global() argument [all...] |
| /linux/arch/riscv/kernel/ |
| H A D | stacktrace.c | 24 #define READ_ONCE_TASK_STACK(task, x) \ argument 28 if ((task) == current) \ 48 void notrace walk_stackframe(struct task_struct *task, struct pt_regs *regs, in walk_stackframe() argument 59 } else if (task == NULL || task == current) { in walk_stackframe() 66 fp = task->thread.s[0]; in walk_stackframe() 67 sp = task->thread.sp; in walk_stackframe() 68 pc = task->thread.ra; in walk_stackframe() 88 fp = READ_ONCE_TASK_STACK(task, frame->fp); in walk_stackframe() 89 pc = READ_ONCE_TASK_STACK(task, frame->ra); in walk_stackframe() 107 void notrace walk_stackframe(struct task_struct *task, in walk_stackframe() argument [all …]
|
| /linux/drivers/scsi/mvsas/ |
| H A D | mv_sas.c | 12 static int mvs_find_tag(struct mvs_info *mvi, struct sas_task *task, u32 *tag) in mvs_find_tag() argument 14 if (task->lldd_task) { in mvs_find_tag() 16 slot = task->lldd_task; in mvs_find_tag() 293 struct sas_task *task = tei->task; in mvs_task_prep_smp() local 295 struct domain_device *dev = task->dev; in mvs_task_prep_smp() 311 sg_req = &task->smp_task.smp_req; in mvs_task_prep_smp() 317 sg_resp = &task->smp_task.smp_resp; in mvs_task_prep_smp() 386 MVS_CHIP_DISP->make_prd(task->scatter, tei->n_elem, buf_prd); in mvs_task_prep_smp() 391 dma_unmap_sg(mvi->dev, &tei->task->smp_task.smp_resp, 1, in mvs_task_prep_smp() 394 dma_unmap_sg(mvi->dev, &tei->task->smp_task.smp_req, 1, in mvs_task_prep_smp() [all …]
|
| /linux/drivers/scsi/aic94xx/ |
| H A D | aic94xx_tmf.c | 214 static int asd_clear_nexus_tag(struct sas_task *task) in asd_clear_nexus_tag() argument 216 struct asd_ha_struct *asd_ha = task->dev->port->ha->lldd_ha; in asd_clear_nexus_tag() 217 struct asd_ascb *tascb = task->lldd_task; in asd_clear_nexus_tag() 221 memcpy(scb->clear_nexus.ssp_task.lun, task->ssp_task.LUN, 8); in asd_clear_nexus_tag() 223 if (task->dev->tproto) in asd_clear_nexus_tag() 225 task->dev->lldd_dev); in asd_clear_nexus_tag() 229 static int asd_clear_nexus_index(struct sas_task *task) in asd_clear_nexus_index() argument 231 struct asd_ha_struct *asd_ha = task->dev->port->ha->lldd_ha; in asd_clear_nexus_index() 232 struct asd_ascb *tascb = task->lldd_task; in asd_clear_nexus_index() 236 if (task->dev->tproto) in asd_clear_nexus_index() [all …]
|