Lines Matching defs:task
391 gss_upcall_callback(struct rpc_task *task)
393 struct gss_cred *gss_cred = container_of(task->tk_rqstp->rq_cred,
401 task->tk_status = gss_msg->msg.errno;
594 gss_refresh_upcall(struct rpc_task *task)
596 struct rpc_cred *cred = task->tk_rqstp->rq_cred;
611 task, NULL, jiffies + (15 * HZ));
622 rpc_sleep_on(&gss_cred->gc_upcall->rpc_waitqueue, task, NULL);
627 rpc_sleep_on(&gss_msg->rpc_waitqueue, task, gss_upcall_callback);
1289 struct rpc_task *task;
1296 task = rpc_call_null(gss_auth->client, &new->gc_base,
1298 if (!IS_ERR(task))
1299 rpc_put_task(task);
1535 static int gss_marshal(struct rpc_task *task, struct xdr_stream *xdr)
1537 struct rpc_rqst *req = task->tk_rqstp;
1563 trace_rpcgss_seqno(task);
1604 trace_rpcgss_get_mic(task, maj_stat);
1609 static int gss_renew_cred(struct rpc_task *task)
1611 struct rpc_cred *oldcred = task->tk_rqstp->rq_cred;
1626 task->tk_rqstp->rq_cred = new;
1652 gss_refresh(struct rpc_task *task)
1654 struct rpc_cred *cred = task->tk_rqstp->rq_cred;
1662 ret = gss_renew_cred(task);
1665 cred = task->tk_rqstp->rq_cred;
1669 ret = gss_refresh_upcall(task);
1676 gss_refresh_null(struct rpc_task *task)
1682 gss_validate(struct rpc_task *task, struct xdr_stream *xdr)
1684 struct rpc_cred *cred = task->tk_rqstp->rq_cred;
1708 *seq = cpu_to_be32(task->tk_rqstp->rq_seqno);
1734 trace_rpcgss_verify_mic(task, maj_stat);
1741 struct rpc_task *task, struct xdr_stream *xdr)
1743 struct rpc_rqst *rqstp = task->tk_rqstp;
1755 if (rpcauth_wrap_req_encode(task, xdr))
1780 trace_rpcgss_get_mic(task, maj_stat);
1834 struct rpc_task *task, struct xdr_stream *xdr)
1836 struct rpc_rqst *rqstp = task->tk_rqstp;
1852 if (rpcauth_wrap_req_encode(task, xdr))
1903 trace_rpcgss_wrap(task, maj_stat);
1907 static int gss_wrap_req(struct rpc_task *task, struct xdr_stream *xdr)
1909 struct rpc_cred *cred = task->tk_rqstp->rq_cred;
1920 status = rpcauth_wrap_req_encode(task, xdr);
1925 status = rpcauth_wrap_req_encode(task, xdr);
1928 status = gss_wrap_req_integ(cred, ctx, task, xdr);
1931 status = gss_wrap_req_priv(cred, ctx, task, xdr);
1943 * @task: rpc_task for incoming RPC Reply being unwrapped
1944 * @cred: controlling rpc_cred for @task
1949 static void gss_update_rslack(struct rpc_task *task, struct rpc_cred *cred,
1957 trace_rpcgss_update_slack(task, auth);
1962 gss_unwrap_resp_auth(struct rpc_task *task, struct rpc_cred *cred)
1964 gss_update_rslack(task, cred, 0, 0);
1982 gss_unwrap_resp_integ(struct rpc_task *task, struct rpc_cred *cred,
2035 gss_update_rslack(task, cred, 2, 2 + 1 + XDR_QUADLEN(mic.len));
2043 trace_rpcgss_unwrap_failed(task);
2046 trace_rpcgss_bad_seqno(task, rqstp->rq_seqno, seqno);
2049 trace_rpcgss_verify_mic(task, maj_stat);
2054 gss_unwrap_resp_priv(struct rpc_task *task, struct rpc_cred *cred,
2086 gss_update_rslack(task, cred, 2 + ctx->gc_gss_ctx->align,
2091 trace_rpcgss_unwrap_failed(task);
2094 trace_rpcgss_bad_seqno(task, rqstp->rq_seqno, be32_to_cpup(--p));
2097 trace_rpcgss_unwrap(task, maj_stat);
2108 gss_xmit_need_reencode(struct rpc_task *task)
2110 struct rpc_rqst *req = task->tk_rqstp;
2140 trace_rpcgss_need_reencode(task, seq_xmit, ret);
2145 gss_unwrap_resp(struct rpc_task *task, struct xdr_stream *xdr)
2147 struct rpc_rqst *rqstp = task->tk_rqstp;
2158 status = gss_unwrap_resp_auth(task, cred);
2161 status = gss_unwrap_resp_integ(task, cred, ctx, rqstp, xdr);
2164 status = gss_unwrap_resp_priv(task, cred, ctx, rqstp, xdr);
2171 status = rpcauth_unwrap_resp_decode(task, xdr);