Searched refs:task (Results 1 - 25 of 30) sorted by relevance

12

/net/sunrpc/
H A Dsched.c46 static void rpc_release_task(struct rpc_task *task);
60 * Disable the timer for a given RPC task. Should be called with
65 __rpc_disable_timer(struct rpc_wait_queue *queue, struct rpc_task *task) argument
67 if (task->tk_timeout == 0)
69 dprintk("RPC: %5u disabling timer\n", task->tk_pid);
70 task->tk_timeout = 0;
71 list_del(&task->u.tk_wait.timer_list);
84 * Set up a timer for the current task.
87 __rpc_add_timer(struct rpc_wait_queue *queue, struct rpc_task *task) argument
89 if (!task
104 struct rpc_task *task; local
137 __rpc_add_wait_queue_priority(struct rpc_wait_queue *queue, struct rpc_task *task, unsigned char queue_priority) argument
167 __rpc_add_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task, unsigned char queue_priority) argument
194 __rpc_remove_wait_queue_priority(struct rpc_task *task) argument
209 __rpc_remove_wait_queue(struct rpc_wait_queue *queue, struct rpc_task *task) argument
262 rpc_task_set_debuginfo(struct rpc_task *task) argument
269 rpc_task_set_debuginfo(struct rpc_task *task) argument
274 rpc_set_active(struct rpc_task *task) argument
286 rpc_complete_task(struct rpc_task *task) argument
312 __rpc_wait_for_completion_task(struct rpc_task *task, int (*action)(void *)) argument
332 rpc_make_runnable(struct rpc_task *task) argument
352 __rpc_sleep_on_priority(struct rpc_wait_queue *q, struct rpc_task *task, rpc_action action, unsigned char queue_priority) argument
369 rpc_sleep_on(struct rpc_wait_queue *q, struct rpc_task *task, rpc_action action) argument
389 rpc_sleep_on_priority(struct rpc_wait_queue *q, struct rpc_task *task, rpc_action action, int priority) argument
416 __rpc_do_wake_up_task(struct rpc_wait_queue *queue, struct rpc_task *task) argument
439 rpc_wake_up_task_queue_locked(struct rpc_wait_queue *queue, struct rpc_task *task) argument
465 rpc_wake_up_queued_task(struct rpc_wait_queue *queue, struct rpc_task *task) argument
479 struct rpc_task *task; local
538 struct rpc_task *task = NULL; local
556 rpc_wake_up_next_func(struct rpc_task *task, void *data) argument
584 struct rpc_task *task; local
613 struct rpc_task *task; local
631 struct rpc_task *task, *n; local
652 __rpc_atrun(struct rpc_task *task) argument
660 rpc_delay(struct rpc_task *task, unsigned long delay) argument
670 rpc_prepare_task(struct rpc_task *task) argument
676 rpc_init_task_statistics(struct rpc_task *task) argument
688 rpc_reset_task_statistics(struct rpc_task *task) argument
699 rpc_exit_task(struct rpc_task *task) argument
713 rpc_exit(struct rpc_task *task, int status) argument
731 __rpc_execute(struct rpc_task *task) argument
826 rpc_execute(struct rpc_task *task) argument
857 rpc_malloc(struct rpc_task *task, size_t size) argument
910 rpc_init_task(struct rpc_task *task, const struct rpc_task_setup *task_setup_data) argument
945 struct rpc_task *task = setup_data->task; local
983 rpc_free_task(struct rpc_task *task) argument
1000 rpc_release_resources_task(struct rpc_task *task) argument
1010 rpc_final_put_task(struct rpc_task *task, struct workqueue_struct *q) argument
1020 rpc_do_put_task(struct rpc_task *task, struct workqueue_struct *q) argument
1028 rpc_put_task(struct rpc_task *task) argument
1034 rpc_put_task_async(struct rpc_task *task) argument
1040 rpc_release_task(struct rpc_task *task) argument
[all...]
H A Dbc_svc.c48 struct rpc_task *task; local
52 task = rpc_run_bc_task(req, &nfs41_callback_ops);
53 if (IS_ERR(task))
54 ret = PTR_ERR(task);
56 WARN_ON_ONCE(atomic_read(&task->tk_count) != 1);
57 ret = task->tk_status;
58 rpc_put_task(task);
H A Dclnt.c60 static void call_start(struct rpc_task *task);
61 static void call_reserve(struct rpc_task *task);
62 static void call_reserveresult(struct rpc_task *task);
63 static void call_allocate(struct rpc_task *task);
64 static void call_decode(struct rpc_task *task);
65 static void call_bind(struct rpc_task *task);
66 static void call_bind_status(struct rpc_task *task);
67 static void call_transmit(struct rpc_task *task);
69 static void call_bc_transmit(struct rpc_task *task);
71 static void call_status(struct rpc_task *task);
725 rpc_task_release_client(struct rpc_task *task) argument
741 rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt) argument
765 rpc_task_reset_client(struct rpc_task *task, struct rpc_clnt *clnt) argument
774 rpc_task_set_rpc_message(struct rpc_task *task, const struct rpc_message *msg) argument
789 rpc_default_callback(struct rpc_task *task, void *data) argument
803 struct rpc_task *task; local
830 struct rpc_task *task; local
867 struct rpc_task *task; local
894 struct rpc_task *task; local
930 rpc_call_start(struct rpc_task *task) argument
1234 rpc_restart_call_prepare(struct rpc_task *task) argument
1250 rpc_restart_call(struct rpc_task *task) argument
1260 rpc_proc_name(const struct rpc_task *task) argument
1281 call_start(struct rpc_task *task) argument
1300 call_reserve(struct rpc_task *task) argument
1315 call_reserveresult(struct rpc_task *task) argument
1368 call_retry_reserve(struct rpc_task *task) argument
1381 call_refresh(struct rpc_task *task) argument
1395 call_refreshresult(struct rpc_task *task) argument
1430 call_allocate(struct rpc_task *task) argument
1478 rpc_task_need_encode(struct rpc_task *task) argument
1484 rpc_task_force_reencode(struct rpc_task *task) argument
1506 rpc_xdr_encode(struct rpc_task *task) argument
1540 call_bind(struct rpc_task *task) argument
1558 call_bind_status(struct rpc_task *task) argument
1634 call_connect(struct rpc_task *task) argument
1655 call_connect_status(struct rpc_task *task) argument
1688 call_transmit(struct rpc_task *task) argument
1730 call_transmit_status(struct rpc_task *task) argument
1780 call_bc_transmit(struct rpc_task *task) argument
1843 call_status(struct rpc_task *task) argument
1906 call_timeout(struct rpc_task *task) argument
1964 call_decode(struct rpc_task *task) argument
2035 rpc_encode_header(struct rpc_task *task) argument
2056 rpc_verify_header(struct rpc_task *task) argument
2263 rpc_show_task(const struct rpc_clnt *clnt, const struct rpc_task *task) argument
2281 struct rpc_task *task; local
[all...]
H A Dsunrpc.h40 static inline int rpc_reply_expected(struct rpc_task *task) argument
42 return (task->tk_msg.rpc_proc != NULL) &&
43 (task->tk_msg.rpc_proc->p_decode != NULL);
H A Dxprt.c67 static void xprt_connect_status(struct rpc_task *task);
190 * @task: task that is requesting access to the transport
197 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
199 struct rpc_rqst *req = task->tk_rqstp;
203 if (task == xprt->snd_task)
207 xprt->snd_task = task;
217 task->tk_pid, xprt);
218 task->tk_timeout = 0;
219 task
250 xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
286 xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) argument
296 __xprt_lock_write_func(struct rpc_task *task, void *data) argument
320 __xprt_lock_write_cong_func(struct rpc_task *task, void *data) argument
358 xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
375 xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
384 xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) argument
396 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
431 xprt_release_rqst_cong(struct rpc_task *task) argument
447 xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) argument
495 xprt_wait_for_buffer_space(struct rpc_task *task, rpc_action action) argument
531 xprt_set_retrans_timeout_def(struct rpc_task *task) argument
543 xprt_set_retrans_timeout_rtt(struct rpc_task *task) argument
702 xprt_connect(struct rpc_task *task) argument
735 xprt_connect_status(struct rpc_task *task) argument
785 xprt_update_rtt(struct rpc_task *task) argument
806 xprt_complete_rqst(struct rpc_task *task, int copied) argument
829 xprt_timer(struct rpc_task *task) argument
857 xprt_prepare_transmit(struct rpc_task *task) argument
877 xprt_end_transmit(struct rpc_task *task) argument
888 xprt_transmit(struct rpc_task *task) argument
951 xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task) argument
963 xprt_throttle_congested(struct rpc_xprt *xprt, struct rpc_task *task) argument
1003 xprt_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) argument
1038 xprt_lock_and_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) argument
1127 xprt_reserve(struct rpc_task *task) argument
1153 xprt_retry_reserve(struct rpc_task *task) argument
1179 xprt_request_init(struct rpc_task *task, struct rpc_xprt *xprt) argument
1200 xprt_release(struct rpc_task *task) argument
[all...]
H A Dauth_null.c62 nul_marshal(struct rpc_task *task, __be32 *p) argument
76 nul_refresh(struct rpc_task *task) argument
78 set_bit(RPCAUTH_CRED_UPTODATE, &task->tk_rqstp->rq_cred->cr_flags);
83 nul_validate(struct rpc_task *task, __be32 *p) argument
H A Dauth.c581 rpcauth_generic_bind_cred(struct rpc_task *task, struct rpc_cred *cred, int lookupflags) argument
583 dprintk("RPC: %5u holding %s cred %p\n", task->tk_pid,
590 rpcauth_bind_root_cred(struct rpc_task *task, int lookupflags) argument
592 struct rpc_auth *auth = task->tk_client->cl_auth;
599 task->tk_pid, task->tk_client->cl_auth->au_ops->au_name);
604 rpcauth_bind_new_cred(struct rpc_task *task, int lookupflags) argument
606 struct rpc_auth *auth = task->tk_client->cl_auth;
609 task->tk_pid, auth->au_ops->au_name);
614 rpcauth_bindcred(struct rpc_task *task, struc argument
673 rpcauth_marshcred(struct rpc_task *task, __be32 *p) argument
684 rpcauth_checkverf(struct rpc_task *task, __be32 *p) argument
704 rpcauth_wrap_req(struct rpc_task *task, kxdreproc_t encode, void *rqstp, __be32 *data, void *obj) argument
729 rpcauth_unwrap_resp(struct rpc_task *task, kxdrdproc_t decode, void *rqstp, __be32 *data, void *obj) argument
744 rpcauth_refreshcred(struct rpc_task *task) argument
767 rpcauth_invalcred(struct rpc_task *task) argument
778 rpcauth_uptodatecred(struct rpc_task *task) argument
[all...]
H A Dauth_unix.c144 unx_marshal(struct rpc_task *task, __be32 *p) argument
146 struct rpc_clnt *clnt = task->tk_client;
147 struct unx_cred *cred = container_of(task->tk_rqstp->rq_cred, struct unx_cred, uc_base);
178 unx_refresh(struct rpc_task *task) argument
180 set_bit(RPCAUTH_CRED_UPTODATE, &task->tk_rqstp->rq_cred->cr_flags);
185 unx_validate(struct rpc_task *task, __be32 *p) argument
203 task->tk_rqstp->rq_cred->cr_auth->au_rslack = (size >> 2) + 2;
H A Dstats.c135 * rpc_count_iostats - tally up per-task stats
136 * @task: completed rpc_task
141 void rpc_count_iostats(const struct rpc_task *task, struct rpc_iostats *stats) argument
143 struct rpc_rqst *req = task->tk_rqstp;
150 op_metrics = &stats[task->tk_msg.rpc_proc->p_statidx];
154 op_metrics->om_timeouts += task->tk_timeouts;
159 delta = ktime_sub(req->rq_xtime, task->tk_start);
164 delta = ktime_sub(ktime_get(), task->tk_start);
H A Dxprtsock.c481 static void xs_nospace_callback(struct rpc_task *task) argument
483 struct sock_xprt *transport = container_of(task->tk_rqstp->rq_xprt, struct sock_xprt, xprt);
490 * xs_nospace - place task on wait queue if transmit was incomplete
491 * @task: task to put to sleep
494 static int xs_nospace(struct rpc_task *task) argument
496 struct rpc_rqst *req = task->tk_rqstp;
502 task->tk_pid, req->rq_slen - req->rq_bytes_sent,
518 xprt_wait_for_buffer_space(task, xs_nospace_callback);
541 * @task
550 xs_local_send_request(struct rpc_task *task) argument
604 xs_udp_send_request(struct rpc_task *task) argument
686 xs_tcp_send_request(struct rpc_task *task) argument
759 xs_tcp_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
905 struct rpc_task *task; local
968 struct rpc_task *task; local
1655 xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task) argument
1738 xs_local_rpcbind(struct rpc_task *task) argument
1926 xs_local_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument
2248 xs_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument
2360 bc_malloc(struct rpc_task *task, size_t size) argument
2427 bc_send_request(struct rpc_task *task) argument
[all...]
H A Dsvc.c317 svc_pool_map_set_cpumask(struct task_struct *task, unsigned int pidx) argument
333 set_cpus_allowed_ptr(task, cpumask_of(node));
338 set_cpus_allowed_ptr(task, cpumask_of_node(node));
663 struct task_struct *task = NULL; local
689 task = rqstp->rq_task;
693 return task;
714 struct task_struct *task; local
742 task = kthread_create_on_node(serv->sv_function, rqstp,
744 if (IS_ERR(task)) {
745 error = PTR_ERR(task);
[all...]
H A Drpcb_clnt.c642 * @task: task that is waiting for portmapper request
647 void rpcb_getport_async(struct rpc_task *task) argument
663 clnt = rpcb_find_transport_owner(task->tk_client);
669 task->tk_pid, __func__,
673 * some other task is already attempting to bind the port */
674 rpc_sleep_on(&xprt->binding, task, NULL);
678 task->tk_pid, __func__);
687 task->tk_pid, __func__);
707 task
[all...]
H A Dauth_generic.c59 static struct rpc_cred *generic_bind_cred(struct rpc_task *task, argument
62 struct rpc_auth *auth = task->tk_client->cl_auth;
/net/irda/
H A Dirda_device.c57 static void __irda_task_delete(struct irda_task *task);
168 static void __irda_task_delete(struct irda_task *task) argument
170 del_timer(&task->timer);
172 kfree(task);
175 static void irda_task_delete(struct irda_task *task) argument
177 /* Unregister task */
178 hashbin_remove(tasks, (long) task, NULL);
180 __irda_task_delete(task);
184 * Function irda_task_kick (task)
186 * Tries to execute a task possibl
191 irda_task_kick(struct irda_task *task) argument
262 struct irda_task *task; local
[all...]
/net/sunrpc/auth_gss/
H A Dauth_gss.c385 gss_upcall_callback(struct rpc_task *task) argument
387 struct gss_cred *gss_cred = container_of(task->tk_rqstp->rq_cred,
395 task->tk_status = gss_msg->msg.errno;
517 gss_refresh_upcall(struct rpc_task *task) argument
519 struct rpc_cred *cred = task->tk_rqstp->rq_cred;
529 task->tk_pid, __func__, from_kuid(&init_user_ns, cred->cr_uid));
530 gss_msg = gss_setup_upcall(task->tk_client, gss_auth, cred);
535 task->tk_timeout = 15*HZ;
536 rpc_sleep_on(&pipe_version_rpc_waitqueue, task, NULL);
546 rpc_sleep_on(&gss_cred->gc_upcall->rpc_waitqueue, task, NUL
991 struct rpc_task *task; local
1157 gss_marshal(struct rpc_task *task, __be32 *p) argument
1212 gss_renew_cred(struct rpc_task *task) argument
1255 gss_refresh(struct rpc_task *task) argument
1279 gss_refresh_null(struct rpc_task *task) argument
1285 gss_validate(struct rpc_task *task, __be32 *p) argument
1500 gss_wrap_req(struct rpc_task *task, kxdreproc_t encode, void *rqstp, __be32 *p, void *obj) argument
1612 gss_unwrap_resp(struct rpc_task *task, kxdrdproc_t decode, void *rqstp, __be32 *p, void *obj) argument
[all...]
/net/sunrpc/xprtrdma/
H A Dtransport.c430 xprt_rdma_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument
445 if (!RPC_IS_ASYNC(task))
451 xprt_rdma_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
464 return xprt_reserve_xprt_cong(xprt, task);
468 * The RDMA allocate/free functions need the task structure as a place
476 xprt_rdma_allocate(struct rpc_task *task, size_t size) argument
478 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;
488 task->tk_client->cl_prog, task->tk_client->cl_vers,
489 task
627 xprt_rdma_send_request(struct rpc_task *task) argument
[all...]
/net/bluetooth/cmtp/
H A Dcmtp.h85 struct task_struct *task; member in struct:cmtp_session
H A Dcore.c377 session->task = kthread_run(cmtp_session, session, "kcmtpd_ctr_%d",
379 if (IS_ERR(session->task)) {
381 err = PTR_ERR(session->task);
389 wake_up_process(session->task);
423 wake_up_process(session->task);
/net/sched/
H A Dsch_atm.c65 struct tasklet_struct task; /* dequeue tasklet */ member in struct:atm_qdisc_data
168 tasklet_schedule(&p->task);
437 tasklet_schedule(&p->task);
504 tasklet_schedule(&p->task);
552 tasklet_init(&p->task, sch_atm_dequeue, (unsigned long)sch);
581 tasklet_kill(&p->task);
/net/bluetooth/bnep/
H A Dbnep.h159 struct task_struct *task; member in struct:bnep_session
H A Dcore.c595 s->task = kthread_run(bnep_session, s, "kbnepd %s", dev->name);
596 if (IS_ERR(s->task)) {
601 err = PTR_ERR(s->task);
627 wake_up_process(s->task);
/net/bluetooth/hidp/
H A Dhidp.h143 struct task_struct *task; member in struct:hidp_session
H A Dcore.c1009 session->task = kthread_run(hidp_session_thread, session,
1011 if (IS_ERR(session->task))
1012 return PTR_ERR(session->task);
1031 wake_up_process(session->task);
/net/core/
H A Dnet_namespace.c630 static void *netns_get(struct task_struct *task) argument
636 nsproxy = task_nsproxy(task);
/net/netfilter/ipvs/
H A Dip_vs_sync.c1703 struct task_struct **array = NULL, *task; local
1791 task = kthread_run(threadfn, tinfo, name, ipvs->gen, id);
1792 if (IS_ERR(task)) {
1793 result = PTR_ERR(task);
1798 ipvs->ms[id].master_thread = task;
1800 array[id] = task;

Completed in 588 milliseconds

12