/net/sunrpc/ |
H A D | sched.c | 46 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 D | bc_svc.c | 48 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 D | clnt.c | 60 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 D | xprt.c | 67 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 D | sunrpc.h | 40 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 D | auth_null.c | 64 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 D | auth.c | 657 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 D | auth_unix.c | 144 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 D | stats.c | 135 * 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 D | xprtsock.c | 497 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 D | svc.c | 317 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 D | rpcb_clnt.c | 664 * @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 D | auth_generic.c | 65 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 D | irda_device.c | 55 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 D | auth_gss.c | 419 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 D | cmtp.h | 85 struct task_struct *task; member in struct:cmtp_session
|
H A D | core.c | 377 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 D | transport.c | 431 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 D | sch_atm.c | 65 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 D | bnep.h | 158 struct task_struct *task; member in struct:bnep_session
|
H A D | core.c | 590 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 D | hidp.h | 145 struct task_struct *task; member in struct:hidp_session
|
H A D | core.c | 1042 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 D | net_namespace.c | 632 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 D | ip_vs_sync.c | 1722 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;
|