| /fs/proc/ |
| D | base.c | 169 static int get_task_root(struct task_struct *task, struct path *root) in get_task_root() argument
173 task_lock(task); in get_task_root()
174 if (task->fs) { in get_task_root()
175 get_fs_root(task->fs, root); in get_task_root()
178 task_unlock(task); in get_task_root()
184 struct task_struct *task = get_proc_task(d_inode(dentry)); in proc_cwd_link() local
187 if (task) { in proc_cwd_link()
188 task_lock(task); in proc_cwd_link()
189 if (task->fs) { in proc_cwd_link()
190 get_fs_pwd(task->fs, path); in proc_cwd_link()
[all …]
|
| D | array.c | 386 static void task_cpus_allowed(struct seq_file *m, struct task_struct *task) in task_cpus_allowed() argument
389 cpumask_pr_args(&task->cpus_allowed)); in task_cpus_allowed()
391 cpumask_pr_args(&task->cpus_allowed)); in task_cpus_allowed()
395 struct pid *pid, struct task_struct *task) in proc_pid_status() argument
397 struct mm_struct *mm = get_task_mm(task); in proc_pid_status()
399 task_name(m, task); in proc_pid_status()
400 task_state(m, ns, pid, task); in proc_pid_status()
406 task_sig(m, task); in proc_pid_status()
407 task_cap(m, task); in proc_pid_status()
408 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()
87 struct task_struct *task; in tid_fd_revalidate() local
95 task = get_proc_task(inode); in tid_fd_revalidate()
98 if (task) { in tid_fd_revalidate()
99 files = get_files_struct(task); in tid_fd_revalidate()
111 task_dump_owner(task, 0, &inode->i_uid, &inode->i_gid); in tid_fd_revalidate()
[all …]
|
| D | proc_net.c | 111 struct task_struct *task; in get_proc_task_net() local
116 task = pid_task(proc_pid(dir), PIDTYPE_PID); in get_proc_task_net()
117 if (task != NULL) { in get_proc_task_net()
118 task_lock(task); in get_proc_task_net()
119 ns = task->nsproxy; in get_proc_task_net()
122 task_unlock(task); in get_proc_task_net()
|
| D | task_nommu.c | 218 priv->task = get_proc_task(priv->inode); in m_start()
219 if (!priv->task) in m_start()
245 if (priv->task) { in m_stop()
246 put_task_struct(priv->task); in m_stop()
247 priv->task = NULL; in m_stop()
|
| D | internal.h | 60 struct task_struct *task);
103 void task_dump_owner(struct task_struct *task, mode_t mode,
283 struct task_struct *task; member
|
| /fs/nfs/flexfilelayout/ |
| D | flexfilelayout.c | 33 static void ff_layout_read_record_layoutstats_done(struct rpc_task *task,
693 nfs4_ff_layout_stat_io_end_read(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_read() argument
701 ktime_get(), task->tk_start); in nfs4_ff_layout_stat_io_end_read()
724 nfs4_ff_layout_stat_io_end_write(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_write() argument
735 requested, completed, ktime_get(), task->tk_start); in nfs4_ff_layout_stat_io_end_write()
996 struct rpc_task *task = &hdr->task; in ff_layout_reset_write() local
1003 hdr->task.tk_pid, in ff_layout_reset_write()
1016 hdr->task.tk_pid, in ff_layout_reset_write()
1022 task->tk_status = pnfs_write_done_resend_to_mds(hdr); in ff_layout_reset_write()
1028 struct rpc_task *task = &hdr->task; in ff_layout_reset_read() local
[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/ |
| D | unlink.c | 45 static void nfs_async_unlink_done(struct rpc_task *task, void *calldata) in nfs_async_unlink_done() argument
50 trace_nfs_sillyrename_unlink(data, task->tk_status); in nfs_async_unlink_done()
51 if (!NFS_PROTO(dir)->unlink_done(task, dir)) in nfs_async_unlink_done()
52 rpc_restart_call_prepare(task); in nfs_async_unlink_done()
75 static void nfs_unlink_prepare(struct rpc_task *task, void *calldata) in nfs_unlink_prepare() argument
79 NFS_PROTO(dir)->unlink_rpc_prepare(task, data); in nfs_unlink_prepare()
102 struct rpc_task *task; in nfs_do_call_unlink() local
111 task = rpc_run_task(&task_setup_data); in nfs_do_call_unlink()
112 if (!IS_ERR(task)) in nfs_do_call_unlink()
113 rpc_put_task_async(task); in nfs_do_call_unlink()
[all …]
|
| D | nfs4proc.c | 529 nfs4_async_handle_exception(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_exception() argument
537 rpc_delay(task, nfs4_update_delay(&exception->timeout)); in nfs4_async_handle_exception()
541 rpc_sleep_on(&clp->cl_rpcwaitq, task, NULL); in nfs4_async_handle_exception()
543 rpc_wake_up_queued_task(&clp->cl_rpcwaitq, task); in nfs4_async_handle_exception()
557 rpc_task_release_transport(task); in nfs4_async_handle_exception()
563 nfs4_async_handle_error(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_error() argument
570 if (task->tk_status >= 0) in nfs4_async_handle_error()
574 task->tk_status = nfs4_async_handle_exception(task, server, in nfs4_async_handle_error()
575 task->tk_status, in nfs4_async_handle_error()
645 static int nfs40_sequence_done(struct rpc_task *task, in nfs40_sequence_done() argument
[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 | 115 nfs_async_iocounter_wait(struct rpc_task *task, struct nfs_lock_context *l_ctx) in nfs_async_iocounter_wait() argument
121 rpc_sleep_on(&NFS_SERVER(inode)->uoc_rpcwaitq, task, NULL); in nfs_async_iocounter_wait()
126 rpc_wake_up_queued_task(&NFS_SERVER(inode)->uoc_rpcwaitq, task); in nfs_async_iocounter_wait()
580 static void nfs_pgio_prepare(struct rpc_task *task, void *calldata) in nfs_pgio_prepare() argument
584 err = NFS_PROTO(hdr->inode)->pgio_rpc_prepare(task, hdr); in nfs_pgio_prepare()
586 rpc_exit(task, err); in nfs_pgio_prepare()
593 struct rpc_task *task; in nfs_initiate_pgio() local
601 .task = &hdr->task, in nfs_initiate_pgio()
619 task = rpc_run_task(&task_setup_data); in nfs_initiate_pgio()
620 if (IS_ERR(task)) { in nfs_initiate_pgio()
[all …]
|
| D | nfs42proc.c | 340 nfs42_layoutstat_prepare(struct rpc_task *task, void *calldata) in nfs42_layoutstat_prepare() argument
351 rpc_exit(task, 0); in nfs42_layoutstat_prepare()
357 &data->res.seq_res, task); in nfs42_layoutstat_prepare()
361 nfs42_layoutstat_done(struct rpc_task *task, void *calldata) in nfs42_layoutstat_done() argument
367 if (!nfs4_sequence_done(task, &data->res.seq_res)) in nfs42_layoutstat_done()
370 switch (task->tk_status) { in nfs42_layoutstat_done()
405 rpc_delay(task, HZ); in nfs42_layoutstat_done()
406 rpc_restart_call_prepare(task); in nfs42_layoutstat_done()
458 struct rpc_task *task; in nfs42_proc_layoutstats_generic() local
466 task = rpc_run_task(&task_setup); in nfs42_proc_layoutstats_generic()
[all …]
|
| D | proc.c | 329 static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs_proc_unlink_rpc_prepare() argument
331 rpc_call_start(task); in nfs_proc_unlink_rpc_prepare()
334 static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs_proc_unlink_done() argument
346 static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs_proc_rename_rpc_prepare() argument
348 rpc_call_start(task); in nfs_proc_rename_rpc_prepare()
352 nfs_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs_proc_rename_done() argument
582 static int nfs_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_read_done() argument
587 if (task->tk_status >= 0) { in nfs_read_done()
605 static int nfs_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs_proc_pgio_rpc_prepare() argument
608 rpc_call_start(task); in nfs_proc_pgio_rpc_prepare()
[all …]
|
| D | read.c | 228 static int nfs_readpage_done(struct rpc_task *task, in nfs_readpage_done() argument
232 int status = NFS_PROTO(inode)->read_done(task, hdr); in nfs_readpage_done()
237 trace_nfs_readpage_done(inode, task->tk_status, in nfs_readpage_done()
240 if (task->tk_status == -ESTALE) { in nfs_readpage_done()
247 static void nfs_readpage_retry(struct rpc_task *task, in nfs_readpage_retry() argument
262 if (!task->tk_ops) { in nfs_readpage_retry()
272 rpc_restart_call_prepare(task); in nfs_readpage_retry()
275 static void nfs_readpage_result(struct rpc_task *task, in nfs_readpage_result() argument
290 nfs_readpage_retry(task, hdr); in nfs_readpage_result()
|
| D | write.c | 1464 void nfs_commit_prepare(struct rpc_task *task, void *calldata) in nfs_commit_prepare() argument
1468 NFS_PROTO(data->inode)->commit_rpc_prepare(task, data); in nfs_commit_prepare()
1532 static int nfs_writeback_done(struct rpc_task *task, in nfs_writeback_done() argument
1545 status = NFS_PROTO(inode)->write_done(task, hdr); in nfs_writeback_done()
1550 trace_nfs_writeback_done(inode, task->tk_status, in nfs_writeback_done()
1554 task->tk_status >= 0) { in nfs_writeback_done()
1584 static void nfs_writeback_result(struct rpc_task *task, in nfs_writeback_result() argument
1605 task->tk_status = -EIO; in nfs_writeback_result()
1610 if (!task->tk_ops) { in nfs_writeback_result()
1628 rpc_restart_call_prepare(task); in nfs_writeback_result()
[all …]
|
| /fs/lockd/ |
| D | clntproc.c | 367 struct rpc_task *task; in nlm_do_async_call() local
369 task = __nlm_async_call(req, proc, msg, tk_ops); in nlm_do_async_call()
370 if (IS_ERR(task)) in nlm_do_async_call()
371 return PTR_ERR(task); in nlm_do_async_call()
372 rpc_put_task(task); in nlm_do_async_call()
411 struct rpc_task *task; in nlmclnt_async_call() local
414 task = __nlm_async_call(req, proc, &msg, tk_ops); in nlmclnt_async_call()
415 if (IS_ERR(task)) in nlmclnt_async_call()
416 return PTR_ERR(task); in nlmclnt_async_call()
417 err = rpc_wait_for_completion_task(task); in nlmclnt_async_call()
[all …]
|
| D | clntlock.c | 215 struct task_struct *task; in nlmclnt_recovery() local
219 task = kthread_run(reclaimer, host, "%s-reclaim", host->h_name); in nlmclnt_recovery()
220 if (IS_ERR(task)) in nlmclnt_recovery()
223 "(%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 | file_table.c | 267 struct task_struct *task = current; in fput() local
269 if (likely(!in_interrupt() && !(task->flags & PF_KTHREAD))) { in fput()
271 if (!task_work_add(task, &file->f_u.fu_rcuhead, true)) in fput()
296 struct task_struct *task = current; in __fput_sync() local
297 BUG_ON(!(task->flags & PF_KTHREAD)); in __fput_sync()
|
| D | nsfs.c | 106 void *ns_get_path(struct path *path, struct task_struct *task, in ns_get_path() argument
113 ns = ns_ops->get(task); in ns_get_path()
194 int ns_get_name(char *buf, size_t size, struct task_struct *task, in ns_get_name() argument
200 ns = ns_ops->get(task); in ns_get_name()
|
| D | coredump.c | 417 core_state->dumper.task = tsk; in coredump_wait()
440 wait_task_inactive(ptr->task, 0); in coredump_wait()
451 struct task_struct *task; in coredump_finish() local
463 task = curr->task; in coredump_finish()
469 curr->task = NULL; in coredump_finish()
470 wake_up_process(task); in coredump_finish()
|
| /fs/nfsd/ |
| D | nfs4callback.c | 863 static void nfsd4_cb_probe_done(struct rpc_task *task, void *calldata) in nfsd4_cb_probe_done() argument
867 if (task->tk_status) in nfsd4_cb_probe_done()
868 nfsd4_mark_cb_down(clp, task->tk_status); in nfsd4_cb_probe_done()
911 static bool nfsd41_cb_get_slot(struct nfs4_client *clp, struct rpc_task *task) in nfsd41_cb_get_slot() argument
914 rpc_sleep_on(&clp->cl_cb_waitq, task, NULL); in nfsd41_cb_get_slot()
920 rpc_wake_up_queued_task(&clp->cl_cb_waitq, task); in nfsd41_cb_get_slot()
929 static void nfsd4_cb_prepare(struct rpc_task *task, void *calldata) in nfsd4_cb_prepare() argument
942 if (!cb->cb_holds_slot && !nfsd41_cb_get_slot(clp, task)) in nfsd4_cb_prepare()
946 rpc_call_start(task); in nfsd4_cb_prepare()
949 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 | 205 struct rpc_task *task; in bl_read_cleanup() local
208 task = container_of(work, struct rpc_task, u.tk_work); in bl_read_cleanup()
209 hdr = container_of(task, struct nfs_pgio_header, task); in bl_read_cleanup()
218 hdr->task.tk_status = hdr->pnfs_error; in bl_end_par_io_read()
219 INIT_WORK(&hdr->task.u.tk_work, bl_read_cleanup); in bl_end_par_io_read()
220 schedule_work(&hdr->task.u.tk_work); in bl_end_par_io_read()
336 struct rpc_task *task = container_of(work, struct rpc_task, u.tk_work); in bl_write_cleanup() local
338 container_of(task, struct nfs_pgio_header, task); in bl_write_cleanup()
361 hdr->task.tk_status = hdr->pnfs_error; in bl_end_par_io_write()
363 INIT_WORK(&hdr->task.u.tk_work, bl_write_cleanup); in bl_end_par_io_write()
[all …]
|