/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/net/sunrpc/ |
H A D | xprt.c | 2 * linux/net/sunrpc/xprt.c 86 #define RPC_MAXCWND(xprt) ((xprt)->max_reqs << RPC_CWNDSHIFT) 88 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd) 180 result = request_module("xprt%s", transport_name); 197 struct rpc_xprt *xprt = req->rq_xprt; local 199 if (test_and_set_bit(XPRT_LOCKED, &xprt->state)) { 200 if (task == xprt 226 xprt_clear_locked(struct rpc_xprt *xprt) argument 247 struct rpc_xprt *xprt = task->tk_xprt; local 276 xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) argument 286 __xprt_lock_write_next(struct rpc_xprt *xprt) argument 313 __xprt_lock_write_next_cong(struct rpc_xprt *xprt) argument 347 xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument 364 xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument 373 xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) argument 385 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument 405 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) argument 436 struct rpc_xprt *xprt = task->tk_xprt; local 464 xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status) argument 481 struct rpc_xprt *xprt = req->rq_xprt; local 494 xprt_write_space(struct rpc_xprt *xprt) argument 565 struct rpc_xprt *xprt = req->rq_xprt; local 597 struct rpc_xprt *xprt = local 610 xprt_disconnect_done(struct rpc_xprt *xprt) argument 625 xprt_force_disconnect(struct rpc_xprt *xprt) argument 648 xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie) argument 668 struct rpc_xprt *xprt = (struct rpc_xprt *)data; local 690 struct rpc_xprt *xprt = task->tk_xprt; local 725 struct rpc_xprt *xprt = task->tk_xprt; local 758 xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid) argument 799 struct rpc_xprt *xprt = req->rq_xprt; local 822 struct rpc_xprt *xprt = req->rq_xprt; local 837 xprt_has_timer(struct rpc_xprt *xprt) argument 850 struct rpc_xprt *xprt = req->rq_xprt; local 881 struct rpc_xprt *xprt = req->rq_xprt; local 937 struct rpc_xprt *xprt = task->tk_xprt; local 955 xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) argument 974 struct rpc_xprt *xprt = task->tk_xprt; local 982 xprt_alloc_xid(struct rpc_xprt *xprt) argument 987 xprt_init_xid(struct rpc_xprt *xprt) argument 992 xprt_request_init(struct rpc_task *task, struct rpc_xprt *xprt) argument 1014 struct rpc_xprt *xprt; local 1055 struct rpc_xprt *xprt; local 1123 struct rpc_xprt *xprt = container_of(kref, struct rpc_xprt, kref); local 1146 xprt_put(struct rpc_xprt *xprt) argument 1156 xprt_get(struct rpc_xprt *xprt) argument [all...] |
H A D | svc_xprt.c | 20 static struct svc_deferred_req *svc_deferred_dequeue(struct svc_xprt *xprt); 45 * 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 xprt->xpt_auth_cache != NULL) 133 svcauth_unix_info_release(xprt->xpt_auth_cache); 134 xprt->xpt_ops->xpo_free(xprt); 138 void svc_xprt_put(struct svc_xprt *xprt) argument 148 svc_xprt_init(struct svc_xprt_class *xcl, struct svc_xprt *xprt, struct svc_serv *serv) argument 251 svc_xprt_copy_addrs(struct svc_rqst *rqstp, struct svc_xprt *xprt) argument 311 svc_xprt_enqueue(struct svc_xprt *xprt) argument 409 struct svc_xprt *xprt; local 432 svc_xprt_received(struct svc_xprt *xprt) argument 461 struct svc_xprt *xprt = rqstp->rq_xprt; local 472 struct svc_xprt *xprt = rqstp->rq_xprt; local 569 struct svc_xprt *xprt = NULL; local 606 struct svc_xprt *xprt = NULL; local 793 struct svc_xprt *xprt; local 832 struct svc_xprt *xprt; local 881 svc_delete_xprt(struct svc_xprt *xprt) argument 913 svc_close_xprt(struct svc_xprt *xprt) argument 929 struct svc_xprt *xprt; local 953 struct svc_xprt *xprt = dr->xprt; local 1044 svc_deferred_dequeue(struct svc_xprt *xprt) argument 1081 struct svc_xprt *xprt; local 1105 svc_one_xprt_name(const struct svc_xprt *xprt, char *pos, int remaining) argument 1132 struct svc_xprt *xprt; local [all...] |
H A D | xprtsock.c | 197 struct rpc_xprt xprt; member in struct:sock_xprt 255 static inline struct sockaddr *xs_addr(struct rpc_xprt *xprt) argument 257 return (struct sockaddr *) &xprt->addr; 260 static inline struct sockaddr_in *xs_addr_in(struct rpc_xprt *xprt) argument 262 return (struct sockaddr_in *) &xprt->addr; 265 static inline struct sockaddr_in6 *xs_addr_in6(struct rpc_xprt *xprt) argument 267 return (struct sockaddr_in6 *) &xprt->addr; 270 static void xs_format_common_peer_addresses(struct rpc_xprt *xprt) argument 272 struct sockaddr *sap = xs_addr(xprt); 278 xprt 295 xs_format_common_peer_ports(struct rpc_xprt *xprt) argument 307 xs_format_peer_addresses(struct rpc_xprt *xprt, const char *protocol, const char *netid) argument 317 xs_update_peer_port(struct rpc_xprt *xprt) argument 325 xs_free_peer_addresses(struct rpc_xprt *xprt) argument 461 struct rpc_xprt *xprt = req->rq_xprt; local 508 struct rpc_xprt *xprt = req->rq_xprt; local 564 xs_tcp_shutdown(struct rpc_xprt *xprt) argument 583 struct rpc_xprt *xprt = req->rq_xprt; local 653 xs_tcp_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument 719 xs_close(struct rpc_xprt *xprt) argument 736 xs_tcp_close(struct rpc_xprt *xprt) argument 749 xs_destroy(struct rpc_xprt *xprt) argument 778 struct rpc_xprt *xprt; local 840 xs_tcp_read_fraghdr(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 952 xs_tcp_read_common(struct rpc_xprt *xprt, struct xdr_skb_reader *desc, struct rpc_rqst *req) argument 1032 xs_tcp_read_reply(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1068 xs_tcp_read_callback(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1107 _xs_tcp_read_data(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1118 _xs_tcp_read_data(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1129 xs_tcp_read_data(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument 1162 struct rpc_xprt *xprt = rd_desc->arg.data; local 1208 struct rpc_xprt *xprt; local 1241 xs_tcp_schedule_linger_timeout(struct rpc_xprt *xprt, unsigned long timeout) argument 1254 xs_tcp_cancel_linger_timeout(struct rpc_xprt *xprt) argument 1267 xs_sock_mark_closed(struct rpc_xprt *xprt) argument 1284 struct rpc_xprt *xprt; local 1359 struct rpc_xprt *xprt; local 1375 struct rpc_xprt *xprt; local 1431 xs_udp_do_set_buffer_size(struct rpc_xprt *xprt) argument 1455 xs_udp_set_buffer_size(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize) argument 1493 xs_set_port(struct rpc_xprt *xprt, unsigned short port) argument 1617 xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) argument 1656 struct rpc_xprt *xprt = &transport->xprt; local 1701 struct rpc_xprt *xprt = &transport->xprt; local 1740 xs_abort_connection(struct rpc_xprt *xprt, struct sock_xprt *transport) argument 1761 xs_tcp_reuse_connection(struct rpc_xprt *xprt, struct sock_xprt *transport) argument 1787 xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) argument 1837 xs_tcp_setup_socket(struct rpc_xprt *xprt, struct sock_xprt *transport, struct socket *(*create_sock)(struct rpc_xprt *, struct sock_xprt *)) argument 1910 xs_create_tcp_sock4(struct rpc_xprt *xprt, struct sock_xprt *transport) argument 1944 struct rpc_xprt *xprt = &transport->xprt; local 1949 xs_create_tcp_sock6(struct rpc_xprt *xprt, struct sock_xprt *transport) argument 1983 struct rpc_xprt *xprt = &transport->xprt; local 2003 struct rpc_xprt *xprt = task->tk_xprt; local 2031 xs_udp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument 2051 xs_tcp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument 2116 struct rpc_xprt *xprt = req->rq_xprt; local 2148 struct svc_xprt *xprt; local 2185 bc_close(struct rpc_xprt *xprt) argument 2194 bc_destroy(struct rpc_xprt *xprt) argument 2250 struct rpc_xprt *xprt; local 2298 struct rpc_xprt *xprt; local 2374 struct rpc_xprt *xprt; local 2444 struct rpc_xprt *xprt; local [all...] |
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 187 xprt_destroy_backchannel(struct rpc_xprt *xprt, unsigned int max_reqs) argument 220 xprt_alloc_bc_request(struct rpc_xprt *xprt) argument 252 struct rpc_xprt *xprt = req->rq_xprt; local [all...] |
H A D | bc_svc.c | 34 #include <linux/sunrpc/xprt.h>
|
H A D | rpcb_clnt.c | 149 static void rpcb_wake_rpcbind_waiters(struct rpc_xprt *xprt, int status) argument 151 xprt_clear_binding(xprt); 152 rpc_wake_up_status(&xprt->binding, status); 535 * owner of the xprt. To do so, we walk back up the tree of parents 566 struct rpc_xprt *xprt; local 576 xprt = clnt->cl_xprt; 580 clnt->cl_server, clnt->cl_prog, clnt->cl_vers, xprt->prot); 584 rpc_sleep_on(&xprt->binding, task, NULL); 586 if (xprt_test_and_set_binding(xprt)) { 593 if (xprt_bound(xprt)) { 694 struct rpc_xprt *xprt = map->r_xprt; local [all...] |
H A D | Makefile | 10 sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \
|
H A D | svcsock.c | 52 #include <linux/sunrpc/xprt.h> 626 static int svc_udp_has_wspace(struct svc_xprt *xprt) argument 628 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); 629 struct svc_serv *serv = xprt->xpt_server; 644 static struct svc_xprt *svc_udp_accept(struct svc_xprt *xprt) argument 785 static struct svc_xprt *svc_tcp_accept(struct svc_xprt *xprt) argument 787 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); 1151 static int svc_tcp_has_wspace(struct svc_xprt *xprt) argument 1153 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); 1157 if (test_bit(XPT_LISTENER, &xprt 1453 svc_sock_detach(struct svc_xprt *xprt) argument 1472 svc_tcp_sock_detach(struct svc_xprt *xprt) argument 1487 svc_sock_free(struct svc_xprt *xprt) argument 1508 struct svc_xprt *xprt = NULL; local 1531 svc_sock_destroy(struct svc_xprt *xprt) argument [all...] |
H A D | clnt.c | 147 static struct rpc_clnt * rpc_new_client(const struct rpc_create_args *args, struct rpc_xprt *xprt) argument 163 dprintk("RPC: creating %s client for %s (xprt %p)\n", 164 program->name, args->servername, xprt); 170 if (!xprt) 195 clnt->cl_xprt = xprt; 213 clnt->cl_timeout = xprt->timeout; 265 xprt_put(xprt); 284 struct rpc_xprt *xprt; local 324 xprt = xprt_create_transport(&xprtargs); 325 if (IS_ERR(xprt)) 770 struct rpc_xprt *xprt = clnt->cl_xprt; local 789 struct rpc_xprt *xprt = clnt->cl_xprt; local 801 struct rpc_xprt *xprt = clnt->cl_xprt; local 1012 struct rpc_xprt *xprt = task->tk_xprt; local 1120 struct rpc_xprt *xprt = task->tk_xprt; local 1210 struct rpc_xprt *xprt = task->tk_xprt; local [all...] |
H A D | stats.c | 114 * @clnt: RPC program, version, and xprt 185 struct rpc_xprt *xprt = clnt->cl_xprt; local 195 if (xprt) 196 xprt->ops->print_stats(xprt, seq);
|
H A D | svcauth_unix.c | 421 struct svc_xprt *xprt = rqstp->rq_xprt; local 423 if (test_bit(XPT_CACHE_AUTH, &xprt->xpt_flags)) { 424 spin_lock(&xprt->xpt_lock); 425 ipm = xprt->xpt_auth_cache; 433 xprt->xpt_auth_cache = NULL; 434 spin_unlock(&xprt->xpt_lock); 440 spin_unlock(&xprt->xpt_lock); 448 struct svc_xprt *xprt = rqstp->rq_xprt; local 450 if (test_bit(XPT_CACHE_AUTH, &xprt->xpt_flags)) { 451 spin_lock(&xprt [all...] |
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/include/linux/sunrpc/ |
H A D | xprt.h | 2 * linux/include/linux/sunrpc/xprt.h 69 int rq_cong; /* has incremented xprt->cong */ 114 void (*set_buffer_size)(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize); 116 void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task); 118 void (*set_port)(struct rpc_xprt *xprt, unsigned short port); 126 void (*close)(struct rpc_xprt *xprt); 127 void (*destroy)(struct rpc_xprt *xprt); 128 void (*print_stats)(struct rpc_xprt *xprt, struct seq_file *seq); 278 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task); 279 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struc 284 xprt_skip_transport_header(struct rpc_xprt *xprt, __be32 *p) argument 321 xprt_set_connected(struct rpc_xprt *xprt) argument 326 xprt_clear_connected(struct rpc_xprt *xprt) argument 331 xprt_connected(struct rpc_xprt *xprt) argument 336 xprt_test_and_set_connected(struct rpc_xprt *xprt) argument 341 xprt_test_and_clear_connected(struct rpc_xprt *xprt) argument 346 xprt_clear_connecting(struct rpc_xprt *xprt) argument 353 xprt_connecting(struct rpc_xprt *xprt) argument 358 xprt_test_and_set_connecting(struct rpc_xprt *xprt) argument 363 xprt_set_bound(struct rpc_xprt *xprt) argument 368 xprt_bound(struct rpc_xprt *xprt) argument 373 xprt_clear_bound(struct rpc_xprt *xprt) argument 378 xprt_clear_binding(struct rpc_xprt *xprt) argument 385 xprt_test_and_set_binding(struct rpc_xprt *xprt) argument [all...] |
H A D | bc_xprt.h | 31 #include <linux/sunrpc/xprt.h> 35 struct rpc_rqst *xprt_alloc_bc_request(struct rpc_xprt *xprt); 51 static inline int xprt_setup_backchannel(struct rpc_xprt *xprt, argument
|
H A D | svc_xprt.h | 50 #define XPT_OLD 9 /* used for xprt aging mark+sweep */ 77 void svc_xprt_enqueue(struct svc_xprt *xprt); 79 void svc_xprt_put(struct svc_xprt *xprt); 80 void svc_xprt_copy_addrs(struct svc_rqst *rqstp, struct svc_xprt *xprt); 81 void svc_close_xprt(struct svc_xprt *xprt); 82 void svc_delete_xprt(struct svc_xprt *xprt); 89 static inline void svc_xprt_get(struct svc_xprt *xprt) argument 91 kref_get(&xprt->xpt_ref); 93 static inline void svc_xprt_set_local(struct svc_xprt *xprt, argument 97 memcpy(&xprt 100 svc_xprt_set_remote(struct svc_xprt *xprt, const struct sockaddr *sa, const size_t salen) argument 134 svc_xprt_local_port(const struct svc_xprt *xprt) argument 139 svc_xprt_remote_port(const struct svc_xprt *xprt) argument [all...] |
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/net/sunrpc/xprtrdma/ |
H A D | transport.c | 154 xprt_rdma_format_addresses(struct rpc_xprt *xprt) argument 157 &rpcx_to_rdmad(xprt).addr; 162 xprt->address_strings[RPC_DISPLAY_ADDR] = kstrdup(buf, GFP_KERNEL); 165 xprt->address_strings[RPC_DISPLAY_PORT] = kstrdup(buf, GFP_KERNEL); 167 xprt->address_strings[RPC_DISPLAY_PROTO] = "rdma"; 170 xprt->address_strings[RPC_DISPLAY_HEX_ADDR] = kstrdup(buf, GFP_KERNEL); 173 xprt->address_strings[RPC_DISPLAY_HEX_PORT] = kstrdup(buf, GFP_KERNEL); 176 xprt->address_strings[RPC_DISPLAY_NETID] = "rdma"; 180 xprt_rdma_free_addresses(struct rpc_xprt *xprt) argument 190 kfree(xprt 199 struct rpc_xprt *xprt = &r_xprt->xprt; local 233 xprt_rdma_destroy(struct rpc_xprt *xprt) argument 277 struct rpc_xprt *xprt; local 422 xprt_rdma_close(struct rpc_xprt *xprt) argument 434 xprt_rdma_set_port(struct rpc_xprt *xprt, u16 port) argument 448 struct rpc_xprt *xprt = (struct rpc_xprt *)task->tk_xprt; local 470 struct rpc_xprt *xprt = task->tk_xprt; local 496 struct rpc_xprt *xprt = task->tk_xprt; local 648 struct rpc_xprt *xprt = task->tk_xprt; local 686 xprt_rdma_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument [all...] |
H A D | svc_rdma_transport.c | 57 static struct svc_xprt *svc_rdma_accept(struct svc_xprt *xprt); 60 static void svc_rdma_detach(struct svc_xprt *xprt); 61 static void svc_rdma_free(struct svc_xprt *xprt); 62 static int svc_rdma_has_wspace(struct svc_xprt *xprt); 63 static void rq_cq_reap(struct svcxprt_rdma *xprt); 64 static void sq_cq_reap(struct svcxprt_rdma *xprt); 92 struct svc_rdma_op_ctxt *svc_rdma_get_context(struct svcxprt_rdma *xprt) argument 102 ctxt->xprt = xprt; 106 atomic_inc(&xprt 112 struct svcxprt_rdma *xprt = ctxt->xprt; local 133 struct svcxprt_rdma *xprt; local 176 struct svc_xprt *xprt = context; local 185 struct svc_xprt *xprt = context; local 222 struct svcxprt_rdma *xprt; local 249 struct svcxprt_rdma *xprt = cq_context; local 286 rq_cq_reap(struct svcxprt_rdma *xprt) argument 333 process_context(struct svcxprt_rdma *xprt, struct svc_rdma_op_ctxt *ctxt) argument 379 sq_cq_reap(struct svcxprt_rdma *xprt) argument 413 struct svcxprt_rdma *xprt = cq_context; local 488 svc_rdma_post_recv(struct svcxprt_rdma *xprt) argument 596 struct svcxprt_rdma *xprt = cma_id->context; local 632 struct svc_xprt *xprt = cma_id->context; local 678 struct svc_xprt *xprt; local 727 rdma_alloc_frmr(struct svcxprt_rdma *xprt) argument 759 rdma_dealloc_frmr_q(struct svcxprt_rdma *xprt) argument 792 frmr_unmap_dma(struct svcxprt_rdma *xprt, struct svc_rdma_fastreg_mr *frmr) argument 829 svc_rdma_accept(struct svc_xprt *xprt) argument 1104 svc_rdma_detach(struct svc_xprt *xprt) argument 1177 svc_rdma_free(struct svc_xprt *xprt) argument 1185 svc_rdma_has_wspace(struct svc_xprt *xprt) argument 1218 svc_rdma_fastreg(struct svcxprt_rdma *xprt, struct svc_rdma_fastreg_mr *frmr) argument 1242 svc_rdma_send(struct svcxprt_rdma *xprt, struct ib_send_wr *wr) argument 1300 svc_rdma_send_error(struct svcxprt_rdma *xprt, struct rpcrdma_msg *rmsgp, enum rpcrdma_errcode err) argument [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_single(xprt->sc_cm_id->device, 269 if (ib_dma_mapping_error(xprt->sc_cm_id->device, 272 atomic_inc(&xprt->sc_dma_used); 292 ret = svc_rdma_fastreg(xprt, frmr); 299 printk("svcrdma: error fast registering xdr for xprt %p", xprt); 300 svc_rdma_put_frmr(xprt, frm 304 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 338 rdma_read_max_sge(struct svcxprt_rdma *xprt, int sge_count) argument 376 rdma_read_xdr(struct svcxprt_rdma *xprt, struct rpcrdma_msg *rmsgp, struct svc_rqst *rqstp, struct svc_rdma_op_ctxt *hdr_ctxt) argument 578 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); 106 ib_dma_map_single(xprt->sc_cm_id->device, 109 if (ib_dma_mapping_error(xprt->sc_cm_id->device, 112 atomic_inc(&xprt->sc_dma_used); 131 ib_dma_map_single(xprt->sc_cm_id->device, 134 if (ib_dma_mapping_error(xprt->sc_cm_id->device, 138 atomic_inc(&xprt->sc_dma_used); 169 ib_dma_map_single(xprt->sc_cm_id->device, va, PAGE_SIZE, 171 if (ib_dma_mapping_error(xprt 192 map_xdr(struct svcxprt_rdma *xprt, struct xdr_buf *xdr, struct svc_rdma_req_map *vec) argument 253 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 341 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 412 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 633 struct svc_xprt *xprt = rqstp->rq_xprt; local [all...] |
H A D | rpc_rdma.c | 370 struct rpc_xprt *xprt = rqst->rq_task->tk_xprt; local 371 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt); 696 struct rpc_xprt *xprt = ep->rep_xprt; local 698 spin_lock_bh(&xprt->transport_lock); 699 if (++xprt->connect_cookie == 0) /* maintain a reserved value */ 700 ++xprt->connect_cookie; 702 if (!xprt_test_and_set_connected(xprt)) 703 xprt_wake_pending_tasks(xprt, 0); 705 if (xprt_test_and_clear_connected(xprt)) 706 xprt_wake_pending_tasks(xprt, 732 struct rpc_xprt *xprt = rep->rr_xprt; local [all...] |
H A D | xprt_rdma.h | 52 #include <linux/sunrpc/xprtrdma.h> /* xprt parameters */ 274 struct rpc_xprt xprt; member in struct:rpcrdma_xprt 283 #define rpcx_to_rdmax(x) container_of(x, struct rpcrdma_xprt, xprt)
|
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/fs/nfs/ |
H A D | callback.c | 179 nfs41_callback_up(struct svc_serv *serv, struct rpc_xprt *xprt) argument 186 bc_xprt = svc_sock_create(serv, xprt->prot); 195 xprt->bc_serv = serv; 209 struct svc_serv *serv, struct rpc_xprt *xprt, 213 *rqstpp = nfs41_callback_up(serv, xprt); 219 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, argument 223 xprt->bc_serv = cb_info->serv; 227 struct svc_serv *serv, struct rpc_xprt *xprt, 233 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, argument 242 int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt) argument 208 nfs_minorversion_callback_svc_setup(u32 minorversion, struct svc_serv *serv, struct rpc_xprt *xprt, struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp)) argument 226 nfs_minorversion_callback_svc_setup(u32 minorversion, struct svc_serv *serv, struct rpc_xprt *xprt, struct svc_rqst **rqstpp, int (**callback_svc)(void *vrqstp)) argument [all...] |
H A D | callback.h | 136 extern int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt);
|
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/fs/lockd/ |
H A D | svc.c | 186 struct svc_xprt *xprt; local 188 xprt = svc_find_xprt(serv, name, family, 0); 189 if (xprt == NULL) 192 svc_xprt_put(xprt);
|
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/fs/nfsd/ |
H A D | nfsctl.c | 980 struct svc_xprt *xprt; local 1007 xprt = svc_find_xprt(nfsd_serv, transport, PF_INET, port); 1008 if (xprt != NULL) { 1009 svc_close_xprt(xprt); 1010 svc_xprt_put(xprt); 1023 struct svc_xprt *xprt; local 1033 xprt = svc_find_xprt(nfsd_serv, transport, AF_UNSPEC, port); 1034 if (xprt == NULL) 1037 svc_close_xprt(xprt); 1038 svc_xprt_put(xprt); [all...] |
/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/net/sched/ |
H A D | cls_rsvp.h | 144 u8 *xprt; local 165 xprt = ((u8*)nhptr) + sizeof(struct ipv6hdr); 170 xprt = ((u8*)nhptr) + (nhptr->ihl<<2); 182 (*(u32*)(xprt+s->dpi.offset)^s->dpi.key)) && 192 !(f->spi.mask & (*(u32*)(xprt+f->spi.offset)^f->spi.key)) 208 nhptr = (void*)(xprt + f->tunnelhdr - sizeof(*nhptr));
|