/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() 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 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); 915 struct rpc_task *task; rpc_cancel_tasks() local 1117 rpc_task_release_transport(struct rpc_task * task) rpc_task_release_transport() argument 1131 rpc_task_release_client(struct rpc_task * task) rpc_task_release_client() argument 1165 rpc_task_set_transport(struct rpc_task * task,struct rpc_clnt * clnt) rpc_task_set_transport() argument 1181 rpc_task_set_client(struct rpc_task * task,struct rpc_clnt * clnt) rpc_task_set_client() argument 1199 rpc_task_set_rpc_message(struct rpc_task * task,const struct rpc_message * msg) rpc_task_set_rpc_message() argument 1215 rpc_default_callback(struct rpc_task * task,void * data) rpc_default_callback() argument 1229 struct rpc_task *task; rpc_run_task() local 1258 struct rpc_task *task; rpc_call_sync() local 1295 struct rpc_task *task; rpc_call_async() local 1324 struct rpc_task *task; rpc_run_bc_task() local 1374 rpc_call_start(struct rpc_task * task) rpc_call_start() argument 1674 __rpc_restart_call(struct rpc_task * task,void (* action)(struct rpc_task *)) __rpc_restart_call() argument 1687 rpc_restart_call(struct rpc_task * task) rpc_restart_call() argument 1698 rpc_restart_call_prepare(struct rpc_task * task) rpc_restart_call_prepare() argument 1707 rpc_proc_name(const struct rpc_task * task) rpc_proc_name() argument 1721 __rpc_call_rpcerror(struct rpc_task * task,int tk_status,int rpc_status) __rpc_call_rpcerror() argument 1729 rpc_call_rpcerror(struct rpc_task * task,int status) rpc_call_rpcerror() argument 1741 call_start(struct rpc_task * task) call_start() argument 1765 call_reserve(struct rpc_task * task) call_reserve() argument 1778 call_reserveresult(struct rpc_task * task) call_reserveresult() argument 1813 call_retry_reserve(struct rpc_task * task) call_retry_reserve() argument 1824 call_refresh(struct rpc_task * task) call_refresh() argument 1836 call_refreshresult(struct rpc_task * task) call_refreshresult() argument 1877 call_allocate(struct rpc_task * task) call_allocate() argument 1926 rpc_task_need_encode(struct rpc_task * task) rpc_task_need_encode() argument 1935 rpc_xdr_encode(struct rpc_task * task) rpc_xdr_encode() argument 1961 call_encode(struct rpc_task * task) call_encode() argument 2011 rpc_task_transmitted(struct rpc_task * task) rpc_task_transmitted() argument 2017 rpc_task_handle_transmitted(struct rpc_task * task) rpc_task_handle_transmitted() argument 2027 call_bind(struct rpc_task * task) call_bind() argument 2052 call_bind_status(struct rpc_task * task) call_bind_status() argument 2132 call_connect(struct rpc_task * task) call_connect() argument 2162 call_connect_status(struct rpc_task * task) call_connect_status() argument 2257 call_transmit(struct rpc_task * task) call_transmit() argument 2282 call_transmit_status(struct rpc_task * task) call_transmit_status() argument 2350 call_bc_encode(struct rpc_task * task) call_bc_encode() argument 2361 call_bc_transmit(struct rpc_task * task) call_bc_transmit() argument 2374 call_bc_transmit_status(struct rpc_task * task) call_bc_transmit_status() argument 2433 call_status(struct rpc_task * task) call_status() argument 2508 rpc_check_timeout(struct rpc_task * task) rpc_check_timeout() argument 2570 call_decode(struct rpc_task * task) call_decode() argument 2639 rpc_encode_header(struct rpc_task * task,struct xdr_stream * xdr) rpc_encode_header() argument 2668 rpc_decode_header(struct rpc_task * task,struct xdr_stream * xdr) rpc_decode_header() argument 2832 rpc_null_call_prepare(struct rpc_task * task,void * data) rpc_null_call_prepare() argument 2873 struct rpc_task *task; rpc_ping() local 2898 struct rpc_task *task; rpc_ping_noreply() local 2914 rpc_cb_add_xprt_done(struct rpc_task * task,void * calldata) rpc_cb_add_xprt_done() argument 2949 struct rpc_task *task; rpc_clnt_test_and_add_xprt() local 2989 struct rpc_task *task; rpc_clnt_add_xprt_helper() local 3329 rpc_show_task(const struct rpc_clnt * clnt,const struct rpc_task * task) rpc_show_task() argument 3346 struct rpc_task *task; rpc_show_tasks() local [all...] |
H A D | xprt.c | 75 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/drivers/infiniband/sw/rxe/ |
H A D | rxe_task.c | 25 /* Check if task is idle i.e. not running, not scheduled in 28 * a qp reference to cover the gap from now until the task finishes. 29 * state will move out of busy if task returns a non zero value 32 * over the task. 33 * Context: caller should hold task->lock. 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() [all …]
|
/linux/drivers/scsi/libsas/ |
H A D | sas_scsi_host.c | 36 /* record final status and free the task */ 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() 47 /* task delivered, what happened afterwards? */ in sas_end_task() 77 pr_notice("LLDD:%s sent SAS_PROTO_RESP for an SSP task; please report this\n", 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() [all …]
|
/linux/drivers/gpu/drm/exynos/ |
H A 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/drivers/scsi/aic94xx/ |
H A D | aic94xx_tmf.c | 3 * 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 …]
|
H A 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/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() 58 * same for task_seq_start() to pick up the correct 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() [all …]
|
/linux/include/asm-generic/ |
H A D | syscall.h | 12 * and only when the caller is sure that the task of interest 23 * syscall_get_nr - find what system call a task is executing 24 * @task: task of interest, must be blocked 25 * @regs: task_pt_regs() of @task 27 * If @task is executing a system call or is at system call 29 * If @task is not executing a system call, i.e. it's blocked 36 * It's only valid to call this when @task is known to be blocked. 38 int syscall_get_nr(struct task_struct *task, struct pt_regs *regs); 42 * @task [all...] |
/linux/drivers/media/i2c/ |
H A D | saa711x_regs.h | 77 /* 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/kernel/ |
H A D | task_work.c | 19 * task_work_add - ask the @task to execute @work->func() 20 * @task: the task which should run the callback 22 * @notify: how to notify the targeted task 24 * Queue @work for task_work_run() below and notify the @task if @notify 28 * task and run the task_work, regardless of whether the task is currently 31 * reschedule IPI to force the targeted task to reschedule and run task_work. 33 * task_work be run as soon as possible, just whenever the task enters the 35 * @TWA_RESUME work is run only when the task exit 54 task_work_add(struct task_struct * task,struct callback_head * work,enum task_work_notify_mode notify) task_work_add() argument 122 task_work_cancel_match(struct task_struct * task,bool (* match)(struct callback_head *,void * data),void * data) task_work_cancel_match() argument 169 task_work_cancel_func(struct task_struct * task,task_work_func_t func) task_work_cancel_func() argument 189 task_work_cancel(struct task_struct * task,struct callback_head * cb) task_work_cancel() argument 208 struct task_struct *task = current; task_work_run() local [all...] |
/linux/drivers/scsi/ |
H A D | libiscsi.c | 136 * @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 D | pm8001_sas.c | 46 * 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/drivers/scsi/isci/ |
H A D | task.c | 64 #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/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/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)) 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/kernel/livepatch/ |
H A 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_TRANSITION_IDLE; 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_TRANSITION_IDLE; in klp_complete_transition() 178 * Switch the patched state of the task to the set of functions in the target 181 * NOTE: If task is not 'current', the caller must ensure the task is inactive. 184 void klp_update_patch_state(struct task_struct *task) in klp_update_patch_state() argument [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/tools/testing/selftests/bpf/progs/ |
H A 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 …]
|
/linux/drivers/media/pci/cx18/ |
H A D | cx23418.h | 18 /* Description: This command creates a new instance of a certain task 19 IN[0] - Task ID. This is one of the XPU_CMD_MASK_YYY where XPU is 20 the processor on which the task YYY will be created 21 OUT[0] - Task handle. This handle is passed along with commands to 22 dispatch to the right instance of the task 26 /* Description: This command destroys an instance of a task 27 IN[0] - Task handle. Hanlde of the task to destroy 65 IN[0] - Task handle. Handle of the task 83 IN[0] - Task handle. Handle of the task to start 88 IN[0] - Task handle. Handle of the task to stop [all …]
|
/linux/drivers/video/fbdev/ |
H A D | uvesafb.c | 69 * find the kernel part of the task struct, copy the registers and 70 * the buffer contents and then complete the task. 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() [all …]
|
/linux/fs/proc/ |
H A D | base.c | 114 * in /proc for a task before it execs a suid executable. 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() [all …]
|
/linux/drivers/gpu/drm/lima/ |
H A D | lima_sched.c | 113 int lima_sched_task_init(struct lima_sched_task *task, in lima_sched_task_init() argument 120 task->bos = kmemdup(bos, sizeof(*bos) * num_bos, GFP_KERNEL); in lima_sched_task_init() 121 if (!task->bos) in lima_sched_task_init() 127 err = drm_sched_job_init(&task->base, &context->base, 1, vm); in lima_sched_task_init() 129 kfree(task->bos); in lima_sched_task_init() 133 drm_sched_job_arm(&task->base); in lima_sched_task_init() 135 task->num_bos = num_bos; in lima_sched_task_init() 136 task->vm = lima_vm_get(vm); in lima_sched_task_init() 141 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 …]
|
/linux/drivers/scsi/qedi/ |
H A D | qedi_fw_iscsi.h | 31 * 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 …]
|