| /fs/proc/ |
| D | base.c | 160 static int get_task_root(struct task_struct *task, struct path *root) in get_task_root() argument
164 task_lock(task); in get_task_root()
165 if (task->fs) { in get_task_root()
166 get_fs_root(task->fs, root); in get_task_root()
169 task_unlock(task); in get_task_root()
175 struct task_struct *task = get_proc_task(d_inode(dentry)); in proc_cwd_link() local
178 if (task) { in proc_cwd_link()
179 task_lock(task); in proc_cwd_link()
180 if (task->fs) { in proc_cwd_link()
181 get_fs_pwd(task->fs, path); in proc_cwd_link()
[all …]
|
| D | array.c | 372 static void task_cpus_allowed(struct seq_file *m, struct task_struct *task) in task_cpus_allowed() argument
375 cpumask_pr_args(&task->cpus_allowed)); in task_cpus_allowed()
377 cpumask_pr_args(&task->cpus_allowed)); in task_cpus_allowed()
381 struct pid *pid, struct task_struct *task) in proc_pid_status() argument
383 struct mm_struct *mm = get_task_mm(task); in proc_pid_status()
385 task_name(m, task); in proc_pid_status()
386 task_state(m, ns, pid, task); in proc_pid_status()
392 task_sig(m, task); in proc_pid_status()
393 task_cap(m, task); in proc_pid_status()
394 task_seccomp(m, task); in proc_pid_status()
[all …]
|
| D | namespaces.c | 37 struct task_struct *task; in proc_ns_follow_link() local
41 task = get_proc_task(inode); in proc_ns_follow_link()
42 if (!task) in proc_ns_follow_link()
45 if (ptrace_may_access(task, PTRACE_MODE_READ_FSCREDS)) { in proc_ns_follow_link()
46 error = ns_get_path(&ns_path, task, ns_ops); in proc_ns_follow_link()
50 put_task_struct(task); in proc_ns_follow_link()
58 struct task_struct *task; in proc_ns_readlink() local
62 task = get_proc_task(inode); in proc_ns_readlink()
63 if (!task) in proc_ns_readlink()
66 if (ptrace_may_access(task, PTRACE_MODE_READ_FSCREDS)) { in proc_ns_readlink()
[all …]
|
| D | fd.c | 24 struct task_struct *task; in seq_show() local
26 task = get_proc_task(m->private); in seq_show()
27 if (!task) in seq_show()
30 files = get_files_struct(task); in seq_show()
31 put_task_struct(task); in seq_show()
86 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 if (task_dumpable(task)) { in tid_fd_revalidate()
[all …]
|
| D | proc_net.c | 109 struct task_struct *task; in get_proc_task_net() local
114 task = pid_task(proc_pid(dir), PIDTYPE_PID); in get_proc_task_net()
115 if (task != NULL) { in get_proc_task_net()
116 task_lock(task); in get_proc_task_net()
117 ns = task->nsproxy; in get_proc_task_net()
120 task_unlock(task); in get_proc_task_net()
|
| D | internal.h | 58 struct task_struct *task);
100 static inline int task_dumpable(struct task_struct *task) in task_dumpable() argument
105 task_lock(task); in task_dumpable()
106 mm = task->mm; in task_dumpable()
109 task_unlock(task); in task_dumpable()
289 struct task_struct *task; member
|
| /fs/nfs/flexfilelayout/ |
| D | flexfilelayout.c | 668 nfs4_ff_layout_stat_io_end_read(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_read() argument
676 ktime_get(), task->tk_start); in nfs4_ff_layout_stat_io_end_read()
697 nfs4_ff_layout_stat_io_end_write(struct rpc_task *task, in nfs4_ff_layout_stat_io_end_write() argument
708 requested, completed, ktime_get(), task->tk_start); in nfs4_ff_layout_stat_io_end_write()
925 struct rpc_task *task = &hdr->task; in ff_layout_reset_write() local
932 hdr->task.tk_pid, in ff_layout_reset_write()
956 hdr->task.tk_pid, in ff_layout_reset_write()
962 task->tk_status = pnfs_write_done_resend_to_mds(hdr); in ff_layout_reset_write()
968 struct rpc_task *task = &hdr->task; in ff_layout_reset_read() local
975 hdr->task.tk_pid, in ff_layout_reset_read()
[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
134 if (task->tk_status >= 0) in filelayout_async_handle_error()
137 switch (task->tk_status) { in filelayout_async_handle_error()
164 "flags 0x%x\n", __func__, task->tk_status, in filelayout_async_handle_error()
[all …]
|
| /fs/nfs/ |
| D | unlink.c | 78 static void nfs_async_unlink_done(struct rpc_task *task, void *calldata) in nfs_async_unlink_done() argument
83 trace_nfs_sillyrename_unlink(data, task->tk_status); in nfs_async_unlink_done()
84 if (!NFS_PROTO(dir)->unlink_done(task, dir)) in nfs_async_unlink_done()
85 rpc_restart_call_prepare(task); in nfs_async_unlink_done()
105 static void nfs_unlink_prepare(struct rpc_task *task, void *calldata) in nfs_unlink_prepare() argument
108 NFS_PROTO(data->dir)->unlink_rpc_prepare(task, data); in nfs_unlink_prepare()
131 struct rpc_task *task; in nfs_do_call_unlink() local
177 task = rpc_run_task(&task_setup_data); in nfs_do_call_unlink()
178 if (!IS_ERR(task)) in nfs_do_call_unlink()
179 rpc_put_task_async(task); in nfs_do_call_unlink()
[all …]
|
| D | nfs4proc.c | 466 nfs4_async_handle_exception(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_exception() argument
474 rpc_delay(task, nfs4_update_delay(&exception->timeout)); in nfs4_async_handle_exception()
478 rpc_sleep_on(&clp->cl_rpcwaitq, task, NULL); in nfs4_async_handle_exception()
480 rpc_wake_up_queued_task(&clp->cl_rpcwaitq, task); in nfs4_async_handle_exception()
493 nfs4_async_handle_error(struct rpc_task *task, struct nfs_server *server, in nfs4_async_handle_error() argument
500 if (task->tk_status >= 0) in nfs4_async_handle_error()
504 task->tk_status = nfs4_async_handle_exception(task, server, in nfs4_async_handle_error()
505 task->tk_status, in nfs4_async_handle_error()
569 struct rpc_task *task) in nfs40_setup_sequence() argument
584 task->tk_timeout = HZ >> 2; in nfs40_setup_sequence()
[all …]
|
| D | nfs3proc.c | 47 nfs3_async_handle_jukebox(struct rpc_task *task, struct inode *inode) in nfs3_async_handle_jukebox() argument
49 if (task->tk_status != -EJUKEBOX) in nfs3_async_handle_jukebox()
51 if (task->tk_status == -EJUKEBOX) in nfs3_async_handle_jukebox()
53 task->tk_status = 0; in nfs3_async_handle_jukebox()
54 rpc_restart_call(task); in nfs3_async_handle_jukebox()
55 rpc_delay(task, NFS_JUKEBOX_RETRY_TIME); in nfs3_async_handle_jukebox()
440 static void nfs3_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs3_proc_unlink_rpc_prepare() argument
442 rpc_call_start(task); in nfs3_proc_unlink_rpc_prepare()
446 nfs3_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs3_proc_unlink_done() argument
449 if (nfs3_async_handle_jukebox(task, dir)) in nfs3_proc_unlink_done()
[all …]
|
| D | callback.c | 35 struct task_struct *task; member
199 if (cb_info->task) in nfs_callback_start_svc()
220 cb_info->task = kthread_create(callback_svc, cb_info->rqst, in nfs_callback_start_svc()
222 if (IS_ERR(cb_info->task)) { in nfs_callback_start_svc()
223 ret = PTR_ERR(cb_info->task); in nfs_callback_start_svc()
226 cb_info->task = NULL; in nfs_callback_start_svc()
229 rqstp->rq_task = cb_info->task; in nfs_callback_start_svc()
230 wake_up_process(cb_info->task); in nfs_callback_start_svc()
296 if (cb_info->task) { in nfs_callback_create_svc()
381 if (cb_info->users == 0 && cb_info->task != NULL) { in nfs_callback_down()
[all …]
|
| D | nfs42proc.c | 197 nfs42_layoutstat_prepare(struct rpc_task *task, void *calldata) in nfs42_layoutstat_prepare() argument
203 &data->res.seq_res, task); in nfs42_layoutstat_prepare()
207 nfs42_layoutstat_done(struct rpc_task *task, void *calldata) in nfs42_layoutstat_done() argument
211 if (!nfs4_sequence_done(task, &data->res.seq_res)) in nfs42_layoutstat_done()
214 switch (task->tk_status) { in nfs42_layoutstat_done()
221 dprintk("%s server returns %d\n", __func__, task->tk_status); in nfs42_layoutstat_done()
264 struct rpc_task *task; in nfs42_proc_layoutstats_generic() local
272 task = rpc_run_task(&task_setup); in nfs42_proc_layoutstats_generic()
273 if (IS_ERR(task)) in nfs42_proc_layoutstats_generic()
274 return PTR_ERR(task); in nfs42_proc_layoutstats_generic()
[all …]
|
| D | pagelist.c | 607 static void nfs_pgio_prepare(struct rpc_task *task, void *calldata) in nfs_pgio_prepare() argument
611 err = NFS_PROTO(hdr->inode)->pgio_rpc_prepare(task, hdr); in nfs_pgio_prepare()
613 rpc_exit(task, err); in nfs_pgio_prepare()
620 struct rpc_task *task; in nfs_initiate_pgio() local
628 .task = &hdr->task, in nfs_initiate_pgio()
646 task = rpc_run_task(&task_setup_data); in nfs_initiate_pgio()
647 if (IS_ERR(task)) { in nfs_initiate_pgio()
648 ret = PTR_ERR(task); in nfs_initiate_pgio()
652 ret = rpc_wait_for_completion_task(task); in nfs_initiate_pgio()
654 ret = task->tk_status; in nfs_initiate_pgio()
[all …]
|
| D | proc.c | 328 static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs_proc_unlink_rpc_prepare() argument
330 rpc_call_start(task); in nfs_proc_unlink_rpc_prepare()
333 static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs_proc_unlink_done() argument
345 static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs_proc_rename_rpc_prepare() argument
347 rpc_call_start(task); in nfs_proc_rename_rpc_prepare()
351 nfs_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs_proc_rename_done() argument
581 static int nfs_read_done(struct rpc_task *task, struct nfs_pgio_header *hdr) in nfs_read_done() argument
586 if (task->tk_status >= 0) { in nfs_read_done()
604 static int nfs_proc_pgio_rpc_prepare(struct rpc_task *task, in nfs_proc_pgio_rpc_prepare() argument
607 rpc_call_start(task); in nfs_proc_pgio_rpc_prepare()
[all …]
|
| D | read.c | 219 static int nfs_readpage_done(struct rpc_task *task, in nfs_readpage_done() argument
223 int status = NFS_PROTO(inode)->read_done(task, hdr); in nfs_readpage_done()
229 if (task->tk_status == -ESTALE) { in nfs_readpage_done()
236 static void nfs_readpage_retry(struct rpc_task *task, in nfs_readpage_retry() argument
251 if (!task->tk_ops) { in nfs_readpage_retry()
261 rpc_restart_call_prepare(task); in nfs_readpage_retry()
264 static void nfs_readpage_result(struct rpc_task *task, in nfs_readpage_result() argument
279 nfs_readpage_retry(task, hdr); in nfs_readpage_result()
|
| D | write.c | 1370 void nfs_commit_prepare(struct rpc_task *task, void *calldata) in nfs_commit_prepare() argument
1374 NFS_PROTO(data->inode)->commit_rpc_prepare(task, data); in nfs_commit_prepare()
1438 static int nfs_writeback_done(struct rpc_task *task, in nfs_writeback_done() argument
1451 status = NFS_PROTO(inode)->write_done(task, hdr); in nfs_writeback_done()
1457 task->tk_status >= 0) { in nfs_writeback_done()
1487 static void nfs_writeback_result(struct rpc_task *task, in nfs_writeback_result() argument
1508 task->tk_status = -EIO; in nfs_writeback_result()
1513 if (!task->tk_ops) { in nfs_writeback_result()
1531 rpc_restart_call_prepare(task); in nfs_writeback_result()
1570 struct rpc_task *task; in nfs_initiate_commit() local
[all …]
|
| /fs/lockd/ |
| D | clntproc.c | 357 struct rpc_task *task; in nlm_do_async_call() local
359 task = __nlm_async_call(req, proc, msg, tk_ops); in nlm_do_async_call()
360 if (IS_ERR(task)) in nlm_do_async_call()
361 return PTR_ERR(task); in nlm_do_async_call()
362 rpc_put_task(task); in nlm_do_async_call()
401 struct rpc_task *task; in nlmclnt_async_call() local
404 task = __nlm_async_call(req, proc, &msg, tk_ops); in nlmclnt_async_call()
405 if (IS_ERR(task)) in nlmclnt_async_call()
406 return PTR_ERR(task); in nlmclnt_async_call()
407 err = rpc_wait_for_completion_task(task); in nlmclnt_async_call()
[all …]
|
| D | clntlock.c | 214 struct task_struct *task; in nlmclnt_recovery() local
218 task = kthread_run(reclaimer, host, "%s-reclaim", host->h_name); in nlmclnt_recovery()
219 if (IS_ERR(task)) in nlmclnt_recovery()
222 "(%ld)\n", host->h_name, PTR_ERR(task)); in nlmclnt_recovery()
|
| /fs/nfsd/ |
| D | nfs4callback.c | 797 static void nfsd4_cb_probe_done(struct rpc_task *task, void *calldata) in nfsd4_cb_probe_done() argument
801 if (task->tk_status) in nfsd4_cb_probe_done()
802 nfsd4_mark_cb_down(clp, task->tk_status); in nfsd4_cb_probe_done()
845 static bool nfsd41_cb_get_slot(struct nfs4_client *clp, struct rpc_task *task) in nfsd41_cb_get_slot() argument
848 rpc_sleep_on(&clp->cl_cb_waitq, task, NULL); in nfsd41_cb_get_slot()
854 rpc_wake_up_queued_task(&clp->cl_cb_waitq, task); in nfsd41_cb_get_slot()
863 static void nfsd4_cb_prepare(struct rpc_task *task, void *calldata) in nfsd4_cb_prepare() argument
877 if (!cb->cb_holds_slot && !nfsd41_cb_get_slot(clp, task)) in nfsd4_cb_prepare()
881 rpc_call_start(task); in nfsd4_cb_prepare()
884 static bool nfsd4_cb_sequence_done(struct rpc_task *task, struct nfsd4_callback *cb) in nfsd4_cb_sequence_done() argument
[all …]
|
| /fs/ |
| D | proc_namespace.c | 241 struct task_struct *task = get_proc_task(inode); in mounts_open_common() local
249 if (!task) in mounts_open_common()
252 task_lock(task); in mounts_open_common()
253 nsp = task->nsproxy; in mounts_open_common()
255 task_unlock(task); in mounts_open_common()
256 put_task_struct(task); in mounts_open_common()
261 if (!task->fs) { in mounts_open_common()
262 task_unlock(task); in mounts_open_common()
263 put_task_struct(task); in mounts_open_common()
267 get_fs_root(task->fs, &root); in mounts_open_common()
[all …]
|
| D | file_table.c | 267 struct task_struct *task = current; in fput_many() local
269 if (likely(!in_interrupt() && !(task->flags & PF_KTHREAD))) { in fput_many()
271 if (!task_work_add(task, &file->f_u.fu_rcuhead, true)) in fput_many()
301 struct task_struct *task = current; in __fput_sync() local
302 BUG_ON(!(task->flags & PF_KTHREAD)); in __fput_sync()
|
| D | nsfs.c | 47 void *ns_get_path(struct path *path, struct task_struct *task, in ns_get_path() argument
58 ns = ns_ops->get(task); in ns_get_path()
110 int ns_get_name(char *buf, size_t size, struct task_struct *task, in ns_get_name() argument
115 ns = ns_ops->get(task); in ns_get_name()
|
| /fs/nfs/objlayout/ |
| D | objlayout.c | 231 struct rpc_task *task; in _rpc_read_complete() local
235 task = container_of(work, struct rpc_task, u.tk_work); in _rpc_read_complete()
236 hdr = container_of(task, struct nfs_pgio_header, task); in _rpc_read_complete()
246 oir->status = hdr->task.tk_status = status; in objlayout_read_done()
260 INIT_WORK(&hdr->task.u.tk_work, _rpc_read_complete); in objlayout_read_done()
261 schedule_work(&hdr->task.u.tk_work); in objlayout_read_done()
313 struct rpc_task *task; in _rpc_write_complete() local
317 task = container_of(work, struct rpc_task, u.tk_work); in _rpc_write_complete()
318 hdr = container_of(task, struct nfs_pgio_header, task); in _rpc_write_complete()
328 oir->status = hdr->task.tk_status = status; in objlayout_write_done()
[all …]
|
| /fs/nfs/blocklayout/ |
| D | blocklayout.c | 203 struct rpc_task *task; in bl_read_cleanup() local
206 task = container_of(work, struct rpc_task, u.tk_work); in bl_read_cleanup()
207 hdr = container_of(task, struct nfs_pgio_header, task); in bl_read_cleanup()
216 hdr->task.tk_status = hdr->pnfs_error; in bl_end_par_io_read()
217 INIT_WORK(&hdr->task.u.tk_work, bl_read_cleanup); in bl_end_par_io_read()
218 schedule_work(&hdr->task.u.tk_work); in bl_end_par_io_read()
334 struct rpc_task *task = container_of(work, struct rpc_task, u.tk_work); in bl_write_cleanup() local
336 container_of(task, struct nfs_pgio_header, task); in bl_write_cleanup()
358 hdr->task.tk_status = hdr->pnfs_error; in bl_end_par_io_write()
360 INIT_WORK(&hdr->task.u.tk_work, bl_write_cleanup); in bl_end_par_io_write()
[all …]
|