| /fs/proc/ |
| D | base.c | 171 static int get_task_root(struct task_struct *task, struct path *root) in get_task_root() argument
175 task_lock(task); in get_task_root()
176 if (task->fs) { in get_task_root()
177 get_fs_root(task->fs, root); in get_task_root()
180 task_unlock(task); in get_task_root()
186 struct task_struct *task = get_proc_task(d_inode(dentry)); in proc_cwd_link() local
189 if (task) { in proc_cwd_link()
190 task_lock(task); in proc_cwd_link()
191 if (task->fs) { in proc_cwd_link()
192 get_fs_pwd(task->fs, path); in proc_cwd_link()
[all …]
|
| D | array.c | 381 static void task_cpus_allowed(struct seq_file *m, struct task_struct *task) in task_cpus_allowed() argument
384 cpumask_pr_args(task->cpus_ptr)); in task_cpus_allowed()
386 cpumask_pr_args(task->cpus_ptr)); in task_cpus_allowed()
405 struct pid *pid, struct task_struct *task) in proc_pid_status() argument
407 struct mm_struct *mm = get_task_mm(task); in proc_pid_status()
410 proc_task_name(m, task, true); in proc_pid_status()
413 task_state(m, ns, pid, task); in proc_pid_status()
421 task_sig(m, task); in proc_pid_status()
422 task_cap(m, task); in proc_pid_status()
423 task_seccomp(m, task); in proc_pid_status()
[all …]
|
| D | namespaces.c | 43 struct task_struct *task; in proc_ns_get_link() local
50 task = get_proc_task(inode); in proc_ns_get_link()
51 if (!task) in proc_ns_get_link()
54 if (ptrace_may_access(task, PTRACE_MODE_READ_FSCREDS)) { in proc_ns_get_link()
55 error = ns_get_path(&ns_path, task, ns_ops); in proc_ns_get_link()
59 put_task_struct(task); in proc_ns_get_link()
67 struct task_struct *task; in proc_ns_readlink() local
71 task = get_proc_task(inode); in proc_ns_readlink()
72 if (!task) in proc_ns_readlink()
75 if (ptrace_may_access(task, PTRACE_MODE_READ_FSCREDS)) { in proc_ns_readlink()
[all …]
|
| D | fd.c | 25 struct task_struct *task; in seq_show() local
27 task = get_proc_task(m->private); in seq_show()
28 if (!task) in seq_show()
31 files = get_files_struct(task); in seq_show()
32 put_task_struct(task); in seq_show()
84 static bool tid_fd_mode(struct task_struct *task, unsigned fd, fmode_t *mode) in tid_fd_mode() argument
86 struct files_struct *files = get_files_struct(task); in tid_fd_mode()
101 static void tid_fd_update_inode(struct task_struct *task, struct inode *inode, in tid_fd_update_inode() argument
104 task_dump_owner(task, 0, &inode->i_uid, &inode->i_gid); in tid_fd_update_inode()
114 security_task_to_inode(task, inode); in tid_fd_update_inode()
[all …]
|
| D | proc_net.c | 256 struct task_struct *task; in get_proc_task_net() local
261 task = pid_task(proc_pid(dir), PIDTYPE_PID); in get_proc_task_net()
262 if (task != NULL) { in get_proc_task_net()
263 task_lock(task); in get_proc_task_net()
264 ns = task->nsproxy; in get_proc_task_net()
267 task_unlock(task); in get_proc_task_net()
|
| D | task_nommu.c | 206 priv->task = get_proc_task(priv->inode); in m_start()
207 if (!priv->task) in m_start()
237 if (priv->task) { in m_stop()
238 put_task_struct(priv->task); in m_stop()
239 priv->task = NULL; in m_stop()
|
| D | task_mmu.c | 106 struct task_struct *task = priv->task; in hold_task_mempolicy() local
108 task_lock(task); in hold_task_mempolicy()
109 priv->task_mempolicy = get_task_policy(task); in hold_task_mempolicy()
111 task_unlock(task); in hold_task_mempolicy()
211 priv->task = get_proc_task(priv->inode); in m_start()
212 if (!priv->task) in m_start()
270 if (priv->task) { in m_stop()
271 put_task_struct(priv->task); in m_stop()
272 priv->task = NULL; in m_stop()
926 priv->task = get_proc_task(priv->inode); in show_smaps_rollup()
[all …]
|
| /fs/nfs/filelayout/ |
| D | filelayout.c | 90 struct rpc_task *task = &hdr->task; in filelayout_reset_write() local
95 hdr->task.tk_pid, in filelayout_reset_write()
101 task->tk_status = pnfs_write_done_resend_to_mds(hdr); in filelayout_reset_write()
107 struct rpc_task *task = &hdr->task; in filelayout_reset_read() local
112 hdr->task.tk_pid, in filelayout_reset_read()
118 task->tk_status = pnfs_read_done_resend_to_mds(hdr); in filelayout_reset_read()
122 static int filelayout_async_handle_error(struct rpc_task *task, in filelayout_async_handle_error() argument
132 if (task->tk_status >= 0) in filelayout_async_handle_error()
135 switch (task->tk_status) { in filelayout_async_handle_error()
145 "flags 0x%x\n", __func__, task->tk_status, in filelayout_async_handle_error()
[all …]
|
| /fs/nfs/flexfilelayout/ |
| D | flexfilelayout.c | 35 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
702 nfs4_ff_layout_stat_io_end_read(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_read() argument
710 ktime_get(), task->tk_start); in nfs4_ff_layout_stat_io_end_read()
733 nfs4_ff_layout_stat_io_end_write(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_write() argument
744 requested, completed, ktime_get(), task->tk_start); in nfs4_ff_layout_stat_io_end_write()
1071 struct rpc_task *task = &hdr->task; in ff_layout_reset_write() local
1078 hdr->task.tk_pid, in ff_layout_reset_write()
1091 hdr->task.tk_pid, in ff_layout_reset_write()
1101 task->tk_status = pnfs_write_done_resend_to_mds(hdr); in ff_layout_reset_write()
1107 struct rpc_task *task = &hdr->task; in ff_layout_reset_read() local
[all …]
|
| /fs/nfs/ |
| D | unlink.c | 46 static void nfs_async_unlink_done(struct rpc_task *task, void *calldata) in nfs_async_unlink_done() argument
51 trace_nfs_sillyrename_unlink(data, task->tk_status); in nfs_async_unlink_done()
52 if (!NFS_PROTO(dir)->unlink_done(task, dir)) in nfs_async_unlink_done()
53 rpc_restart_call_prepare(task); in nfs_async_unlink_done()
76 static void nfs_unlink_prepare(struct rpc_task *task, void *calldata) in nfs_unlink_prepare() argument
80 NFS_PROTO(dir)->unlink_rpc_prepare(task, data); in nfs_unlink_prepare()
103 struct rpc_task *task; in nfs_do_call_unlink() local
112 task = rpc_run_task(&task_setup_data); in nfs_do_call_unlink()
113 if (!IS_ERR(task)) in nfs_do_call_unlink()
114 rpc_put_task_async(task); in nfs_do_call_unlink()
[all …]
|
| D | nfs4proc.c | 597 nfs4_async_handle_exception(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_exception() argument
605 rpc_delay(task, nfs4_update_delay(&exception->timeout)); in nfs4_async_handle_exception()
609 rpc_sleep_on(&clp->cl_rpcwaitq, task, NULL); in nfs4_async_handle_exception()
611 rpc_wake_up_queued_task(&clp->cl_rpcwaitq, task); in nfs4_async_handle_exception()
625 rpc_task_release_transport(task); in nfs4_async_handle_exception()
631 nfs4_async_handle_error(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_error() argument
638 if (task->tk_status >= 0) in nfs4_async_handle_error()
642 task->tk_status = nfs4_async_handle_exception(task, server, in nfs4_async_handle_error()
643 task->tk_status, in nfs4_async_handle_error()
709 static int nfs40_sequence_done(struct rpc_task *task, in nfs40_sequence_done() argument
[all …]
|
| D | nfs42proc.c | 385 static void nfs42_offload_cancel_prepare(struct rpc_task *task, void *calldata) in nfs42_offload_cancel_prepare() argument
391 &data->res.osr_seq_res, task); in nfs42_offload_cancel_prepare()
394 static void nfs42_offload_cancel_done(struct rpc_task *task, void *calldata) in nfs42_offload_cancel_done() argument
398 nfs41_sequence_done(task, &data->res.osr_seq_res); in nfs42_offload_cancel_done()
399 if (task->tk_status && in nfs42_offload_cancel_done()
400 nfs4_async_handle_error(task, data->seq_server, NULL, in nfs42_offload_cancel_done()
402 rpc_restart_call_prepare(task); in nfs42_offload_cancel_done()
422 struct rpc_task *task; in nfs42_do_offload_cancel_async() local
452 task = rpc_run_task(&task_setup_data); in nfs42_do_offload_cancel_async()
453 if (IS_ERR(task)) in nfs42_do_offload_cancel_async()
[all …]
|
| D | nfs3proc.c | 48 nfs3_async_handle_jukebox(struct rpc_task *task, struct inode *inode) in nfs3_async_handle_jukebox() argument
50 if (task->tk_status != -EJUKEBOX) in nfs3_async_handle_jukebox()
52 if (task->tk_status == -EJUKEBOX) in nfs3_async_handle_jukebox()
54 task->tk_status = 0; in nfs3_async_handle_jukebox()
55 rpc_restart_call(task); in nfs3_async_handle_jukebox()
56 rpc_delay(task, NFS_JUKEBOX_RETRY_TIME); in nfs3_async_handle_jukebox()
434 static void nfs3_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs3_proc_unlink_rpc_prepare() argument
436 rpc_call_start(task); in nfs3_proc_unlink_rpc_prepare()
440 nfs3_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs3_proc_unlink_done() argument
443 if (nfs3_async_handle_jukebox(task, dir)) in nfs3_proc_unlink_done()
[all …]
|
| D | pagelist.c | 116 nfs_async_iocounter_wait(struct rpc_task *task, struct nfs_lock_context *l_ctx) in nfs_async_iocounter_wait() argument
122 rpc_sleep_on(&NFS_SERVER(inode)->uoc_rpcwaitq, task, NULL); in nfs_async_iocounter_wait()
127 rpc_wake_up_queued_task(&NFS_SERVER(inode)->uoc_rpcwaitq, task); in nfs_async_iocounter_wait()
604 static void nfs_pgio_prepare(struct rpc_task *task, void *calldata) in nfs_pgio_prepare() argument
608 err = NFS_PROTO(hdr->inode)->pgio_rpc_prepare(task, hdr); in nfs_pgio_prepare()
610 rpc_exit(task, err); in nfs_pgio_prepare()
617 struct rpc_task *task; in nfs_initiate_pgio() local
625 .task = &hdr->task, in nfs_initiate_pgio()
643 task = rpc_run_task(&task_setup_data); in nfs_initiate_pgio()
644 if (IS_ERR(task)) { in nfs_initiate_pgio()
[all …]
|
| D | proc.c | 332 static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs_proc_unlink_rpc_prepare() argument
334 rpc_call_start(task); in nfs_proc_unlink_rpc_prepare()
337 static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs_proc_unlink_done() argument
351 static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs_proc_rename_rpc_prepare() argument
353 rpc_call_start(task); in nfs_proc_rename_rpc_prepare()
357 nfs_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs_proc_rename_done() argument
587 static int nfs_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_read_done() argument
592 if (task->tk_status >= 0) { in nfs_read_done()
610 static int nfs_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs_proc_pgio_rpc_prepare() argument
613 rpc_call_start(task); in nfs_proc_pgio_rpc_prepare()
[all …]
|
| D | read.c | 241 static int nfs_readpage_done(struct rpc_task *task, in nfs_readpage_done() argument
245 int status = NFS_PROTO(inode)->read_done(task, hdr); in nfs_readpage_done()
250 trace_nfs_readpage_done(inode, task->tk_status, in nfs_readpage_done()
253 if (task->tk_status == -ESTALE) { in nfs_readpage_done()
260 static void nfs_readpage_retry(struct rpc_task *task, in nfs_readpage_retry() argument
275 if (!task->tk_ops) { in nfs_readpage_retry()
285 rpc_restart_call_prepare(task); in nfs_readpage_retry()
288 static void nfs_readpage_result(struct rpc_task *task, in nfs_readpage_result() argument
301 nfs_readpage_retry(task, hdr); in nfs_readpage_result()
|
| D | write.c | 1485 void nfs_commit_prepare(struct rpc_task *task, void *calldata) in nfs_commit_prepare() argument
1489 NFS_PROTO(data->inode)->commit_rpc_prepare(task, data); in nfs_commit_prepare()
1553 static int nfs_writeback_done(struct rpc_task *task, in nfs_writeback_done() argument
1566 status = NFS_PROTO(inode)->write_done(task, hdr); in nfs_writeback_done()
1571 trace_nfs_writeback_done(inode, task->tk_status, in nfs_writeback_done()
1575 task->tk_status >= 0) { in nfs_writeback_done()
1608 static void nfs_writeback_result(struct rpc_task *task, in nfs_writeback_result() argument
1629 task->tk_status = -EIO; in nfs_writeback_result()
1634 if (!task->tk_ops) { in nfs_writeback_result()
1652 rpc_restart_call_prepare(task); in nfs_writeback_result()
[all …]
|
| /fs/lockd/ |
| D | clntproc.c | 369 struct rpc_task *task; in nlm_do_async_call() local
371 task = __nlm_async_call(req, proc, msg, tk_ops); in nlm_do_async_call()
372 if (IS_ERR(task)) in nlm_do_async_call()
373 return PTR_ERR(task); in nlm_do_async_call()
374 rpc_put_task(task); in nlm_do_async_call()
413 struct rpc_task *task; in nlmclnt_async_call() local
416 task = __nlm_async_call(req, proc, &msg, tk_ops); in nlmclnt_async_call()
417 if (IS_ERR(task)) in nlmclnt_async_call()
418 return PTR_ERR(task); in nlmclnt_async_call()
419 err = rpc_wait_for_completion_task(task); in nlmclnt_async_call()
[all …]
|
| D | clntlock.c | 216 struct task_struct *task; in nlmclnt_recovery() local
220 task = kthread_run(reclaimer, host, "%s-reclaim", host->h_name); in nlmclnt_recovery()
221 if (IS_ERR(task)) in nlmclnt_recovery()
224 "(%ld)\n", host->h_name, PTR_ERR(task)); in nlmclnt_recovery()
|
| /fs/ |
| D | proc_namespace.c | 245 struct task_struct *task = get_proc_task(inode); in mounts_open_common() local
253 if (!task) in mounts_open_common()
256 task_lock(task); in mounts_open_common()
257 nsp = task->nsproxy; in mounts_open_common()
259 task_unlock(task); in mounts_open_common()
260 put_task_struct(task); in mounts_open_common()
265 if (!task->fs) { in mounts_open_common()
266 task_unlock(task); in mounts_open_common()
267 put_task_struct(task); in mounts_open_common()
271 get_fs_root(task->fs, &root); in mounts_open_common()
[all …]
|
| D | nsfs.c | 124 struct task_struct *task; member
131 return args->ns_ops->get(args->task); in ns_get_path_task()
134 void *ns_get_path(struct path *path, struct task_struct *task, in ns_get_path() argument
139 .task = task, in ns_get_path()
215 int ns_get_name(char *buf, size_t size, struct task_struct *task, in ns_get_name() argument
221 ns = ns_ops->get(task); in ns_get_name()
|
| D | file_table.c | 337 struct task_struct *task = current; in fput_many() local
339 if (likely(!in_interrupt() && !(task->flags & PF_KTHREAD))) { in fput_many()
341 if (!task_work_add(task, &file->f_u.fu_rcuhead, true)) in fput_many()
371 struct task_struct *task = current; in __fput_sync() local
372 BUG_ON(!(task->flags & PF_KTHREAD)); in __fput_sync()
|
| D | coredump.c | 443 core_state->dumper.task = tsk; in coredump_wait()
466 wait_task_inactive(ptr->task, 0); in coredump_wait()
477 struct task_struct *task; in coredump_finish() local
489 task = curr->task; in coredump_finish()
495 curr->task = NULL; in coredump_finish()
496 wake_up_process(task); in coredump_finish()
|
| /fs/nfsd/ |
| D | nfs4callback.c | 930 static void nfsd4_cb_probe_done(struct rpc_task *task, void *calldata) in nfsd4_cb_probe_done() argument
934 if (task->tk_status) in nfsd4_cb_probe_done()
935 nfsd4_mark_cb_down(clp, task->tk_status); in nfsd4_cb_probe_done()
978 static bool nfsd41_cb_get_slot(struct nfs4_client *clp, struct rpc_task *task) in nfsd41_cb_get_slot() argument
981 rpc_sleep_on(&clp->cl_cb_waitq, task, NULL); in nfsd41_cb_get_slot()
987 rpc_wake_up_queued_task(&clp->cl_cb_waitq, task); in nfsd41_cb_get_slot()
996 static void nfsd4_cb_prepare(struct rpc_task *task, void *calldata) in nfsd4_cb_prepare() argument
1009 if (!cb->cb_holds_slot && !nfsd41_cb_get_slot(clp, task)) in nfsd4_cb_prepare()
1013 rpc_call_start(task); in nfsd4_cb_prepare()
1016 static bool nfsd4_cb_sequence_done(struct rpc_task *task, struct nfsd4_callback *cb) in nfsd4_cb_sequence_done() argument
[all …]
|
| /fs/nfs/blocklayout/ |
| D | blocklayout.c | 234 struct rpc_task *task; in bl_read_cleanup() local
237 task = container_of(work, struct rpc_task, u.tk_work); in bl_read_cleanup()
238 hdr = container_of(task, struct nfs_pgio_header, task); in bl_read_cleanup()
247 hdr->task.tk_status = hdr->pnfs_error; in bl_end_par_io_read()
248 INIT_WORK(&hdr->task.u.tk_work, bl_read_cleanup); in bl_end_par_io_read()
249 schedule_work(&hdr->task.u.tk_work); in bl_end_par_io_read()
366 struct rpc_task *task = container_of(work, struct rpc_task, u.tk_work); in bl_write_cleanup() local
368 container_of(task, struct nfs_pgio_header, task); in bl_write_cleanup()
391 hdr->task.tk_status = hdr->pnfs_error; in bl_end_par_io_write()
393 INIT_WORK(&hdr->task.u.tk_work, bl_write_cleanup); in bl_end_par_io_write()
[all …]
|