/net/sunrpc/ |
H A D | backchannel_rqst.c | 26 #include <linux/sunrpc/xprt.h> 38 static inline int xprt_need_to_requeue(struct rpc_xprt *xprt) argument 40 return xprt->bc_alloc_count > 0; 43 static inline void xprt_inc_alloc_count(struct rpc_xprt *xprt, unsigned int n) argument 45 xprt->bc_alloc_count += n; 48 static inline int xprt_dec_alloc_count(struct rpc_xprt *xprt, unsigned int n) argument 50 return xprt->bc_alloc_count -= n; 89 int xprt_setup_backchannel(struct rpc_xprt *xprt, unsigned int min_reqs) argument 120 req->rq_xprt = xprt; 159 spin_lock_bh(&xprt 188 xprt_destroy_backchannel(struct rpc_xprt *xprt, unsigned int max_reqs) argument 224 xprt_alloc_bc_request(struct rpc_xprt *xprt) argument 256 struct rpc_xprt *xprt = req->rq_xprt; local [all...] |
H A D | stats.c | 114 * @clnt: RPC program, version, and xprt 183 struct rpc_xprt *xprt; local 194 xprt = rcu_dereference(clnt->cl_xprt); 195 if (xprt) 196 xprt->ops->print_stats(xprt, seq);
|
H A D | xprt.c | 2 * linux/net/sunrpc/xprt.c 65 static void xprt_init(struct rpc_xprt *xprt, struct net *net); 69 static void xprt_destroy(struct rpc_xprt *xprt); 88 #define RPC_MAXCWND(xprt) ((xprt)->max_reqs << RPC_CWNDSHIFT) 90 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd) 182 result = request_module("xprt%s", transport_name); 191 * @xprt 197 xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument 231 xprt_clear_locked(struct rpc_xprt *xprt) argument 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 298 struct rpc_xprt *xprt = data; local 310 __xprt_lock_write_next(struct rpc_xprt *xprt) argument 322 struct rpc_xprt *xprt = data; local 339 __xprt_lock_write_next_cong(struct rpc_xprt *xprt) 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 416 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) argument 447 xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) argument 477 xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status) argument 498 struct rpc_xprt *xprt = req->rq_xprt; local 511 xprt_write_space(struct rpc_xprt *xprt) argument 579 struct rpc_xprt *xprt = req->rq_xprt; local 611 struct rpc_xprt *xprt = local 624 xprt_disconnect_done(struct rpc_xprt *xprt) argument 639 xprt_force_disconnect(struct rpc_xprt *xprt) argument 662 xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie) argument 682 struct rpc_xprt *xprt = (struct rpc_xprt *)data; local 704 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local 737 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local 770 xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid) argument 809 struct rpc_xprt *xprt = req->rq_xprt; local 832 struct rpc_xprt *xprt = req->rq_xprt; local 847 xprt_has_timer(struct rpc_xprt *xprt) argument 860 struct rpc_xprt *xprt = req->rq_xprt; local 891 struct rpc_xprt *xprt = req->rq_xprt; local 951 xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task) argument 957 xprt_wake_up_backlog(struct rpc_xprt *xprt) argument 963 xprt_throttle_congested(struct rpc_xprt *xprt, struct rpc_task *task) argument 979 xprt_dynamic_alloc_slot(struct rpc_xprt *xprt, gfp_t gfp_flags) argument 994 xprt_dynamic_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) 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 1052 xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) argument 1063 xprt_free_all_slots(struct rpc_xprt *xprt) argument 1077 struct rpc_xprt *xprt; local 1111 xprt_free(struct rpc_xprt *xprt) argument 1129 struct rpc_xprt *xprt; local 1155 struct rpc_xprt *xprt; local 1169 xprt_alloc_xid(struct rpc_xprt *xprt) argument 1174 xprt_init_xid(struct rpc_xprt *xprt) argument 1179 xprt_request_init(struct rpc_task *task, struct rpc_xprt *xprt) argument 1202 struct rpc_xprt *xprt; local 1247 xprt_init(struct rpc_xprt *xprt, struct net *net) argument 1282 struct rpc_xprt *xprt; local 1333 xprt_destroy(struct rpc_xprt *xprt) argument 1355 xprt_put(struct rpc_xprt *xprt) argument 1366 xprt_get(struct rpc_xprt *xprt) argument [all...] |
H A D | clnt.c | 292 static struct rpc_clnt * rpc_new_client(const struct rpc_create_args *args, struct rpc_xprt *xprt) argument 301 dprintk("RPC: creating %s client for %s (xprt %p)\n", 302 program->name, args->servername, xprt); 321 rcu_assign_pointer(clnt->cl_xprt, xprt); 336 if (!xprt_bound(xprt)) 339 clnt->cl_timeout = xprt->timeout; 385 xprt_put(xprt); 401 struct rpc_xprt *xprt; local 452 xprt = xprt_create_transport(&xprtargs); 453 if (IS_ERR(xprt)) 501 struct rpc_xprt *xprt; local 750 struct rpc_xprt *xprt; local 947 struct rpc_xprt *xprt; local 974 struct rpc_xprt *xprt; local 1112 struct rpc_xprt *xprt; local 1137 struct rpc_xprt *xprt; local 1434 struct rpc_xprt *xprt = req->rq_xprt; local 1542 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local 1636 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local [all...] |
H A D | rpcb_clnt.c | 148 static void rpcb_wake_rpcbind_waiters(struct rpc_xprt *xprt, int status) argument 150 xprt_clear_binding(xprt); 151 rpc_wake_up_status(&xprt->binding, status); 620 * owner of the xprt. To do so, we walk back up the tree of parents 627 struct rpc_xprt *xprt = rcu_dereference(clnt->cl_xprt); local 630 if (rcu_dereference(parent->cl_xprt) != xprt) 652 struct rpc_xprt *xprt; local 664 xprt = xprt_get(rcu_dereference(clnt->cl_xprt)); 665 } while (xprt == NULL); 670 xprt 786 struct rpc_xprt *xprt = map->r_xprt; local [all...] |
H A D | svc_xprt.c | 16 #include <linux/sunrpc/xprt.h> 21 static struct svc_deferred_req *svc_deferred_dequeue(struct svc_xprt *xprt); 25 static void svc_delete_xprt(struct svc_xprt *xprt); 47 * The XPT_BUSY bit in xprt->xpt_flags prevents a transport being 128 struct svc_xprt *xprt = local 130 struct module *owner = xprt->xpt_class->xcl_owner; 131 if (test_bit(XPT_CACHE_AUTH, &xprt->xpt_flags)) 132 svcauth_unix_info_release(xprt); 133 put_net(xprt->xpt_net); 135 if (xprt 141 svc_xprt_put(struct svc_xprt *xprt) argument 151 svc_xprt_init(struct net *net, struct svc_xprt_class *xcl, struct svc_xprt *xprt, struct svc_serv *serv) argument 219 svc_xprt_received(struct svc_xprt *xprt) argument 283 svc_xprt_copy_addrs(struct svc_rqst *rqstp, struct svc_xprt *xprt) argument 329 svc_xprt_has_something_to_do(struct svc_xprt *xprt) argument 343 svc_xprt_enqueue(struct svc_xprt *xprt) argument 408 struct svc_xprt *xprt; local 438 struct svc_xprt *xprt = rqstp->rq_xprt; local 449 struct svc_xprt *xprt = rqstp->rq_xprt; local 547 struct svc_xprt *xprt = NULL; local 617 struct svc_xprt *xprt; local 711 svc_handle_xprt(struct svc_rqst *rqstp, struct svc_xprt *xprt) argument 759 struct svc_xprt *xprt = NULL; local 824 struct svc_xprt *xprt; local 864 struct svc_xprt *xprt; local 899 call_xpt_users(struct svc_xprt *xprt) argument 915 svc_delete_xprt(struct svc_xprt *xprt) argument 942 svc_close_xprt(struct svc_xprt *xprt) argument 960 struct svc_xprt *xprt; local 978 struct svc_xprt *xprt; local 1000 struct svc_xprt *xprt; local 1040 struct svc_xprt *xprt = dr->xprt; local 1133 svc_deferred_dequeue(struct svc_xprt *xprt) argument 1171 struct svc_xprt *xprt; local 1197 svc_one_xprt_name(const struct svc_xprt *xprt, char *pos, int remaining) argument 1224 struct svc_xprt *xprt; local [all...] |
H A D | svcauth_unix.c | 341 ip_map_cached_get(struct svc_xprt *xprt) argument 346 if (test_bit(XPT_CACHE_AUTH, &xprt->xpt_flags)) { 347 spin_lock(&xprt->xpt_lock); 348 ipm = xprt->xpt_auth_cache; 356 sn = net_generic(xprt->xpt_net, sunrpc_net_id); 357 xprt->xpt_auth_cache = NULL; 358 spin_unlock(&xprt->xpt_lock); 364 spin_unlock(&xprt->xpt_lock); 370 ip_map_cached_put(struct svc_xprt *xprt, struct ip_map *ipm) argument 372 if (test_bit(XPT_CACHE_AUTH, &xprt 664 struct svc_xprt *xprt = rqstp->rq_xprt; local [all...] |
H A D | svcsock.c | 54 #include <linux/sunrpc/xprt.h> 77 static void svc_bc_sock_free(struct svc_xprt *xprt); 637 static int svc_udp_has_wspace(struct svc_xprt *xprt) argument 639 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); 640 struct svc_serv *serv = xprt->xpt_server; 655 static struct svc_xprt *svc_udp_accept(struct svc_xprt *xprt) argument 802 static struct svc_xprt *svc_tcp_accept(struct svc_xprt *xprt) argument 804 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); 1182 static int svc_tcp_has_wspace(struct svc_xprt *xprt) argument 1184 struct svc_sock *svsk = container_of(xprt, struc 1219 svc_bc_tcp_sock_detach(struct svc_xprt *xprt) argument 1534 svc_sock_detach(struct svc_xprt *xprt) argument 1555 svc_tcp_sock_detach(struct svc_xprt *xprt) argument 1572 svc_sock_free(struct svc_xprt *xprt) argument 1595 struct svc_xprt *xprt; local 1618 svc_bc_sock_free(struct svc_xprt *xprt) argument [all...] |
H A D | xprtsock.c | 52 static void xs_close(struct rpc_xprt *xprt); 218 struct rpc_xprt xprt; member in struct:sock_xprt 275 static inline struct sockaddr *xs_addr(struct rpc_xprt *xprt) argument 277 return (struct sockaddr *) &xprt->addr; 280 static inline struct sockaddr_un *xs_addr_un(struct rpc_xprt *xprt) argument 282 return (struct sockaddr_un *) &xprt->addr; 285 static inline struct sockaddr_in *xs_addr_in(struct rpc_xprt *xprt) argument 287 return (struct sockaddr_in *) &xprt->addr; 290 static inline struct sockaddr_in6 *xs_addr_in6(struct rpc_xprt *xprt) argument 292 return (struct sockaddr_in6 *) &xprt 295 xs_format_common_peer_addresses(struct rpc_xprt *xprt) argument 331 xs_format_common_peer_ports(struct rpc_xprt *xprt) argument 343 xs_format_peer_addresses(struct rpc_xprt *xprt, const char *protocol, const char *netid) argument 353 xs_update_peer_port(struct rpc_xprt *xprt) argument 361 xs_free_peer_addresses(struct rpc_xprt *xprt) argument 497 struct rpc_xprt *xprt = req->rq_xprt; local 553 struct rpc_xprt *xprt = req->rq_xprt; local 607 struct rpc_xprt *xprt = req->rq_xprt; local 663 xs_tcp_shutdown(struct rpc_xprt *xprt) argument 689 struct rpc_xprt *xprt = req->rq_xprt; local 759 xs_tcp_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument 827 xs_close(struct rpc_xprt *xprt) argument 844 xs_tcp_close(struct rpc_xprt *xprt) argument 852 xs_local_destroy(struct rpc_xprt *xprt) argument 865 xs_destroy(struct rpc_xprt *xprt) argument 906 struct rpc_xprt *xprt; local 969 struct rpc_xprt *xprt; local 1029 xs_tcp_force_close(struct rpc_xprt *xprt) argument 1035 xs_tcp_read_fraghdr(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1147 xs_tcp_read_common(struct rpc_xprt *xprt, struct xdr_skb_reader *desc, struct rpc_rqst *req) argument 1227 xs_tcp_read_reply(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1263 xs_tcp_read_callback(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1302 _xs_tcp_read_data(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1313 _xs_tcp_read_data(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1324 xs_tcp_read_data(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1357 struct rpc_xprt *xprt = rd_desc->arg.data; local 1403 struct rpc_xprt *xprt; local 1433 xs_tcp_schedule_linger_timeout(struct rpc_xprt *xprt, unsigned long timeout) argument 1446 xs_tcp_cancel_linger_timeout(struct rpc_xprt *xprt) argument 1459 xs_sock_reset_connection_flags(struct rpc_xprt *xprt) argument 1469 xs_sock_mark_closed(struct rpc_xprt *xprt) argument 1483 struct rpc_xprt *xprt; local 1555 struct rpc_xprt *xprt; local 1611 xs_udp_do_set_buffer_size(struct rpc_xprt *xprt) argument 1635 xs_udp_set_buffer_size(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize) argument 1655 xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task) argument 1673 xs_set_port(struct rpc_xprt *xprt, unsigned short port) argument 1745 xs_local_set_port(struct rpc_xprt *xprt, unsigned short port) argument 1813 xs_create_sock(struct rpc_xprt *xprt, struct sock_xprt *transport, int family, int type, int protocol) argument 1838 xs_local_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) argument 1879 struct rpc_xprt *xprt = &transport->xprt; local 1926 xs_local_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument 1950 xs_set_memalloc(struct rpc_xprt *xprt) argument 1965 xs_swapper(struct rpc_xprt *xprt, int enable) argument 1983 xs_set_memalloc(struct rpc_xprt *xprt) argument 1988 xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) argument 2022 struct rpc_xprt *xprt = &transport->xprt; local 2098 xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) argument 2165 struct rpc_xprt *xprt = &transport->xprt; local 2248 xs_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument 2277 xs_local_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument 2306 xs_udp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument 2330 xs_tcp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument 2401 struct rpc_xprt *xprt = req->rq_xprt; local 2430 struct svc_xprt *xprt; local 2465 bc_close(struct rpc_xprt *xprt) argument 2474 bc_destroy(struct rpc_xprt *xprt) argument 2578 struct rpc_xprt *xprt; local 2628 struct rpc_xprt *xprt; local 2693 struct rpc_xprt *xprt; local 2770 struct rpc_xprt *xprt; local 2844 struct rpc_xprt *xprt; local [all...] |
/net/sunrpc/xprtrdma/ |
H A D | svc_rdma_marshal.c | 278 int svc_rdma_xdr_encode_error(struct svcxprt_rdma *xprt, argument 286 *va++ = htonl(xprt->sc_max_requests); 364 void svc_rdma_xdr_encode_reply_header(struct svcxprt_rdma *xprt, argument 371 rdma_resp->rm_credit = htonl(xprt->sc_max_requests);
|
H A D | rpc_rdma.c | 369 struct rpc_xprt *xprt = rqst->rq_xprt; local 370 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); 694 struct rpc_xprt *xprt = ep->rep_xprt; local 696 spin_lock_bh(&xprt->transport_lock); 697 if (++xprt->connect_cookie == 0) /* maintain a reserved value */ 698 ++xprt->connect_cookie; 700 if (!xprt_test_and_set_connected(xprt)) 701 xprt_wake_pending_tasks(xprt, 0); 703 if (xprt_test_and_clear_connected(xprt)) 704 xprt_wake_pending_tasks(xprt, 730 struct rpc_xprt *xprt = rep->rr_xprt; local [all...] |
H A D | svc_rdma_recvfrom.c | 128 static int map_read_chunks(struct svcxprt_rdma *xprt, argument 228 static int fast_reg_read_chunks(struct svcxprt_rdma *xprt, argument 244 frmr = svc_rdma_get_frmr(xprt); 266 ib_dma_map_page(xprt->sc_cm_id->device, 269 if (ib_dma_mapping_error(xprt->sc_cm_id->device, 272 atomic_inc(&xprt->sc_dma_used); 293 ret = svc_rdma_fastreg(xprt, frmr); 300 printk("svcrdma: error fast registering xdr for xprt %p", xprt); 301 svc_rdma_put_frmr(xprt, frm 305 rdma_set_ctxt_sge(struct svcxprt_rdma *xprt, struct svc_rdma_op_ctxt *ctxt, struct svc_rdma_fastreg_mr *frmr, struct kvec *vec, u64 *sgl_offset, int count) argument 343 rdma_read_max_sge(struct svcxprt_rdma *xprt, int sge_count) argument 381 rdma_read_xdr(struct svcxprt_rdma *xprt, struct rpcrdma_msg *rmsgp, struct svc_rqst *rqstp, struct svc_rdma_op_ctxt *hdr_ctxt) argument 586 struct svc_xprt *xprt = rqstp->rq_xprt; local [all...] |
H A D | svc_rdma_sendto.c | 72 static int fast_reg_xdr(struct svcxprt_rdma *xprt, argument 84 frmr = svc_rdma_get_frmr(xprt); 107 ib_dma_map_page(xprt->sc_cm_id->device, 112 if (ib_dma_mapping_error(xprt->sc_cm_id->device, 115 atomic_inc(&xprt->sc_dma_used); 135 ib_dma_map_page(xprt->sc_cm_id->device, 138 if (ib_dma_mapping_error(xprt->sc_cm_id->device, 142 atomic_inc(&xprt->sc_dma_used); 173 ib_dma_map_page(xprt->sc_cm_id->device, virt_to_page(va), 177 if (ib_dma_mapping_error(xprt 198 map_xdr(struct svcxprt_rdma *xprt, struct xdr_buf *xdr, struct svc_rdma_req_map *vec) argument 254 dma_map_xdr(struct svcxprt_rdma *xprt, struct xdr_buf *xdr, u32 xdr_off, size_t len, int dir) argument 288 send_write(struct svcxprt_rdma *xprt, struct svc_rqst *rqstp, u32 rmr, u64 to, u32 xdr_off, int write_len, struct svc_rdma_req_map *vec) argument 377 send_write_chunks(struct svcxprt_rdma *xprt, struct rpcrdma_msg *rdma_argp, struct rpcrdma_msg *rdma_resp, struct svc_rqst *rqstp, struct svc_rdma_req_map *vec) argument 448 send_reply_chunks(struct svcxprt_rdma *xprt, struct rpcrdma_msg *rdma_argp, struct rpcrdma_msg *rdma_resp, struct svc_rqst *rqstp, struct svc_rdma_req_map *vec) argument 677 struct svc_xprt *xprt = rqstp->rq_xprt; local [all...] |
H A D | transport.c | 155 xprt_rdma_format_addresses(struct rpc_xprt *xprt) argument 158 &rpcx_to_rdmad(xprt).addr; 163 xprt->address_strings[RPC_DISPLAY_ADDR] = kstrdup(buf, GFP_KERNEL); 166 xprt->address_strings[RPC_DISPLAY_PORT] = kstrdup(buf, GFP_KERNEL); 168 xprt->address_strings[RPC_DISPLAY_PROTO] = "rdma"; 171 xprt->address_strings[RPC_DISPLAY_HEX_ADDR] = kstrdup(buf, GFP_KERNEL); 174 xprt->address_strings[RPC_DISPLAY_HEX_PORT] = kstrdup(buf, GFP_KERNEL); 177 xprt->address_strings[RPC_DISPLAY_NETID] = "rdma"; 181 xprt_rdma_free_addresses(struct rpc_xprt *xprt) argument 191 kfree(xprt 200 struct rpc_xprt *xprt = &r_xprt->xprt; local 229 xprt_rdma_destroy(struct rpc_xprt *xprt) argument 270 struct rpc_xprt *xprt; local 406 xprt_rdma_close(struct rpc_xprt *xprt) argument 418 xprt_rdma_set_port(struct rpc_xprt *xprt, u16 port) argument 430 xprt_rdma_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument 451 xprt_rdma_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument 478 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local 630 struct rpc_xprt *xprt = rqst->rq_xprt; local 668 xprt_rdma_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument [all...] |
H A D | svc_rdma_transport.c | 62 static struct svc_xprt *svc_rdma_accept(struct svc_xprt *xprt); 65 static void svc_rdma_detach(struct svc_xprt *xprt); 66 static void svc_rdma_free(struct svc_xprt *xprt); 67 static int svc_rdma_has_wspace(struct svc_xprt *xprt); 68 static void rq_cq_reap(struct svcxprt_rdma *xprt); 69 static void sq_cq_reap(struct svcxprt_rdma *xprt); 94 struct svc_rdma_op_ctxt *svc_rdma_get_context(struct svcxprt_rdma *xprt) argument 104 ctxt->xprt = xprt; 108 atomic_inc(&xprt 114 struct svcxprt_rdma *xprt = ctxt->xprt; local 135 struct svcxprt_rdma *xprt; local 175 struct svc_xprt *xprt = context; local 184 struct svc_xprt *xprt = context; local 221 struct svcxprt_rdma *xprt; local 248 struct svcxprt_rdma *xprt = cq_context; local 285 rq_cq_reap(struct svcxprt_rdma *xprt) argument 332 process_context(struct svcxprt_rdma *xprt, struct svc_rdma_op_ctxt *ctxt) argument 378 sq_cq_reap(struct svcxprt_rdma *xprt) argument 412 struct svcxprt_rdma *xprt = cq_context; local 487 svc_rdma_post_recv(struct svcxprt_rdma *xprt) argument 592 struct svcxprt_rdma *xprt = cma_id->context; local 628 struct svc_xprt *xprt = cma_id->context; local 675 struct svc_xprt *xprt; local 725 rdma_alloc_frmr(struct svcxprt_rdma *xprt) argument 757 rdma_dealloc_frmr_q(struct svcxprt_rdma *xprt) argument 790 frmr_unmap_dma(struct svcxprt_rdma *xprt, struct svc_rdma_fastreg_mr *frmr) argument 827 svc_rdma_accept(struct svc_xprt *xprt) argument 1107 svc_rdma_detach(struct svc_xprt *xprt) argument 1180 svc_rdma_free(struct svc_xprt *xprt) argument 1188 svc_rdma_has_wspace(struct svc_xprt *xprt) argument 1221 svc_rdma_fastreg(struct svcxprt_rdma *xprt, struct svc_rdma_fastreg_mr *frmr) argument 1245 svc_rdma_send(struct svcxprt_rdma *xprt, struct ib_send_wr *wr) argument 1303 svc_rdma_send_error(struct svcxprt_rdma *xprt, struct rpcrdma_msg *rmsgp, enum rpcrdma_errcode err) argument [all...] |
H A D | verbs.c | 287 struct rpcrdma_xprt *xprt = id->context; local 288 struct rpcrdma_ia *ia = &xprt->rx_ia; 289 struct rpcrdma_ep *ep = &xprt->rx_ep; 369 xprt->rx_buf.rb_max_requests, 383 rpcrdma_create_id(struct rpcrdma_xprt *xprt, argument 391 id = rdma_create_id(rpcrdma_conn_upcall, xprt, RDMA_PS_TCP, IB_QPT_RC); 459 rpcrdma_ia_open(struct rpcrdma_xprt *xprt, struct sockaddr *addr, int memreg) argument 463 struct rpcrdma_ia *ia = &xprt->rx_ia; 465 ia->ri_id = rpcrdma_create_id(xprt, ia, addr); 832 struct rpcrdma_xprt *xprt; local [all...] |
H A D | xprt_rdma.h | 52 #include <linux/sunrpc/xprtrdma.h> /* xprt parameters */ 275 struct rpc_xprt xprt; member in struct:rpcrdma_xprt 284 #define rpcx_to_rdmax(x) container_of(x, struct rpcrdma_xprt, xprt)
|
/net/sched/ |
H A D | cls_rsvp.h | 143 u8 *xprt; local 164 xprt = ((u8 *)nhptr) + sizeof(struct ipv6hdr); 169 xprt = ((u8 *)nhptr) + (nhptr->ihl<<2); 181 (*(u32 *)(xprt + s->dpi.offset) ^ s->dpi.key)) && 191 !(f->spi.mask & (*(u32 *)(xprt + f->spi.offset) ^ f->spi.key)) 207 nhptr = (void *)(xprt + f->tunnelhdr - sizeof(*nhptr));
|