Searched refs:xprt (Results 1 - 25 of 31) sorted by relevance

12

/netgear-R7000-V1.0.7.12_1.2.5/components/opensource/linux/linux-2.6.36/net/sunrpc/
H A Dxprt.c2 * 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 Dsvc_xprt.c20 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 Dxprtsock.c197 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 Dbackchannel_rqst.c26 #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 Dbc_svc.c34 #include <linux/sunrpc/xprt.h>
H A Drpcb_clnt.c149 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 DMakefile10 sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \
H A Dsvcsock.c52 #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 Dclnt.c147 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 Dstats.c114 * @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 Dsvcauth_unix.c421 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 Dxprt.h2 * 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 Dbc_xprt.h31 #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 Dsvc_xprt.h50 #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 Dtransport.c154 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 Dsvc_rdma_transport.c57 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 Dsvc_rdma_recvfrom.c128 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 Dsvc_rdma_sendto.c72 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 Drpc_rdma.c370 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 Dxprt_rdma.h52 #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 Dcallback.c179 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 Dcallback.h136 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 Dsvc.c186 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 Dnfsctl.c980 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 Dcls_rsvp.h144 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));

Completed in 301 milliseconds

12