| /net/sunrpc/ |
| D | sched.c | 45 static void rpc_release_task(struct rpc_task *task);
61 rpc_task_timeout(const struct rpc_task *task) in rpc_task_timeout() argument
63 unsigned long timeout = READ_ONCE(task->tk_timeout); in rpc_task_timeout()
80 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) in __rpc_disable_timer() argument
82 if (list_empty(&task->u.tk_wait.timer_list)) in __rpc_disable_timer()
84 task->tk_timeout = 0; in __rpc_disable_timer()
85 list_del(&task->u.tk_wait.timer_list); in __rpc_disable_timer()
106 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task, in __rpc_add_timer() argument
109 task->tk_timeout = timeout; in __rpc_add_timer()
112 list_add(&task->u.tk_wait.timer_list, &queue->timer_list.list); in __rpc_add_timer()
[all …]
|
| D | clnt.c | 58 static void call_start(struct rpc_task *task);
59 static void call_reserve(struct rpc_task *task);
60 static void call_reserveresult(struct rpc_task *task);
61 static void call_allocate(struct rpc_task *task);
62 static void call_encode(struct rpc_task *task);
63 static void call_decode(struct rpc_task *task);
64 static void call_bind(struct rpc_task *task);
65 static void call_bind_status(struct rpc_task *task);
66 static void call_transmit(struct rpc_task *task);
67 static void call_status(struct rpc_task *task);
[all …]
|
| D | xprt.c | 75 static void xprt_request_init(struct rpc_task *task);
266 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_reserve_xprt() argument
268 struct rpc_rqst *req = task->tk_rqstp; in xprt_reserve_xprt()
271 if (task == xprt->snd_task) in xprt_reserve_xprt()
277 xprt->snd_task = task; in xprt_reserve_xprt()
280 trace_xprt_reserve_xprt(xprt, task); in xprt_reserve_xprt()
286 task->tk_status = -EAGAIN; in xprt_reserve_xprt()
287 if (RPC_IS_SOFT(task)) in xprt_reserve_xprt()
288 rpc_sleep_on_timeout(&xprt->sending, task, NULL, in xprt_reserve_xprt()
291 rpc_sleep_on(&xprt->sending, task, NULL); in xprt_reserve_xprt()
[all …]
|
| D | auth.c | 610 rpcauth_bind_root_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_root_cred() argument
612 struct rpc_auth *auth = task->tk_client->cl_auth; in rpcauth_bind_root_cred()
624 rpcauth_bind_machine_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_machine_cred() argument
626 struct rpc_auth *auth = task->tk_client->cl_auth; in rpcauth_bind_machine_cred()
628 .principal = task->tk_client->cl_principal, in rpcauth_bind_machine_cred()
638 rpcauth_bind_new_cred(struct rpc_task *task, int lookupflags) in rpcauth_bind_new_cred() argument
640 struct rpc_auth *auth = task->tk_client->cl_auth; in rpcauth_bind_new_cred()
646 rpcauth_bindcred(struct rpc_task *task, const struct cred *cred, int flags) in rpcauth_bindcred() argument
648 struct rpc_rqst *req = task->tk_rqstp; in rpcauth_bindcred()
651 struct rpc_auth *auth = task->tk_client->cl_auth; in rpcauth_bindcred()
[all …]
|
| D | debugfs.c | 23 struct rpc_task *task = v; in tasks_show() local
24 struct rpc_clnt *clnt = task->tk_client; in tasks_show()
27 if (RPC_IS_QUEUED(task)) in tasks_show()
28 rpc_waitq = rpc_qname(task->tk_waitqueue); in tasks_show()
30 if (task->tk_rqstp) in tasks_show()
31 xid = be32_to_cpu(task->tk_rqstp->rq_xid); in tasks_show()
34 task->tk_pid, task->tk_flags, task->tk_status, in tasks_show()
35 clnt->cl_clid, xid, rpc_task_timeout(task), task->tk_ops, in tasks_show()
36 clnt->cl_program->name, clnt->cl_vers, rpc_proc_name(task), in tasks_show()
37 task->tk_action, rpc_waitq); in tasks_show()
[all …]
|
| D | svc.c | 305 svc_pool_map_set_cpumask(struct task_struct *task, unsigned int pidx) in svc_pool_map_set_cpumask() argument
321 set_cpus_allowed_ptr(task, cpumask_of(node)); in svc_pool_map_set_cpumask()
326 set_cpus_allowed_ptr(task, cpumask_of_node(node)); in svc_pool_map_set_cpumask()
678 struct task_struct *task = NULL; in choose_victim() local
705 task = rqstp->rq_task; in choose_victim()
709 return task; in choose_victim()
717 struct task_struct *task; in svc_start_kthreads() local
732 task = kthread_create_on_node(serv->sv_ops->svo_function, rqstp, in svc_start_kthreads()
734 if (IS_ERR(task)) { in svc_start_kthreads()
737 return PTR_ERR(task); in svc_start_kthreads()
[all …]
|
| D | stats.c | 149 void rpc_count_iostats_metrics(const struct rpc_task *task, in rpc_count_iostats_metrics() argument
152 struct rpc_rqst *req = task->tk_rqstp; in rpc_count_iostats_metrics()
164 op_metrics->om_timeouts += task->tk_timeouts; in rpc_count_iostats_metrics()
171 backlog = ktime_sub(req->rq_xtime, task->tk_start); in rpc_count_iostats_metrics()
177 execute = ktime_sub(now, task->tk_start); in rpc_count_iostats_metrics()
179 if (task->tk_status < 0) in rpc_count_iostats_metrics()
195 void rpc_count_iostats(const struct rpc_task *task, struct rpc_iostats *stats) in rpc_count_iostats() argument
197 rpc_count_iostats_metrics(task, in rpc_count_iostats()
198 &stats[task->tk_msg.rpc_proc->p_statidx]); in rpc_count_iostats()
|
| D | auth_unix.c | 103 unx_marshal(struct rpc_task *task, struct xdr_stream *xdr) in unx_marshal() argument
105 struct rpc_clnt *clnt = task->tk_client; in unx_marshal()
106 struct rpc_cred *cred = task->tk_rqstp->rq_cred; in unx_marshal()
158 unx_refresh(struct rpc_task *task) in unx_refresh() argument
160 set_bit(RPCAUTH_CRED_UPTODATE, &task->tk_rqstp->rq_cred->cr_flags); in unx_refresh()
165 unx_validate(struct rpc_task *task, struct xdr_stream *xdr) in unx_validate() argument
167 struct rpc_auth *auth = task->tk_rqstp->rq_cred->cr_auth; in unx_validate()
|
| D | auth_null.c | 63 nul_marshal(struct rpc_task *task, struct xdr_stream *xdr) in nul_marshal() argument
83 nul_refresh(struct rpc_task *task) in nul_refresh() argument
85 set_bit(RPCAUTH_CRED_UPTODATE, &task->tk_rqstp->rq_cred->cr_flags); in nul_refresh()
90 nul_validate(struct rpc_task *task, struct xdr_stream *xdr) in nul_validate() argument
|
| D | rpcb_clnt.c | 646 void rpcb_getport_async(struct rpc_task *task) in rpcb_getport_async() argument
661 clnt = rpcb_find_transport_owner(task->tk_client); in rpcb_getport_async()
663 xprt = xprt_get(task->tk_xprt); in rpcb_getport_async()
667 rpc_sleep_on_timeout(&xprt->binding, task, in rpcb_getport_async()
704 trace_rpcb_getport(clnt, task, bind_version); in rpcb_getport_async()
711 task->tk_client->cl_timeout); in rpcb_getport_async()
764 task->tk_status = status; in rpcb_getport_async()
|
| D | xprtsock.c | 1309 struct rpc_task *task; in xs_udp_data_read_skb() local
1334 task = rovr->rq_task; in xs_udp_data_read_skb()
1348 xprt_adjust_cwnd(xprt, task, copied); in xs_udp_data_read_skb()
1351 xprt_complete_rqst(task, copied); in xs_udp_data_read_skb()
1623 static void xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task) in xs_udp_timer() argument
1626 xprt_adjust_cwnd(xprt, task, -ETIMEDOUT); in xs_udp_timer()
1762 static void xs_local_rpcbind(struct rpc_task *task) in xs_local_rpcbind() argument
1764 xprt_set_bound(task->tk_xprt); in xs_local_rpcbind()
1957 static void xs_local_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xs_local_connect() argument
1962 if (RPC_IS_ASYNC(task)) { in xs_local_connect()
[all …]
|
| /net/sunrpc/auth_gss/ |
| D | auth_gss.c | 374 gss_upcall_callback(struct rpc_task *task) in gss_upcall_callback() argument
376 struct gss_cred *gss_cred = container_of(task->tk_rqstp->rq_cred, in gss_upcall_callback()
384 task->tk_status = gss_msg->msg.errno; in gss_upcall_callback()
577 gss_refresh_upcall(struct rpc_task *task) in gss_refresh_upcall() argument
579 struct rpc_cred *cred = task->tk_rqstp->rq_cred; in gss_refresh_upcall()
594 task, NULL, jiffies + (15 * HZ)); in gss_refresh_upcall()
605 rpc_sleep_on(&gss_cred->gc_upcall->rpc_waitqueue, task, NULL); in gss_refresh_upcall()
610 rpc_sleep_on(&gss_msg->rpc_waitqueue, task, gss_upcall_callback); in gss_refresh_upcall()
1270 struct rpc_task *task; in gss_send_destroy_context() local
1277 task = rpc_call_null(gss_auth->client, &new->gc_base, in gss_send_destroy_context()
[all …]
|
| /net/sunrpc/xprtrdma/ |
| D | transport.c | 433 xprt_rdma_timer(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_rdma_timer() argument
483 xprt_rdma_connect(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_rdma_connect() argument
489 WARN_ON_ONCE(!xprt_lock_connect(xprt, task, r_xprt)); in xprt_rdma_connect()
511 xprt_rdma_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) in xprt_rdma_alloc_slot() argument
519 task->tk_rqstp = &req->rl_slot; in xprt_rdma_alloc_slot()
520 task->tk_status = 0; in xprt_rdma_alloc_slot()
524 task->tk_status = -ENOMEM; in xprt_rdma_alloc_slot()
525 xprt_add_backlog(xprt, task); in xprt_rdma_alloc_slot()
569 xprt_rdma_allocate(struct rpc_task *task) in xprt_rdma_allocate() argument
571 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_allocate()
[all …]
|
| D | svc_rdma_backchannel.c | 110 xprt_rdma_bc_allocate(struct rpc_task *task) in xprt_rdma_bc_allocate() argument
112 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_bc_allocate()
136 xprt_rdma_bc_free(struct rpc_task *task) in xprt_rdma_bc_free() argument
138 struct rpc_rqst *rqst = task->tk_rqstp; in xprt_rdma_bc_free()
|
| /net/sched/ |
| D | sch_atm.c | 68 struct tasklet_struct task; /* dequeue tasklet */ member
178 tasklet_schedule(&p->task); in sch_atm_pop()
462 tasklet_schedule(&p->task); in atm_tc_enqueue()
475 struct atm_qdisc_data *p = from_tasklet(p, t, task); in sch_atm_dequeue()
529 tasklet_schedule(&p->task); in atm_tc_dequeue()
570 tasklet_setup(&p->task, sch_atm_dequeue); in atm_tc_init()
600 tasklet_kill(&p->task); in atm_tc_destroy()
|
| /net/netfilter/ipvs/ |
| D | ip_vs_sync.c | 198 struct task_struct *task; member
378 wake_up_process(ipvs->master_tinfo[id].task); in sb_queue_tail()
1643 wake_up_process(ipvs->master_tinfo[id].task); in master_wakeup_work_handler()
1754 struct task_struct *task; in start_sync_thread() local
1879 task = kthread_run(threadfn, tinfo, name, ipvs->gen, id); in start_sync_thread()
1880 if (IS_ERR(task)) { in start_sync_thread()
1881 result = PTR_ERR(task); in start_sync_thread()
1884 tinfo->task = task; in start_sync_thread()
1910 if (tinfo->task) in start_sync_thread()
1911 kthread_stop(tinfo->task); in start_sync_thread()
[all …]
|
| /net/bluetooth/cmtp/ |
| D | core.c | 384 session->task = kthread_run(cmtp_session, session, "kcmtpd_ctr_%d", in cmtp_add_connection()
386 if (IS_ERR(session->task)) { in cmtp_add_connection()
388 err = PTR_ERR(session->task); in cmtp_add_connection()
|
| D | cmtp.h | 85 struct task_struct *task; member
|
| D | capi.c | 376 wake_up_process(session->task); in cmtp_reset_ctr()
|
| /net/bluetooth/bnep/ |
| D | core.c | 630 s->task = kthread_run(bnep_session, s, "kbnepd %s", dev->name); in bnep_add_connection()
631 if (IS_ERR(s->task)) { in bnep_add_connection()
636 err = PTR_ERR(s->task); in bnep_add_connection()
|
| D | bnep.h | 152 struct task_struct *task; member
|
| /net/bluetooth/hidp/ |
| D | hidp.h | 145 struct task_struct *task; member
|
| D | core.c | 1060 session->task = kthread_run(hidp_session_thread, session, in hidp_session_start_sync()
1062 if (IS_ERR(session->task)) in hidp_session_start_sync()
1063 return PTR_ERR(session->task); in hidp_session_start_sync()
|
| /net/core/ |
| D | net_namespace.c | 1335 static struct ns_common *netns_get(struct task_struct *task) in netns_get() argument
1340 task_lock(task); in netns_get()
1341 nsproxy = task->nsproxy; in netns_get()
1344 task_unlock(task); in netns_get()
|
| /net/ |
| D | Kconfig | 41 to tasks depending on whether the task is a compat task or not. To
44 which message to actually pass to the task.
|