Lines Matching refs:rqstp
131 extern u32 svc_max_payload(const struct svc_rqst *rqstp);
303 static inline bool svc_thread_should_stop(struct svc_rqst *rqstp) in svc_thread_should_stop() argument
305 if (test_and_clear_bit(SP_NEED_VICTIM, &rqstp->rq_pool->sp_flags)) in svc_thread_should_stop()
306 set_bit(RQ_VICTIM, &rqstp->rq_flags); in svc_thread_should_stop()
308 return test_bit(RQ_VICTIM, &rqstp->rq_flags); in svc_thread_should_stop()
324 static inline void svc_thread_init_status(struct svc_rqst *rqstp, int err) in svc_thread_init_status() argument
326 store_release_wake_up(&rqstp->rq_err, err); in svc_thread_init_status()
346 int (*dispatch)(struct svc_rqst *rqstp);
365 enum svc_auth_status (*pg_authenticate)(struct svc_rqst *rqstp);
396 int (*vs_dispatch)(struct svc_rqst *rqstp);
406 bool (*pc_decode)(struct svc_rqst *rqstp,
409 bool (*pc_encode)(struct svc_rqst *rqstp,
430 bool svc_rqst_replace_page(struct svc_rqst *rqstp,
432 void svc_rqst_release_pages(struct svc_rqst *rqstp);
441 void svc_process(struct svc_rqst *rqstp);
442 void svc_process_bc(struct rpc_rqst *req, struct svc_rqst *rqstp);
447 void svc_reserve(struct svc_rqst *rqstp, int space);
451 const char * svc_proc_name(const struct svc_rqst *rqstp);
452 int svc_encode_result_payload(struct svc_rqst *rqstp,
455 unsigned int svc_fill_write_vector(struct svc_rqst *rqstp,
457 char *svc_fill_symlink_pathname(struct svc_rqst *rqstp,
460 __be32 svc_generic_init_request(struct svc_rqst *rqstp,
478 static inline void svc_reserve_auth(struct svc_rqst *rqstp, int space) in svc_reserve_auth() argument
480 svc_reserve(rqstp, space + rqstp->rq_auth_slack); in svc_reserve_auth()
488 static inline void svcxdr_init_decode(struct svc_rqst *rqstp) in svcxdr_init_decode() argument
490 struct xdr_stream *xdr = &rqstp->rq_arg_stream; in svcxdr_init_decode()
491 struct xdr_buf *buf = &rqstp->rq_arg; in svcxdr_init_decode()
498 xdr_set_scratch_page(xdr, rqstp->rq_scratch_page); in svcxdr_init_decode()
506 static inline void svcxdr_init_encode(struct svc_rqst *rqstp) in svcxdr_init_encode() argument
508 struct xdr_stream *xdr = &rqstp->rq_res_stream; in svcxdr_init_encode()
509 struct xdr_buf *buf = &rqstp->rq_res; in svcxdr_init_encode()
520 buf->buflen = PAGE_SIZE * (rqstp->rq_page_end - buf->pages); in svcxdr_init_encode()
535 static inline void svcxdr_encode_opaque_pages(struct svc_rqst *rqstp, in svcxdr_encode_opaque_pages() argument
542 xdr->page_ptr = rqstp->rq_next_page - 1; in svcxdr_encode_opaque_pages()
553 static inline void svcxdr_set_auth_slack(struct svc_rqst *rqstp, int slack) in svcxdr_set_auth_slack() argument
555 struct xdr_stream *xdr = &rqstp->rq_res_stream; in svcxdr_set_auth_slack()
556 struct xdr_buf *buf = &rqstp->rq_res; in svcxdr_set_auth_slack()
559 rqstp->rq_auth_slack = slack; in svcxdr_set_auth_slack()
562 buf->buflen -= rqstp->rq_auth_slack; in svcxdr_set_auth_slack()
576 static inline bool svcxdr_set_accept_stat(struct svc_rqst *rqstp) in svcxdr_set_accept_stat() argument
578 struct xdr_stream *xdr = &rqstp->rq_res_stream; in svcxdr_set_accept_stat()
580 rqstp->rq_accept_statp = xdr_reserve_space(xdr, XDR_UNIT); in svcxdr_set_accept_stat()
581 if (unlikely(!rqstp->rq_accept_statp)) in svcxdr_set_accept_stat()
583 *rqstp->rq_accept_statp = rpc_success; in svcxdr_set_accept_stat()