| /netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/sunrpc/ |
| H A D | xprt.c | 2 * linux/net/sunrpc/xprt.c
79 #define RPC_MAXCWND(xprt) ((xprt)->max_reqs << RPC_CWNDSHIFT)
81 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd)
93 struct rpc_xprt *xprt = task->tk_xprt; local
96 if (test_and_set_bit(XPRT_LOCKED, &xprt->state)) {
97 if (task == xprt->snd_task)
103 xprt
122 xprt_clear_locked(struct rpc_xprt *xprt) argument
143 struct rpc_xprt *xprt = task->tk_xprt; local
171 xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) argument
181 __xprt_lock_write_next(struct rpc_xprt *xprt) argument
208 __xprt_lock_write_next_cong(struct rpc_xprt *xprt) argument
242 xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
258 xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
266 xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) argument
278 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
298 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
328 struct rpc_xprt *xprt = task->tk_xprt; local
355 xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status) argument
371 struct rpc_xprt *xprt = req->rq_xprt; local
383 xprt_write_space(struct rpc_xprt *xprt) argument
450 struct rpc_xprt *xprt = req->rq_xprt; local
482 struct rpc_xprt *xprt = local
495 xprt_disconnect(struct rpc_xprt *xprt) argument
507 struct rpc_xprt *xprt = (struct rpc_xprt *)data; local
531 struct rpc_xprt *xprt = task->tk_xprt; local
558 struct rpc_xprt *xprt = task->tk_xprt; local
598 xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid) argument
660 struct rpc_xprt *xprt = req->rq_xprt; local
683 struct rpc_xprt *xprt = req->rq_xprt; local
721 struct rpc_xprt *xprt = req->rq_xprt; local
773 struct rpc_xprt *xprt = task->tk_xprt; local
800 struct rpc_xprt *xprt = task->tk_xprt; local
808 xprt_alloc_xid(struct rpc_xprt *xprt) argument
813 xprt_init_xid(struct rpc_xprt *xprt) argument
818 xprt_request_init(struct rpc_task *task, struct rpc_xprt *xprt) argument
840 struct rpc_xprt *xprt = task->tk_xprt; local
897 struct rpc_xprt *xprt; local
957 struct rpc_xprt *xprt = container_of(kref, struct rpc_xprt, kref); local
974 xprt_put(struct rpc_xprt *xprt) argument
984 xprt_get(struct rpc_xprt *xprt) argument
[all...] |
| H A D | xprtsock.c | 210 struct rpc_xprt xprt; member in struct:sock_xprt
258 static void xs_format_peer_addresses(struct rpc_xprt *xprt) argument
260 struct sockaddr_in *addr = (struct sockaddr_in *) &xprt->addr;
268 xprt->address_strings[RPC_DISPLAY_ADDR] = buf;
275 xprt->address_strings[RPC_DISPLAY_PORT] = buf;
277 if (xprt->prot == IPPROTO_UDP)
278 xprt->address_strings[RPC_DISPLAY_PROTO] = "udp";
280 xprt->address_strings[RPC_DISPLAY_PROTO] = "tcp";
287 xprt->prot == IPPROTO_UDP ? "udp" : "tcp");
289 xprt
292 xs_free_peer_addresses(struct rpc_xprt *xprt) argument
413 struct rpc_xprt *xprt = req->rq_xprt; local
450 struct rpc_xprt *xprt = req->rq_xprt; local
504 struct rpc_xprt *xprt = req->rq_xprt; local
572 xs_tcp_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
597 xs_close(struct rpc_xprt *xprt) argument
632 xs_destroy(struct rpc_xprt *xprt) argument
662 struct rpc_xprt *xprt; local
721 xs_tcp_read_fraghdr(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument
787 xs_tcp_read_request(struct rpc_xprt *xprt, struct xdr_skb_reader *desc) argument
882 struct rpc_xprt *xprt = rd_desc->arg.data; local
923 struct rpc_xprt *xprt; local
949 struct rpc_xprt *xprt; local
1011 struct rpc_xprt *xprt; local
1044 struct rpc_xprt *xprt; local
1060 xs_udp_do_set_buffer_size(struct rpc_xprt *xprt) argument
1084 xs_udp_set_buffer_size(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize) argument
1122 xs_set_port(struct rpc_xprt *xprt, unsigned short port) argument
1198 struct rpc_xprt *xprt = &transport->xprt; local
1255 xs_tcp_reuse_connection(struct rpc_xprt *xprt) argument
1285 struct rpc_xprt *xprt = &transport->xprt; local
1385 struct rpc_xprt *xprt = task->tk_xprt; local
1416 xs_udp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument
1436 xs_tcp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument
1492 struct rpc_xprt *xprt; local
1533 struct rpc_xprt *xprt; local
1577 struct rpc_xprt *xprt; local
[all...] |
| H A D | rpcb_clnt.c | 109 struct rpc_xprt *xprt = map->r_xprt; local
111 .rpc_proc = rpcb_next_version[xprt->bind_index].rpc_proc,
133 static void rpcb_wake_rpcbind_waiters(struct rpc_xprt *xprt, int status) argument
135 xprt_clear_binding(xprt);
136 rpc_wake_up_status(&xprt->binding, status);
273 struct rpc_xprt *xprt = task->tk_xprt; local
282 clnt->cl_prog, clnt->cl_vers, xprt->prot);
287 if (xprt_test_and_set_binding(xprt)) {
296 rpc_sleep_on(&xprt->binding, task, NULL, NULL);
299 if (xprt_bound(xprt)) {
371 struct rpc_xprt *xprt = map->r_xprt; local
[all...] |
| H A D | Makefile | 9 sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \
|
| H A D | clnt.c | 103 static struct rpc_clnt * rpc_new_client(struct rpc_xprt *xprt, char *servname, struct rpc_program *program, u32 vers, rpc_authflavor_t flavor) argument
111 dprintk("RPC: creating %s client for %s (xprt %p)\n",
112 program->name, servname, xprt);
115 if (!xprt)
139 clnt->cl_xprt = xprt;
156 rpc_init_rtt(&clnt->cl_rtt_default, xprt->timeout.to_initval);
189 xprt_put(xprt);
206 struct rpc_xprt *xprt; local
209 xprt = xprt_create_transport(args->protocol, args->address,
211 if (IS_ERR(xprt))
576 struct rpc_xprt *xprt = clnt->cl_xprt; local
594 struct rpc_xprt *xprt = clnt->cl_xprt; local
606 struct rpc_xprt *xprt = clnt->cl_xprt; local
750 struct rpc_xprt *xprt = task->tk_xprt; local
862 struct rpc_xprt *xprt = task->tk_xprt; local
928 struct rpc_xprt *xprt = task->tk_xprt; local
[all...] |
| H A D | stats.c | 111 * @clnt: RPC program, version, and xprt
189 struct rpc_xprt *xprt = clnt->cl_xprt; local
199 if (xprt)
200 xprt->ops->print_stats(xprt, seq);
|
| /netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/include/linux/sunrpc/ |
| H A D | xprt.h | 2 * linux/include/linux/sunrpc/xprt.h
77 int rq_cong; /* has incremented xprt->cong */
110 void (*set_buffer_size)(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize);
112 void (*release_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
114 void (*set_port)(struct rpc_xprt *xprt, unsigned short port);
122 void (*close)(struct rpc_xprt *xprt);
123 void (*destroy)(struct rpc_xprt *xprt);
124 void (*print_stats)(struct rpc_xprt *xprt, struct seq_file *seq);
216 void xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task);
217 void xprt_release_xprt_cong(struct rpc_xprt *xprt, struc
222 xprt_skip_transport_header(struct rpc_xprt *xprt, __be32 *p) argument
260 xprt_set_connected(struct rpc_xprt *xprt) argument
265 xprt_clear_connected(struct rpc_xprt *xprt) argument
270 xprt_connected(struct rpc_xprt *xprt) argument
275 xprt_test_and_set_connected(struct rpc_xprt *xprt) argument
280 xprt_test_and_clear_connected(struct rpc_xprt *xprt) argument
285 xprt_clear_connecting(struct rpc_xprt *xprt) argument
292 xprt_connecting(struct rpc_xprt *xprt) argument
297 xprt_test_and_set_connecting(struct rpc_xprt *xprt) argument
302 xprt_set_bound(struct rpc_xprt *xprt) argument
307 xprt_bound(struct rpc_xprt *xprt) argument
312 xprt_clear_bound(struct rpc_xprt *xprt) argument
317 xprt_clear_binding(struct rpc_xprt *xprt) argument
324 xprt_test_and_set_binding(struct rpc_xprt *xprt) argument
[all...] |
| H A D | clnt.h | 14 #include <linux/sunrpc/xprt.h>
|
| /netgear-WNDR4500v2-V1.0.0.60_1.0.38/src/linux/linux-2.6/net/sched/ |
| H A D | cls_rsvp.h | 144 u8 *xprt; local
157 xprt = ((u8*)nhptr) + sizeof(struct ipv6hdr);
162 xprt = ((u8*)nhptr) + (nhptr->ihl<<2);
173 !(s->dpi.mask & (*(u32*)(xprt+s->dpi.offset)^s->dpi.key))
183 !(f->spi.mask & (*(u32*)(xprt+f->spi.offset)^f->spi.key))
198 nhptr = (void*)(xprt + f->tunnelhdr - sizeof(*nhptr));
|