| /fs/proc/ |
| D | base.c | 159 static int get_task_root(struct task_struct *task, struct path *root) in get_task_root() argument
163 task_lock(task); in get_task_root()
164 if (task->fs) { in get_task_root()
165 get_fs_root(task->fs, root); in get_task_root()
168 task_unlock(task); in get_task_root()
174 struct task_struct *task = get_proc_task(dentry->d_inode); in proc_cwd_link() local
177 if (task) { in proc_cwd_link()
178 task_lock(task); in proc_cwd_link()
179 if (task->fs) { in proc_cwd_link()
180 get_fs_pwd(task->fs, path); in proc_cwd_link()
[all …]
|
| D | array.c | 330 static void task_cpus_allowed(struct seq_file *m, struct task_struct *task) in task_cpus_allowed() argument
333 seq_cpumask(m, &task->cpus_allowed); in task_cpus_allowed()
336 seq_cpumask_list(m, &task->cpus_allowed); in task_cpus_allowed()
341 struct pid *pid, struct task_struct *task) in proc_pid_status() argument
343 struct mm_struct *mm = get_task_mm(task); in proc_pid_status()
345 task_name(m, task); in proc_pid_status()
346 task_state(m, ns, pid, task); in proc_pid_status()
352 task_sig(m, task); in proc_pid_status()
353 task_cap(m, task); in proc_pid_status()
354 task_cpus_allowed(m, task); in proc_pid_status()
[all …]
|
| D | namespaces.c | 60 struct task_struct *task, const struct proc_ns_operations *ns_ops) in proc_ns_get_dentry() argument
68 ns = ns_ops->get(task); in proc_ns_get_dentry()
113 struct task_struct *task; in proc_ns_follow_link() local
117 task = get_proc_task(inode); in proc_ns_follow_link()
118 if (!task) in proc_ns_follow_link()
121 if (!ptrace_may_access(task, PTRACE_MODE_READ)) in proc_ns_follow_link()
124 ns_dentry = proc_ns_get_dentry(sb, task, ei->ns_ops); in proc_ns_follow_link()
135 put_task_struct(task); in proc_ns_follow_link()
145 struct task_struct *task; in proc_ns_readlink() local
150 task = get_proc_task(inode); in proc_ns_readlink()
[all …]
|
| D | internal.h | 50 struct pid *pid, struct task_struct *task);
52 struct pid *pid, struct task_struct *task);
54 struct pid *pid, struct task_struct *task);
56 struct pid *pid, struct task_struct *task);
72 struct task_struct *task; member
145 instantiate_t instantiate, struct task_struct *task, const void *ptr);
147 struct inode *proc_pid_make_inode(struct super_block * sb, struct task_struct *task);
|
| D | task_mmu.c | 161 priv->task = NULL; in m_start()
174 priv->task = get_pid_task(priv->pid, PIDTYPE_PID); in m_start()
175 if (!priv->task) in m_start()
178 mm = mm_for_maps(priv->task); in m_start()
183 tail_vma = get_gate_vma(priv->task->mm); in m_start()
239 if (priv->task) in m_stop()
240 put_task_struct(priv->task); in m_stop()
268 struct task_struct *task = priv->task; in show_map_vma() local
327 tid = vm_is_stack(task, vma, is_pid); in show_map_vma()
363 struct task_struct *task = priv->task; in show_map() local
[all …]
|
| 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_for_maps(priv->task); 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 | 105 struct task_struct *task; in get_proc_task_net() local
110 task = pid_task(proc_pid(dir), PIDTYPE_PID); in get_proc_task_net()
111 if (task != NULL) { in get_proc_task_net()
112 ns = task_nsproxy(task); in get_proc_task_net()
|
| /fs/nfs/ |
| D | nfs4proc.c | 402 bool nfs4_set_task_privileged(struct rpc_task *task, void *dummy) in nfs4_set_task_privileged() argument
404 rpc_task_set_priority(task, RPC_PRIORITY_PRIVILEGED); in nfs4_set_task_privileged()
457 static int nfs41_sequence_done(struct rpc_task *task, struct nfs4_sequence_res *res) in nfs41_sequence_done() argument
472 if (!RPC_WAS_SENT(task)) in nfs41_sequence_done()
507 if (!rpc_restart_call(task)) in nfs41_sequence_done()
509 rpc_delay(task, NFS4_POLL_RETRY_MAX); in nfs41_sequence_done()
513 static int nfs4_sequence_done(struct rpc_task *task, in nfs4_sequence_done() argument
518 return nfs41_sequence_done(task, res); in nfs4_sequence_done()
568 struct rpc_task *task) in nfs41_setup_sequence() argument
583 !rpc_task_has_priority(task, RPC_PRIORITY_PRIVILEGED)) { in nfs41_setup_sequence()
[all …]
|
| D | direct.c | 234 static void nfs_direct_read_result(struct rpc_task *task, void *calldata) in nfs_direct_read_result() argument
238 nfs_readpage_result(task, data); in nfs_direct_read_result()
246 int status = data->task.tk_status; in nfs_direct_read_release()
288 struct rpc_task *task; in nfs_direct_read_schedule_segment() local
353 task_setup_data.task = &data->task; in nfs_direct_read_schedule_segment()
357 task = rpc_run_task(&task_setup_data); in nfs_direct_read_schedule_segment()
358 if (IS_ERR(task)) in nfs_direct_read_schedule_segment()
360 rpc_put_task(task); in nfs_direct_read_schedule_segment()
364 data->task.tk_pid, in nfs_direct_read_schedule_segment()
466 struct rpc_task *task; in nfs_direct_write_reschedule() local
[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()
333 static void nfs_async_rename_done(struct rpc_task *task, void *calldata) in nfs_async_rename_done() argument
[all …]
|
| D | read.c | 177 struct rpc_task *task; in nfs_initiate_read() local
184 .task = &data->task, in nfs_initiate_read()
198 data->task.tk_pid, in nfs_initiate_read()
204 task = rpc_run_task(&task_setup_data); in nfs_initiate_read()
205 if (IS_ERR(task)) in nfs_initiate_read()
206 return PTR_ERR(task); in nfs_initiate_read()
207 rpc_put_task(task); in nfs_initiate_read()
390 int nfs_readpage_result(struct rpc_task *task, struct nfs_read_data *data) in nfs_readpage_result() argument
394 dprintk("NFS: %s: %5u, (status %d)\n", __func__, task->tk_pid, in nfs_readpage_result()
395 task->tk_status); in nfs_readpage_result()
[all …]
|
| D | nfs4filelayout.c | 85 static int filelayout_async_handle_error(struct rpc_task *task, in filelayout_async_handle_error() argument
93 if (task->tk_status >= 0) in filelayout_async_handle_error()
97 switch (task->tk_status) { in filelayout_async_handle_error()
119 "flags 0x%x\n", __func__, task->tk_status, in filelayout_async_handle_error()
126 rpc_delay(task, FILELAYOUT_POLL_RETRY_MAX); in filelayout_async_handle_error()
132 task->tk_status); in filelayout_async_handle_error()
137 task->tk_status = 0; in filelayout_async_handle_error()
140 rpc_sleep_on(&mds_client->cl_rpcwaitq, task, NULL); in filelayout_async_handle_error()
142 rpc_wake_up_queued_task(&mds_client->cl_rpcwaitq, task); in filelayout_async_handle_error()
148 static int filelayout_read_done_cb(struct rpc_task *task, in filelayout_read_done_cb() argument
[all …]
|
| D | write.c | 847 struct rpc_task *task; in nfs_initiate_write() local
855 .task = &data->task, in nfs_initiate_write()
870 data->task.tk_pid, in nfs_initiate_write()
876 task = rpc_run_task(&task_setup_data); in nfs_initiate_write()
877 if (IS_ERR(task)) { in nfs_initiate_write()
878 ret = PTR_ERR(task); in nfs_initiate_write()
882 ret = rpc_wait_for_completion_task(task); in nfs_initiate_write()
884 ret = task->tk_status; in nfs_initiate_write()
886 rpc_put_task(task); in nfs_initiate_write()
1124 static void nfs_writeback_done_partial(struct rpc_task *task, void *calldata) in nfs_writeback_done_partial() argument
[all …]
|
| D | proc.c | 72 nfs_async_handle_expired_key(struct rpc_task *task) in nfs_async_handle_expired_key() argument
74 if (task->tk_status != -EKEYEXPIRED) in nfs_async_handle_expired_key()
76 task->tk_status = 0; in nfs_async_handle_expired_key()
77 rpc_restart_call(task); in nfs_async_handle_expired_key()
78 rpc_delay(task, NFS_JUKEBOX_RETRY_TIME); in nfs_async_handle_expired_key()
361 static void nfs_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs_proc_unlink_rpc_prepare() argument
363 rpc_call_start(task); in nfs_proc_unlink_rpc_prepare()
366 static int nfs_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs_proc_unlink_done() argument
368 if (nfs_async_handle_expired_key(task)) in nfs_proc_unlink_done()
380 static void nfs_proc_rename_rpc_prepare(struct rpc_task *task, struct nfs_renamedata *data) in nfs_proc_rename_rpc_prepare() argument
[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 && task->tk_status != -EKEYEXPIRED) 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()
431 static void nfs3_proc_unlink_rpc_prepare(struct rpc_task *task, struct nfs_unlinkdata *data) in nfs3_proc_unlink_rpc_prepare() argument
433 rpc_call_start(task); in nfs3_proc_unlink_rpc_prepare()
437 nfs3_proc_unlink_done(struct rpc_task *task, struct inode *dir) in nfs3_proc_unlink_done() argument
440 if (nfs3_async_handle_jukebox(task, dir)) in nfs3_proc_unlink_done()
[all …]
|
| D | callback.c | 33 struct task_struct *task; member
259 if (cb_info->users++ || cb_info->task != NULL) { in nfs_callback_up()
293 cb_info->task = kthread_run(callback_svc, cb_info->rqst, svc_name); in nfs_callback_up()
294 if (IS_ERR(cb_info->task)) { in nfs_callback_up()
295 ret = PTR_ERR(cb_info->task); in nfs_callback_up()
298 cb_info->task = NULL; in nfs_callback_up()
330 if (cb_info->users == 0 && cb_info->task != NULL) { in nfs_callback_down()
331 kthread_stop(cb_info->task); in nfs_callback_down()
336 cb_info->task = NULL; in nfs_callback_down()
|
| D | nfs4_fs.h | 74 struct rpc_task *task; member
233 extern bool nfs4_set_task_privileged(struct rpc_task *task, void *dummy);
236 struct rpc_task *task);
239 struct rpc_task *task);
270 struct rpc_task *task) in nfs4_setup_sequence() argument
344 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 | 225 struct task_struct *task = get_proc_task(inode); in mounts_open_common() local
232 if (!task) in mounts_open_common()
236 nsp = task_nsproxy(task); in mounts_open_common()
239 put_task_struct(task); in mounts_open_common()
245 put_task_struct(task); in mounts_open_common()
250 task_lock(task); in mounts_open_common()
251 if (!task->fs) { in mounts_open_common()
252 task_unlock(task); in mounts_open_common()
253 put_task_struct(task); in mounts_open_common()
257 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()
|
| /fs/nfsd/ |
| D | nfs4callback.c | 700 static void nfsd4_cb_probe_done(struct rpc_task *task, void *calldata) in nfsd4_cb_probe_done() argument
704 if (task->tk_status) in nfsd4_cb_probe_done()
705 nfsd4_mark_cb_down(clp, task->tk_status); in nfsd4_cb_probe_done()
783 static bool nfsd41_cb_get_slot(struct nfs4_client *clp, struct rpc_task *task) in nfsd41_cb_get_slot() argument
786 rpc_sleep_on(&clp->cl_cb_waitq, task, NULL); in nfsd41_cb_get_slot()
797 static void nfsd4_cb_prepare(struct rpc_task *task, void *calldata) in nfsd4_cb_prepare() argument
806 if (!nfsd41_cb_get_slot(clp, task)) in nfsd4_cb_prepare()
816 rpc_call_start(task); in nfsd4_cb_prepare()
819 static void nfsd4_cb_done(struct rpc_task *task, void *calldata) in nfsd4_cb_done() argument
837 task->tk_msg.rpc_resp = NULL; in nfsd4_cb_done()
[all …]
|
| /fs/nfs/objlayout/ |
| D | objlayout.c | 242 struct rpc_task *task; in _rpc_read_complete() local
246 task = container_of(work, struct rpc_task, u.tk_work); in _rpc_read_complete()
247 rdata = container_of(task, struct nfs_read_data, task); in _rpc_read_complete()
257 oir->status = rdata->task.tk_status = status; in objlayout_read_done()
271 INIT_WORK(&rdata->task.u.tk_work, _rpc_read_complete); in objlayout_read_done()
272 schedule_work(&rdata->task.u.tk_work); in objlayout_read_done()
323 struct rpc_task *task; in _rpc_write_complete() local
327 task = container_of(work, struct rpc_task, u.tk_work); in _rpc_write_complete()
328 wdata = container_of(task, struct nfs_write_data, task); in _rpc_write_complete()
338 oir->status = wdata->task.tk_status = status; in objlayout_write_done()
[all …]
|
| /fs/ecryptfs/ |
| D | messaging.c | 68 (*msg_ctx)->task = current; in ecryptfs_acquire_free_msg_ctx()
165 (*daemon)->task = current; in ecryptfs_spawn_daemon()
206 if (daemon->task) in ecryptfs_exorcise_daemon()
207 wake_up_process(daemon->task); in ecryptfs_exorcise_daemon()
297 nsproxy = task_nsproxy(msg_ctx->task); in ecryptfs_process_response()
306 tsk_user_ns = __task_cred(msg_ctx->task)->user->user_ns; in ecryptfs_process_response()
307 ctx_euid = task_euid(msg_ctx->task); in ecryptfs_process_response()
364 wake_up_process(msg_ctx->task); in ecryptfs_process_response()
523 ecryptfs_msg_ctx_arr[i].task = NULL; in ecryptfs_init_messaging()
|
| /fs/nfs/blocklayout/ |
| D | blocklayout.c | 225 struct rpc_task *task; in bl_read_cleanup() local
228 task = container_of(work, struct rpc_task, u.tk_work); in bl_read_cleanup()
229 rdata = container_of(task, struct nfs_read_data, task); in bl_read_cleanup()
238 rdata->task.tk_status = rdata->pnfs_error; in bl_end_par_io_read()
239 INIT_WORK(&rdata->task.u.tk_work, bl_read_cleanup); in bl_end_par_io_read()
240 schedule_work(&rdata->task.u.tk_work); in bl_end_par_io_read()
403 struct rpc_task *task; in bl_write_cleanup() local
406 task = container_of(work, struct rpc_task, u.tk_work); in bl_write_cleanup()
407 wdata = container_of(task, struct nfs_write_data, task); in bl_write_cleanup()
426 wdata->task.tk_status = wdata->pnfs_error; in bl_end_par_io_write()
[all …]
|