| /fs/proc/ |
| D | base.c | 161 static int get_task_root(struct task_struct *task, struct path *root) in get_task_root() argument
165 task_lock(task); in get_task_root()
166 if (task->fs) { in get_task_root()
167 get_fs_root(task->fs, root); in get_task_root()
170 task_unlock(task); in get_task_root()
176 struct task_struct *task = get_proc_task(dentry->d_inode); in proc_cwd_link() local
179 if (task) { in proc_cwd_link()
180 task_lock(task); in proc_cwd_link()
181 if (task->fs) { in proc_cwd_link()
182 get_fs_pwd(task->fs, path); in proc_cwd_link()
[all …]
|
| D | array.c | 359 static void task_cpus_allowed(struct seq_file *m, struct task_struct *task) in task_cpus_allowed() argument
362 seq_cpumask(m, &task->cpus_allowed); in task_cpus_allowed()
365 seq_cpumask_list(m, &task->cpus_allowed); in task_cpus_allowed()
370 struct pid *pid, struct task_struct *task) in proc_pid_status() argument
372 struct mm_struct *mm = get_task_mm(task); in proc_pid_status()
374 task_name(m, task); in proc_pid_status()
375 task_state(m, ns, pid, task); in proc_pid_status()
381 task_sig(m, task); in proc_pid_status()
382 task_cap(m, task); in proc_pid_status()
383 task_seccomp(m, task); in proc_pid_status()
[all …]
|
| D | fd.c | 22 struct task_struct *task; in seq_show() local
24 task = get_proc_task(m->private); in seq_show()
25 if (!task) in seq_show()
28 files = get_files_struct(task); in seq_show()
29 put_task_struct(task); in seq_show()
76 struct task_struct *task; in tid_fd_revalidate() local
85 task = get_proc_task(inode); in tid_fd_revalidate()
88 if (task) { in tid_fd_revalidate()
89 files = get_files_struct(task); in tid_fd_revalidate()
101 if (task_dumpable(task)) { in tid_fd_revalidate()
[all …]
|
| D | namespaces.c | 67 struct task_struct *task, const struct proc_ns_operations *ns_ops) in proc_ns_get_dentry() argument
75 ns = ns_ops->get(task); in proc_ns_get_dentry()
120 struct task_struct *task; in proc_ns_follow_link() local
124 task = get_proc_task(inode); in proc_ns_follow_link()
125 if (!task) in proc_ns_follow_link()
128 if (!ptrace_may_access(task, PTRACE_MODE_READ)) in proc_ns_follow_link()
131 ns_path.dentry = proc_ns_get_dentry(sb, task, ei->ns.ns_ops); in proc_ns_follow_link()
142 put_task_struct(task); in proc_ns_follow_link()
152 struct task_struct *task; in proc_ns_readlink() local
157 task = get_proc_task(inode); in proc_ns_readlink()
[all …]
|
| D | task_mmu.c | 117 struct task_struct *task = priv->task; in hold_task_mempolicy() local
119 task_lock(task); in hold_task_mempolicy()
120 priv->task_mempolicy = task->mempolicy; in hold_task_mempolicy()
122 task_unlock(task); in hold_task_mempolicy()
206 priv->task = NULL; in m_start()
219 priv->task = get_pid_task(priv->pid, PIDTYPE_PID); in m_start()
220 if (!priv->task) in m_start()
223 mm = mm_access(priv->task, PTRACE_MODE_READ); in m_start()
228 tail_vma = get_gate_vma(priv->task->mm); in m_start()
285 if (priv->task) in m_stop()
[all …]
|
| D | internal.h | 55 int (*proc_read)(struct task_struct *task, char *page);
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()
276 struct task_struct *task; member
|
| D | task_nommu.c | 173 pid_t tid = vm_is_stack(priv->task, vma, is_pid); in nommu_vma_show()
222 priv->task = get_pid_task(priv->pid, PIDTYPE_PID); in m_start()
223 if (!priv->task) in m_start()
226 mm = mm_access(priv->task, PTRACE_MODE_READ); in m_start()
228 put_task_struct(priv->task); in m_start()
229 priv->task = NULL; in m_start()
245 if (priv->task) { in m_stop()
246 struct mm_struct *mm = priv->task->mm; in m_stop()
249 put_task_struct(priv->task); in m_stop()
|
| 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 ns = task_nsproxy(task); in get_proc_task_net()
|
| /fs/nfs/ |
| D | nfs4filelayout.c | 89 struct rpc_task *task = &data->task; in filelayout_reset_write() local
94 data->task.tk_pid, in filelayout_reset_write()
100 task->tk_status = pnfs_write_done_resend_to_mds(hdr->inode, in filelayout_reset_write()
110 struct rpc_task *task = &data->task; in filelayout_reset_read() local
115 data->task.tk_pid, in filelayout_reset_read()
121 task->tk_status = pnfs_read_done_resend_to_mds(hdr->inode, in filelayout_reset_read()
135 static int filelayout_async_handle_error(struct rpc_task *task, in filelayout_async_handle_error() argument
147 if (task->tk_status >= 0) in filelayout_async_handle_error()
150 switch (task->tk_status) { in filelayout_async_handle_error()
180 "flags 0x%x\n", __func__, task->tk_status, in filelayout_async_handle_error()
[all …]
|
| D | nfs4proc.c | 433 static int nfs41_sequence_done(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs41_sequence_done() argument
442 if (!RPC_WAS_SENT(task)) in nfs41_sequence_done()
521 if (rpc_restart_call_prepare(task)) { in nfs41_sequence_done()
522 task->tk_status = 0; in nfs41_sequence_done()
527 if (!rpc_restart_call(task)) in nfs41_sequence_done()
529 rpc_delay(task, NFS4_POLL_RETRY_MAX); in nfs41_sequence_done()
533 static int nfs4_sequence_done(struct rpc_task *task, in nfs4_sequence_done() argument
538 return nfs41_sequence_done(task, res); in nfs4_sequence_done()
560 struct rpc_task *task) in nfs41_setup_sequence() argument
572 task->tk_timeout = 0; in nfs41_setup_sequence()
[all …]
|
| D | unlink.c | 75 static void nfs_async_unlink_done(struct rpc_task *task, void *calldata) in nfs_async_unlink_done() argument
80 if (!NFS_PROTO(dir)->unlink_done(task, dir)) in nfs_async_unlink_done()
81 rpc_restart_call_prepare(task); in nfs_async_unlink_done()
101 static void nfs_unlink_prepare(struct rpc_task *task, void *calldata) in nfs_unlink_prepare() argument
104 NFS_PROTO(data->dir)->unlink_rpc_prepare(task, data); in nfs_unlink_prepare()
127 struct rpc_task *task; in nfs_do_call_unlink() local
173 task = rpc_run_task(&task_setup_data); in nfs_do_call_unlink()
174 if (!IS_ERR(task)) in nfs_do_call_unlink()
175 rpc_put_task_async(task); in nfs_do_call_unlink()
332 static void nfs_async_rename_done(struct rpc_task *task, void *calldata) in nfs_async_rename_done() argument
[all …]
|
| D | read.c | 212 struct rpc_task *task; in nfs_initiate_read() local
219 .task = &data->task, in nfs_initiate_read()
233 data->task.tk_pid, in nfs_initiate_read()
239 task = rpc_run_task(&task_setup_data); in nfs_initiate_read()
240 if (IS_ERR(task)) in nfs_initiate_read()
241 return PTR_ERR(task); in nfs_initiate_read()
242 rpc_put_task(task); in nfs_initiate_read()
442 int nfs_readpage_result(struct rpc_task *task, struct nfs_read_data *data) in nfs_readpage_result() argument
447 dprintk("NFS: %s: %5u, (status %d)\n", __func__, task->tk_pid, in nfs_readpage_result()
448 task->tk_status); in nfs_readpage_result()
[all …]
|
| D | nfs3proc.c | 45 nfs3_async_handle_jukebox(struct rpc_task *task, struct inode *inode) in nfs3_async_handle_jukebox() argument
47 if (task->tk_status != -EJUKEBOX) in nfs3_async_handle_jukebox()
49 if (task->tk_status == -EJUKEBOX) in nfs3_async_handle_jukebox()
51 task->tk_status = 0; in nfs3_async_handle_jukebox()
52 rpc_restart_call(task); in nfs3_async_handle_jukebox()
53 rpc_delay(task, NFS_JUKEBOX_RETRY_TIME); in nfs3_async_handle_jukebox()
430 static void nfs3_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs3_proc_unlink_rpc_prepare() argument
432 rpc_call_start(task); in nfs3_proc_unlink_rpc_prepare()
436 nfs3_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs3_proc_unlink_done() argument
439 if (nfs3_async_handle_jukebox(task, dir)) in nfs3_proc_unlink_done()
[all …]
|
| D | write.c | 952 struct rpc_task *task; in nfs_initiate_write() local
960 .task = &data->task, in nfs_initiate_write()
975 data->task.tk_pid, in nfs_initiate_write()
981 task = rpc_run_task(&task_setup_data); in nfs_initiate_write()
982 if (IS_ERR(task)) { in nfs_initiate_write()
983 ret = PTR_ERR(task); in nfs_initiate_write()
987 ret = rpc_wait_for_completion_task(task); in nfs_initiate_write()
989 ret = task->tk_status; in nfs_initiate_write()
991 rpc_put_task(task); in nfs_initiate_write()
1250 void nfs_write_prepare(struct rpc_task *task, void *calldata) in nfs_write_prepare() argument
[all …]
|
| D | callback.c | 35 struct task_struct *task; member
219 if (cb_info->task) in nfs_callback_start_svc()
241 cb_info->task = kthread_run(callback_svc, cb_info->rqst, svc_name); in nfs_callback_start_svc()
242 if (IS_ERR(cb_info->task)) { in nfs_callback_start_svc()
243 ret = PTR_ERR(cb_info->task); in nfs_callback_start_svc()
246 cb_info->task = NULL; in nfs_callback_start_svc()
316 if (cb_info->task) { in nfs_callback_create_svc()
401 if (cb_info->users == 0 && cb_info->task != NULL) { in nfs_callback_down()
402 kthread_stop(cb_info->task); in nfs_callback_down()
408 cb_info->task = NULL; in nfs_callback_down()
|
| D | proc.c | 327 static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs_proc_unlink_rpc_prepare() argument
329 rpc_call_start(task); in nfs_proc_unlink_rpc_prepare()
332 static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs_proc_unlink_done() argument
344 static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs_proc_rename_rpc_prepare() argument
346 rpc_call_start(task); in nfs_proc_rename_rpc_prepare()
350 nfs_proc_rename_done(struct rpc_task *task, struct inode *old_dir, in nfs_proc_rename_done() argument
604 static int nfs_read_done(struct rpc_task *task, struct nfs_read_data *data) in nfs_read_done() argument
609 if (task->tk_status >= 0) { in nfs_read_done()
625 static void nfs_proc_read_rpc_prepare(struct rpc_task *task, struct nfs_read_data *data) in nfs_proc_read_rpc_prepare() argument
627 rpc_call_start(task); in nfs_proc_read_rpc_prepare()
[all …]
|
| D | nfs4_fs.h | 71 struct rpc_task *task; member
253 struct rpc_task *task);
256 struct rpc_task *task);
284 struct rpc_task *task) in nfs4_setup_sequence() argument
286 rpc_call_start(task); in nfs4_setup_sequence()
368 extern int nfs_wait_on_sequence(struct nfs_seqid *seqid, struct rpc_task *task);
|
| /fs/lockd/ |
| D | clntproc.c | 356 struct rpc_task *task; in nlm_do_async_call() local
358 task = __nlm_async_call(req, proc, msg, tk_ops); in nlm_do_async_call()
359 if (IS_ERR(task)) in nlm_do_async_call()
360 return PTR_ERR(task); in nlm_do_async_call()
361 rpc_put_task(task); in nlm_do_async_call()
400 struct rpc_task *task; in nlmclnt_async_call() local
403 task = __nlm_async_call(req, proc, &msg, tk_ops); in nlmclnt_async_call()
404 if (IS_ERR(task)) in nlmclnt_async_call()
405 return PTR_ERR(task); in nlmclnt_async_call()
406 err = rpc_wait_for_completion_task(task); in nlmclnt_async_call()
[all …]
|
| D | clntlock.c | 209 struct task_struct *task; in nlmclnt_recovery() local
213 task = kthread_run(reclaimer, host, "%s-reclaim", host->h_name); in nlmclnt_recovery()
214 if (IS_ERR(task)) in nlmclnt_recovery()
217 "(%ld)\n", host->h_name, PTR_ERR(task)); in nlmclnt_recovery()
|
| /fs/ |
| D | proc_namespace.c | 229 struct task_struct *task = get_proc_task(inode); in mounts_open_common() local
236 if (!task) in mounts_open_common()
240 nsp = task_nsproxy(task); in mounts_open_common()
243 put_task_struct(task); in mounts_open_common()
249 put_task_struct(task); in mounts_open_common()
254 task_lock(task); in mounts_open_common()
255 if (!task->fs) { in mounts_open_common()
256 task_unlock(task); in mounts_open_common()
257 put_task_struct(task); in mounts_open_common()
261 get_fs_root(task->fs, &root); in mounts_open_common()
[all …]
|
| D | ioprio.c | 32 int set_task_ioprio(struct task_struct *task, int ioprio) in set_task_ioprio() argument
39 tcred = __task_cred(task); in set_task_ioprio()
47 err = security_task_setioprio(task, ioprio); in set_task_ioprio()
51 ioc = get_task_io_context(task, GFP_ATOMIC, NUMA_NO_NODE); in set_task_ioprio()
|
| D | coredump.c | 367 core_state->dumper.task = tsk; in coredump_wait()
386 wait_task_inactive(ptr->task, 0); in coredump_wait()
397 struct task_struct *task; in coredump_finish() local
409 task = curr->task; in coredump_finish()
415 curr->task = NULL; in coredump_finish()
416 wake_up_process(task); in coredump_finish()
|
| /fs/nfsd/ |
| D | nfs4callback.c | 711 static void nfsd4_cb_probe_done(struct rpc_task *task, void *calldata) in nfsd4_cb_probe_done() argument
715 if (task->tk_status) in nfsd4_cb_probe_done()
716 nfsd4_mark_cb_down(clp, task->tk_status); in nfsd4_cb_probe_done()
780 static bool nfsd41_cb_get_slot(struct nfs4_client *clp, struct rpc_task *task) in nfsd41_cb_get_slot() argument
783 rpc_sleep_on(&clp->cl_cb_waitq, task, NULL); in nfsd41_cb_get_slot()
794 static void nfsd4_cb_prepare(struct rpc_task *task, void *calldata) in nfsd4_cb_prepare() argument
802 if (!nfsd41_cb_get_slot(clp, task)) in nfsd4_cb_prepare()
812 rpc_call_start(task); in nfsd4_cb_prepare()
815 static void nfsd4_cb_done(struct rpc_task *task, void *calldata) in nfsd4_cb_done() argument
832 task->tk_msg.rpc_resp = NULL; in nfsd4_cb_done()
[all …]
|
| /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 rdata = container_of(task, struct nfs_read_data, task); in _rpc_read_complete()
246 oir->status = rdata->task.tk_status = status; in objlayout_read_done()
260 INIT_WORK(&rdata->task.u.tk_work, _rpc_read_complete); in objlayout_read_done()
261 schedule_work(&rdata->task.u.tk_work); in objlayout_read_done()
314 struct rpc_task *task; in _rpc_write_complete() local
318 task = container_of(work, struct rpc_task, u.tk_work); in _rpc_write_complete()
319 wdata = container_of(task, struct nfs_write_data, task); in _rpc_write_complete()
329 oir->status = wdata->task.tk_status = status; in objlayout_write_done()
[all …]
|
| /fs/btrfs/ |
| D | async-thread.c | 47 struct task_struct *task; member
431 kthread_stop(worker->task); in btrfs_stop_workers()
483 worker->task = kthread_run(worker_loop, worker, in __btrfs_start_workers()
486 if (IS_ERR(worker->task)) { in __btrfs_start_workers()
487 ret = PTR_ERR(worker->task); in __btrfs_start_workers()
655 wake_up_process(worker->task); in btrfs_requeue_work()
712 wake_up_process(worker->task); in btrfs_queue_worker()
|