Home
last modified time | relevance | path

Searched full:task (Results 1 – 25 of 2073) sorted by relevance

12345678910>>...83

/linux/net/sunrpc/
H A Dsched.c45 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()
90 * Disable the timer for a given RPC task. Should be called with
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()
[all …]
H A Dclnt.c53 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 Dxprt.c75 static void xprt_request_init(struct rpc_task *task);
258 * @task: task that is requesting access to the transport
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()
[all …]
/linux/tools/testing/selftests/bpf/progs/
H A Dtask_kfunc_failure.c20 static struct __tasks_kfunc_map_value *insert_lookup_task(struct task_struct *task) in insert_lookup_task() argument
24 status = tasks_kfunc_map_insert(task); in insert_lookup_task()
28 return tasks_kfunc_map_value_lookup(task); in insert_lookup_task()
33 int BPF_PROG(task_kfunc_acquire_untrusted, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument
38 v = insert_lookup_task(task); in BPF_PROG()
43 acquired = bpf_task_acquire(v->task); in BPF_PROG()
54 int BPF_PROG(task_kfunc_acquire_fp, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument
70 int BPF_PROG(task_kfunc_acquire_unsafe_kretprobe, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument
75 acquired = bpf_task_acquire(task); in BPF_PROG()
85 int BPF_PROG(task_kfunc_acquire_unsafe_kretprobe_rcu, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument
[all …]
H A Dtask_kfunc_success.c24 struct task_struct *bpf_task_acquire___one(struct task_struct *task) __ksym __weak;
40 static int test_acquire_release(struct task_struct *task) in test_acquire_release() argument
58 acquired = bpf_task_acquire(task); in test_acquire_release()
68 int BPF_PROG(test_task_kfunc_flavor_relo, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument
74 acquired = bpf_task_acquire___one(task); in BPF_PROG()
80 acquired = bpf_task_acquire___two(task, &fake_ctx); in BPF_PROG()
98 int BPF_PROG(test_task_kfunc_flavor_relo_not_found, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument
112 int BPF_PROG(test_task_acquire_release_argument, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument
117 return test_acquire_release(task); in BPF_PROG()
121 int BPF_PROG(test_task_acquire_release_current, struct task_struct *task, u64 clone_flags) in BPF_PROG() argument
[all …]
H A Drcu_read_lock.c43 struct task_struct *task; in get_cgroup_id() local
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 get_cgroup_id()
64 struct task_struct *task, *real_parent; in task_succ() local
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 no_lock() local
96 task = bpf_get_current_task_btf(); in no_lock()
[all …]
/linux/drivers/scsi/libsas/
H A Dsas_scsi_host.c37 /* record final status and free the task */
38 static void sas_end_task(struct scsi_cmnd *sc, struct sas_task *task) in sas_end_task() argument
40 struct task_status_struct *ts = &task->task_status; in sas_end_task()
48 /* task delivered, what happened afterwards? */ in sas_end_task()
78 pr_notice("LLDD:%s sent SAS_PROTO_RESP for an SSP task; please report this\n", in sas_end_task()
79 task->dev->port->ha->sas_ha_name); in sas_end_task()
97 sas_free_task(task); in sas_end_task()
100 static void sas_scsi_task_done(struct sas_task *task) in sas_scsi_task_done() argument
102 struct scsi_cmnd *sc = task->uldd_task; in sas_scsi_task_done()
103 struct domain_device *dev = task->dev; in sas_scsi_task_done()
[all …]
/linux/drivers/scsi/aic94xx/
H A Daic94xx_tmf.c3 * Aic94xx Task Management Functions
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()
[all …]
/linux/kernel/bpf/
H A Dtask_iter.c41 struct task_struct *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()
60 * same for task_seq_start() to pick up the correct 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()
69 task = find_task_by_pid_ns(common->pid_visiting, common->ns); in task_group_seq_get_next()
70 if (!task) in task_group_seq_get_next()
74 task = __next_thread(task); in task_group_seq_get_next()
[all …]
/linux/scripts/gdb/linux/
H A Dtasks.py4 # 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))
72 gdb.write("{:>10} {:>12} {:>7}\n".format("TASK", "PI
86 get_thread_info(task) global() argument
103 invoke(self, task) global() argument
[all...]
/linux/drivers/media/i2c/
H A Dsaa711x_regs.h77 /* Task independent global settings */
87 /* Task A definition */
134 /* Task B definition */
361 /* Task independent global settings: R_80_GLOBAL_CNTL_1 to R_8F_STATUS_INFO_SCALER */
383 /* Task A definition: R_90_A_TASK_HANDLING_CNTL to R_BF_A_VERT_LUMA_PHASE_OFF_11 */
384 /* Task A: Basic settings and acquisition window definition */
386 "Task A: Task handling control"},
388 "Task A: X port formats and configuration"},
390 "Task A: X port input reference signal definition"},
392 "Task A: I port output formats and configuration"},
[all …]
/linux/arch/powerpc/kernel/
H A Dsignal.h36 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/drivers/scsi/isci/
H A Dtask.c64 #include "task.h"
71 * @task: request to complete
72 * @response: response code for the completed task.
73 * @status: status code for the completed task.
76 static void isci_task_refuse(struct isci_host *ihost, struct sas_task *task, in isci_task_refuse() argument
84 dev_dbg(&ihost->pdev->dev, "%s: task = %p, response=%d, status=%d\n", in isci_task_refuse()
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()
[all …]
/linux/drivers/scsi/
H A Dlibiscsi.c136 * @task: scsi command task
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()
[all …]
/linux/drivers/scsi/pm8001/
H A Dpm8001_sas.c46 * pm8001_find_tag - from sas task to find out tag that belongs to this task
47 * @task: the task sent to the LLDD
48 * @tag: the found tag associated with the task
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()
64 * @tag: the found tag associated with the task
80 * pm8001_tag_alloc - allocate a empty tag for task used.
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()
[all …]
/linux/Documentation/scheduler/
H A Dsched-ext.rst20 a runnable task stalls, or on invoking the SysRq key sequence
49 If a task explicitly sets its scheduling policy to ``SCHED_EXT``, it will be
120 the task and the core scheduler silently picked a fallback CPU.
123 * ``SCX_EV_DISPATCH_KEEP_LAST``: a task continued running because no other
124 task was available (only when ``SCX_OPS_ENQ_LAST`` is not set).
125 * ``SCX_EV_ENQ_SKIP_EXITING``: an exiting task was dispatched to the local DSQ
127 * ``SCX_EV_ENQ_SKIP_MIGRATION_DISABLED``: a migration-disabled task was
130 * ``SCX_EV_REENQ_IMMED``: a task dispatched with ``SCX_ENQ_IMMED`` was
133 task running in between; recurring counts indicate that the BPF scheduler
135 * ``SCX_EV_REFILL_SLICE_DFL``: a task's time slice was refilled with the
[all …]
/linux/kernel/livepatch/
H A Dtransition.c85 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/rust/kernel/
H A Dtask.rs33 /// Returns the currently running task.
39 // leave current task context:
47 unsafe { &*$crate::task::Task::current() }
75 /// Getting the current task and storing it in some struct. The reference count is automatically
79 /// use kernel::{task::Task, sync::aref::ARef};
82 /// creator: ARef<Task>,
96 pub struct Task(pub(crate) Opaque<bindings::task_struct>); struct
98 // SAFETY: By design, the only way to access a `Task` i
102 unsafe impl Send for Task {} global() implementation
107 unsafe impl Sync for Task {} global() implementation
142 deref(&self) -> &Task deref() argument
156 impl Task { global() implementation
179 task: *const CurrentTask, current() field
337 group_leader(&self) -> &Task group_leader() argument
350 unsafe impl crate::sync::aref::AlwaysRefCounted for Task { global() implementation
364 impl PartialEq for Task { global() implementation
371 impl Eq for Task {} global() implementation
[all...]
/linux/drivers/scsi/qedi/
H A Dqedi_fw_iscsi.h31 * task context.
33 * @param task_params - Pointer to task parameters struct
37 * @param sgl_task_params - Pointer to SGL task params
49 * Request task context.
51 * @param task_params - Pointer to task parameters struct
53 * @param tx_sgl_task_params - Pointer to SGL task params
54 * @param rx_sgl_task_params - Pointer to SGL task params
62 * task context.
64 * @param task_params - Pointer to task parameters struct
66 * @param tx_sgl_task_params - Pointer to SGL task params
[all …]
/linux/fs/proc/
H A Dnamespaces.c47 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 error = down_read_killable(&task->signal->exec_update_lock); in proc_ns_get_link()
63 if (!ptrace_may_access(task, PTRACE_MODE_READ_FSCREDS)) in proc_ns_get_link()
66 error = ns_get_path(&ns_path, task, ns_ops); in proc_ns_get_link()
72 up_read(&task->signal->exec_update_lock); in proc_ns_get_link()
74 put_task_struct(task); in proc_ns_get_link()
82 struct task_struct *task; in proc_ns_readlink() local
86 task = get_proc_task(inode); in proc_ns_readlink()
[all …]
/linux/tools/perf/util/bpf_skel/
H A Dkwork_top.bpf.c105 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/drivers/scsi/qedf/
H A Ddrv_fcoe_fw_funcs.h29 * @brief init_initiator_rw_fcoe_task - Initializes FCoE task context for
30 * read/write task types and init fcoe_sqe
32 * @param task_params - Pointer to task parameters struct
33 * @param sgl_task_params - Pointer to SGL task params
45 * @brief init_initiator_midpath_fcoe_task - Initializes FCoE task context for
46 * midpath/unsolicited task types and init fcoe_sqe
48 * @param task_params - Pointer to task parameters struct
50 * @param tx_sgl_task_params - Pointer to Tx SGL task params
51 * @param rx_sgl_task_params - Pointer to Rx SGL task params
63 * @brief init_initiator_abort_fcoe_task - Initializes FCoE task context for
[all …]
/linux/arch/s390/include/asm/
H A Dunwind.h14 * There four combinations for task and regs:
15 * 1) task==NULL, regs==NULL: the unwind starts for the task that is currently
17 * 2) task==NULL, regs!=NULL: the unwind starts from the sp/ip found in
18 * the struct pt_regs of an interrupt frame for the current task
19 * 3) task!=NULL, regs==NULL: the unwind starts for an inactive task with
20 * the sp picked up from task->thread.ksp and the ip picked up from the
22 * 4) task!=NULL, regs!=NULL: the sp/ip are picked up from the interrupt
23 * frame 'regs' of a inactive task
37 struct task_struct *task; member
50 ip = ftrace_graph_ret_addr(state->task, &state->graph_idx, ip, (void *)state->sp); in unwind_recover_ret_addr()
[all …]
/linux/arch/arm64/kernel/
H A Dfpsimd.c62 * (a) for each task, we need to remember which CPU was the last one to have
63 * the task's FPSIMD state loaded into its FPSIMD registers;
64 * (b) for each CPU, we need to remember which task's userland FPSIMD state has
71 * address of the userland FPSIMD state of the task that was loaded onto the CPU
77 * task's fpsimd_cpu are still mutually in sync. If this is the case, we
81 * indicate whether or not the userland FPSIMD state of the current task is
84 * task. If the task is behaving as a VMM, then this is will be managed by
91 * called from softirq context, which will save the task's FPSIMD context back
93 * task's FPSIMD state from task context and thereby corrupting the state, it
94 * is necessary to protect any manipulation of a task's fpsimd_state or
[all …]
/linux/arch/mips/include/asm/
H A Dsyscall.h29 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 …]

12345678910>>...83