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, wait_bit_action_f *action) 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
451 rpc_wake_up_queued_task(struct rpc_wait_queue *queue, struct rpc_task *task) argument
465 struct rpc_task *task; local
524 struct rpc_task *task = NULL; local
542 rpc_wake_up_next_func(struct rpc_task *task, void *data) argument
570 struct rpc_task *task; local
599 struct rpc_task *task; local
617 struct rpc_task *task, *n; local
638 __rpc_atrun(struct rpc_task *task) argument
647 rpc_delay(struct rpc_task *task, unsigned long delay) argument
657 rpc_prepare_task(struct rpc_task *task) argument
663 rpc_init_task_statistics(struct rpc_task *task) argument
675 rpc_reset_task_statistics(struct rpc_task *task) argument
686 rpc_exit_task(struct rpc_task *task) argument
700 rpc_exit(struct rpc_task *task, int status) argument
718 __rpc_execute(struct rpc_task *task) argument
812 rpc_execute(struct rpc_task *task) argument
844 rpc_malloc(struct rpc_task *task, size_t size) argument
897 rpc_init_task(struct rpc_task *task, const struct rpc_task_setup *task_setup_data) argument
932 struct rpc_task *task = setup_data->task; local
970 rpc_free_task(struct rpc_task *task) argument
987 rpc_release_resources_task(struct rpc_task *task) argument
997 rpc_final_put_task(struct rpc_task *task, struct workqueue_struct *q) argument
1007 rpc_do_put_task(struct rpc_task *task, struct workqueue_struct *q) argument
1015 rpc_put_task(struct rpc_task *task) argument
1021 rpc_put_task_async(struct rpc_task *task) argument
1027 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);
861 rpc_task_release_client(struct rpc_task *task) argument
877 rpc_task_set_client(struct rpc_task *task, struct rpc_clnt *clnt) argument
903 rpc_task_reset_client(struct rpc_task *task, struct rpc_clnt *clnt) argument
912 rpc_task_set_rpc_message(struct rpc_task *task, const struct rpc_message *msg) argument
927 rpc_default_callback(struct rpc_task *task, void *data) argument
941 struct rpc_task *task; local
968 struct rpc_task *task; local
1005 struct rpc_task *task; local
1032 struct rpc_task *task; local
1068 rpc_call_start(struct rpc_task *task) argument
1372 rpc_restart_call_prepare(struct rpc_task *task) argument
1389 rpc_restart_call(struct rpc_task *task) argument
1400 rpc_proc_name(const struct rpc_task *task) argument
1421 call_start(struct rpc_task *task) argument
1440 call_reserve(struct rpc_task *task) argument
1455 call_reserveresult(struct rpc_task *task) argument
1508 call_retry_reserve(struct rpc_task *task) argument
1521 call_refresh(struct rpc_task *task) argument
1535 call_refreshresult(struct rpc_task *task) argument
1574 call_allocate(struct rpc_task *task) argument
1622 rpc_task_need_encode(struct rpc_task *task) argument
1628 rpc_task_force_reencode(struct rpc_task *task) argument
1650 rpc_xdr_encode(struct rpc_task *task) argument
1684 call_bind(struct rpc_task *task) argument
1702 call_bind_status(struct rpc_task *task) argument
1779 call_connect(struct rpc_task *task) argument
1804 call_connect_status(struct rpc_task *task) argument
1842 call_transmit(struct rpc_task *task) argument
1887 call_transmit_status(struct rpc_task *task) argument
1940 call_bc_transmit(struct rpc_task *task) argument
2002 call_status(struct rpc_task *task) argument
2073 call_timeout(struct rpc_task *task) argument
2130 call_decode(struct rpc_task *task) argument
2200 rpc_encode_header(struct rpc_task *task) argument
2221 rpc_verify_header(struct rpc_task *task) argument
2431 rpc_show_task(const struct rpc_clnt *clnt, const struct rpc_task *task) argument
2449 struct rpc_task *task; local
[all...]
H A Dxprt.c67 static void xprt_connect_status(struct rpc_task *task);
172 * @task: task that is requesting access to the transport
179 int xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
181 struct rpc_rqst *req = task->tk_rqstp;
185 if (task == xprt->snd_task)
189 xprt->snd_task = task;
197 task->tk_pid, xprt);
198 task->tk_timeout = 0;
199 task
230 xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
265 xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) argument
275 __xprt_lock_write_func(struct rpc_task *task, void *data) argument
297 __xprt_lock_write_cong_func(struct rpc_task *task, void *data) argument
334 xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
356 xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
370 xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) argument
382 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
417 xprt_release_rqst_cong(struct rpc_task *task) argument
441 xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) argument
489 xprt_wait_for_buffer_space(struct rpc_task *task, rpc_action action) argument
525 xprt_set_retrans_timeout_def(struct rpc_task *task) argument
537 xprt_set_retrans_timeout_rtt(struct rpc_task *task) argument
696 xprt_connect(struct rpc_task *task) argument
729 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
889 xprt_end_transmit(struct rpc_task *task) argument
900 xprt_transmit(struct rpc_task *task) argument
964 xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task) argument
976 xprt_throttle_congested(struct rpc_xprt *xprt, struct rpc_task *task) argument
1016 xprt_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) argument
1051 xprt_lock_and_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) argument
1138 xprt_reserve(struct rpc_task *task) argument
1164 xprt_retry_reserve(struct rpc_task *task) argument
1190 xprt_request_init(struct rpc_task *task, struct rpc_xprt *xprt) argument
1217 xprt_release(struct rpc_task *task) argument
[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 Dauth_null.c64 nul_marshal(struct rpc_task *task, __be32 *p) argument
78 nul_refresh(struct rpc_task *task) argument
80 set_bit(RPCAUTH_CRED_UPTODATE, &task->tk_rqstp->rq_cred->cr_flags);
85 nul_validate(struct rpc_task *task, __be32 *p) argument
H A Dauth.c657 rpcauth_generic_bind_cred(struct rpc_task *task, struct rpc_cred *cred, int lookupflags) argument
659 dprintk("RPC: %5u holding %s cred %p\n", task->tk_pid,
666 rpcauth_bind_root_cred(struct rpc_task *task, int lookupflags) argument
668 struct rpc_auth *auth = task->tk_client->cl_auth;
675 task->tk_pid, task->tk_client->cl_auth->au_ops->au_name);
680 rpcauth_bind_new_cred(struct rpc_task *task, int lookupflags) argument
682 struct rpc_auth *auth = task->tk_client->cl_auth;
685 task->tk_pid, auth->au_ops->au_name);
690 rpcauth_bindcred(struct rpc_task *task, struc argument
749 rpcauth_marshcred(struct rpc_task *task, __be32 *p) argument
760 rpcauth_checkverf(struct rpc_task *task, __be32 *p) argument
780 rpcauth_wrap_req(struct rpc_task *task, kxdreproc_t encode, void *rqstp, __be32 *data, void *obj) argument
805 rpcauth_unwrap_resp(struct rpc_task *task, kxdrdproc_t decode, void *rqstp, __be32 *data, void *obj) argument
820 rpcauth_refreshcred(struct rpc_task *task) argument
843 rpcauth_invalcred(struct rpc_task *task) argument
854 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.c497 static void xs_nospace_callback(struct rpc_task *task) argument
499 struct sock_xprt *transport = container_of(task->tk_rqstp->rq_xprt, struct sock_xprt, xprt);
506 * xs_nospace - place task on wait queue if transmit was incomplete
507 * @task: task to put to sleep
510 static int xs_nospace(struct rpc_task *task) argument
512 struct rpc_rqst *req = task->tk_rqstp;
519 task->tk_pid, req->rq_slen - req->rq_bytes_sent,
535 xprt_wait_for_buffer_space(task, xs_nospace_callback);
561 * @task
570 xs_local_send_request(struct rpc_task *task) argument
626 xs_udp_send_request(struct rpc_task *task) argument
716 xs_tcp_send_request(struct rpc_task *task) argument
799 xs_tcp_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
968 struct rpc_task *task; local
1031 struct rpc_task *task; local
1708 xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task) argument
1807 xs_local_rpcbind(struct rpc_task *task) argument
1999 xs_local_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument
2333 xs_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument
2445 bc_malloc(struct rpc_task *task, size_t size) argument
2512 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));
661 struct task_struct *task = NULL; local
687 task = rqstp->rq_task;
691 return task;
712 struct task_struct *task; local
740 task = kthread_create_on_node(serv->sv_function, rqstp,
742 if (IS_ERR(task)) {
743 error = PTR_ERR(task);
[all...]
H A Drpcb_clnt.c664 * @task: task that is waiting for portmapper request
669 void rpcb_getport_async(struct rpc_task *task) argument
685 clnt = rpcb_find_transport_owner(task->tk_client);
691 task->tk_pid, __func__,
695 * some other task is already attempting to bind the port */
696 rpc_sleep_on(&xprt->binding, task, NULL);
700 task->tk_pid, __func__);
709 task->tk_pid, __func__);
729 task
[all...]
H A Dauth_generic.c65 static struct rpc_cred *generic_bind_cred(struct rpc_task *task, argument
68 struct rpc_auth *auth = task->tk_client->cl_auth;
/net/irda/
H A Dirda_device.c55 static void __irda_task_delete(struct irda_task *task);
166 static void __irda_task_delete(struct irda_task *task) argument
168 del_timer(&task->timer);
170 kfree(task);
173 static void irda_task_delete(struct irda_task *task) argument
175 /* Unregister task */
176 hashbin_remove(tasks, (long) task, NULL);
178 __irda_task_delete(task);
182 * Function irda_task_kick (task)
184 * Tries to execute a task possibl
189 irda_task_kick(struct irda_task *task) argument
260 struct irda_task *task; local
[all...]
/net/sunrpc/auth_gss/
H A Dauth_gss.c419 gss_upcall_callback(struct rpc_task *task) argument
421 struct gss_cred *gss_cred = container_of(task->tk_rqstp->rq_cred,
429 task->tk_status = gss_msg->msg.errno;
558 gss_refresh_upcall(struct rpc_task *task) argument
560 struct rpc_cred *cred = task->tk_rqstp->rq_cred;
570 task->tk_pid, __func__, from_kuid(&init_user_ns, cred->cr_uid));
576 task->tk_timeout = 15*HZ;
577 rpc_sleep_on(&pipe_version_rpc_waitqueue, task, NULL);
587 rpc_sleep_on(&gss_cred->gc_upcall->rpc_waitqueue, task, NULL);
589 task
1212 struct rpc_task *task; local
1477 gss_marshal(struct rpc_task *task, __be32 *p) argument
1532 gss_renew_cred(struct rpc_task *task) argument
1575 gss_refresh(struct rpc_task *task) argument
1599 gss_refresh_null(struct rpc_task *task) argument
1605 gss_validate(struct rpc_task *task, __be32 *p) argument
1823 gss_wrap_req(struct rpc_task *task, kxdreproc_t encode, void *rqstp, __be32 *p, void *obj) argument
1935 gss_unwrap_resp(struct rpc_task *task, kxdrdproc_t decode, void *rqstp, __be32 *p, void *obj) 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/sunrpc/xprtrdma/
H A Dtransport.c431 xprt_rdma_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument
446 if (!RPC_IS_ASYNC(task))
452 * The RDMA allocate/free functions need the task structure as a place
460 xprt_rdma_allocate(struct rpc_task *task, size_t size) argument
462 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt;
473 task->tk_client->cl_prog, task->tk_client->cl_vers,
474 task->tk_msg.rpc_proc->p_proc);
491 if (task->tk_flags & RPC_TASK_SWAPPER)
592 xprt_rdma_send_request(struct rpc_task *task) argument
[all...]
/net/sched/
H A Dsch_atm.c65 struct tasklet_struct task; /* dequeue tasklet */ member in struct:atm_qdisc_data
168 tasklet_schedule(&p->task);
439 tasklet_schedule(&p->task);
506 tasklet_schedule(&p->task);
554 tasklet_init(&p->task, sch_atm_dequeue, (unsigned long)sch);
583 tasklet_kill(&p->task);
/net/bluetooth/bnep/
H A Dbnep.h158 struct task_struct *task; member in struct:bnep_session
H A Dcore.c590 s->task = kthread_run(bnep_session, s, "kbnepd %s", dev->name);
591 if (IS_ERR(s->task)) {
596 err = PTR_ERR(s->task);
622 wake_up_process(s->task);
/net/bluetooth/hidp/
H A Dhidp.h145 struct task_struct *task; member in struct:hidp_session
H A Dcore.c1042 session->task = kthread_run(hidp_session_thread, session,
1044 if (IS_ERR(session->task))
1045 return PTR_ERR(session->task);
1064 wake_up_process(session->task);
/net/core/
H A Dnet_namespace.c632 static void *netns_get(struct task_struct *task) argument
637 task_lock(task);
638 nsproxy = task->nsproxy;
641 task_unlock(task);
/net/netfilter/ipvs/
H A Dip_vs_sync.c1722 struct task_struct **array = NULL, *task; local
1810 task = kthread_run(threadfn, tinfo, name, ipvs->gen, id);
1811 if (IS_ERR(task)) {
1812 result = PTR_ERR(task);
1817 ipvs->ms[id].master_thread = task;
1819 array[id] = task;

Completed in 364 milliseconds

12