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

12

/linux-master/net/sunrpc/
H A Dxprt.c3 * linux/net/sunrpc/xprt.c
72 static void xprt_init(struct rpc_xprt *xprt, struct net *net);
73 static __be32 xprt_alloc_xid(struct rpc_xprt *xprt);
74 static void xprt_destroy(struct rpc_xprt *xprt);
247 static void xprt_clear_locked(struct rpc_xprt *xprt) argument
249 xprt->snd_task = NULL;
250 if (!test_bit(XPRT_CLOSE_WAIT, &xprt->state))
251 clear_bit_unlock(XPRT_LOCKED, &xprt->state);
253 queue_work(xprtiod_workqueue, &xprt->task_cleanup);
259 * @xprt
265 xprt_reserve_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
296 xprt_need_congestion_window_wait(struct rpc_xprt *xprt) argument
302 xprt_set_congestion_window_wait(struct rpc_xprt *xprt) argument
314 xprt_test_and_clear_congestion_window_wait(struct rpc_xprt *xprt) argument
329 xprt_reserve_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
364 xprt_lock_write(struct rpc_xprt *xprt, struct rpc_task *task) argument
378 struct rpc_xprt *xprt = data; local
384 __xprt_lock_write_next(struct rpc_xprt *xprt) argument
397 __xprt_lock_write_next_cong(struct rpc_xprt *xprt) argument
419 xprt_release_xprt(struct rpc_xprt *xprt, struct rpc_task *task) argument
437 xprt_release_xprt_cong(struct rpc_xprt *xprt, struct rpc_task *task) argument
447 xprt_release_write(struct rpc_xprt *xprt, struct rpc_task *task) argument
461 __xprt_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
480 __xprt_put_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
499 xprt_request_get_cong(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
526 xprt_clear_congestion_window_wait_locked(struct rpc_xprt *xprt) argument
537 xprt_clear_congestion_window_wait(struct rpc_xprt *xprt) argument
562 xprt_adjust_cwnd(struct rpc_xprt *xprt, struct rpc_task *task, int result) argument
592 xprt_wake_pending_tasks(struct rpc_xprt *xprt, int status) argument
609 xprt_wait_for_buffer_space(struct rpc_xprt *xprt) argument
616 xprt_clear_write_space_locked(struct rpc_xprt *xprt) argument
633 xprt_write_space(struct rpc_xprt *xprt) argument
683 struct rpc_xprt *xprt = req->rq_xprt; local
702 struct rpc_xprt *xprt = req->rq_xprt; local
737 struct rpc_xprt *xprt = local
756 xprt_disconnect_done(struct rpc_xprt *xprt) argument
772 xprt_schedule_autoclose_locked(struct rpc_xprt *xprt) argument
788 xprt_force_disconnect(struct rpc_xprt *xprt) argument
800 xprt_connect_cookie(struct rpc_xprt *xprt) argument
809 struct rpc_xprt *xprt = req->rq_xprt; local
826 xprt_conditional_disconnect(struct rpc_xprt *xprt, unsigned int cookie) argument
840 xprt_has_timer(const struct rpc_xprt *xprt) argument
857 struct rpc_xprt *xprt = from_timer(xprt, t, timer); local
869 xprt_inject_disconnect(struct rpc_xprt *xprt) argument
876 xprt_inject_disconnect(struct rpc_xprt *xprt) argument
881 xprt_lock_connect(struct rpc_xprt *xprt, struct rpc_task *task, void *cookie) argument
901 xprt_unlock_connect(struct rpc_xprt *xprt, void *cookie) argument
925 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local
963 xprt_reconnect_delay(const struct rpc_xprt *xprt) argument
980 xprt_reconnect_backoff(struct rpc_xprt *xprt, unsigned long init_to) argument
1006 xprt_request_rb_find(struct rpc_xprt *xprt, __be32 xid) argument
1028 xprt_request_rb_insert(struct rpc_xprt *xprt, struct rpc_rqst *new) argument
1054 xprt_request_rb_remove(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
1066 xprt_lookup_rqst(struct rpc_xprt *xprt, __be32 xid) argument
1149 struct rpc_xprt *xprt = req->rq_xprt; local
1220 struct rpc_xprt *xprt = req->rq_xprt; local
1239 struct rpc_xprt *xprt = req->rq_xprt; local
1303 struct rpc_xprt *xprt = req->rq_xprt; local
1343 struct rpc_xprt *xprt = req->rq_xprt; local
1401 struct rpc_xprt *xprt = req->rq_xprt; local
1430 struct rpc_xprt *xprt = req->rq_xprt; local
1448 struct rpc_xprt *xprt = req->rq_xprt; local
1480 struct rpc_xprt *xprt = req->rq_xprt; local
1507 struct rpc_xprt *xprt = req->rq_xprt; local
1525 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local
1544 struct rpc_xprt *xprt = req->rq_xprt; local
1623 struct rpc_xprt *xprt = req->rq_xprt; local
1659 xprt_add_backlog(struct rpc_xprt *xprt, struct rpc_task *task) argument
1678 xprt_wake_up_backlog(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
1688 xprt_throttle_congested(struct rpc_xprt *xprt, struct rpc_task *task) argument
1704 xprt_dynamic_alloc_slot(struct rpc_xprt *xprt) argument
1722 xprt_dynamic_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
1732 xprt_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) argument
1770 xprt_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *req) argument
1782 xprt_free_all_slots(struct rpc_xprt *xprt) argument
1799 xprt_alloc_id(struct rpc_xprt *xprt) argument
1811 xprt_free_id(struct rpc_xprt *xprt) argument
1820 struct rpc_xprt *xprt; local
1850 xprt_free(struct rpc_xprt *xprt) argument
1861 xprt_init_connect_cookie(struct rpc_rqst *req, struct rpc_xprt *xprt) argument
1867 xprt_alloc_xid(struct rpc_xprt *xprt) argument
1878 xprt_init_xid(struct rpc_xprt *xprt) argument
1886 struct rpc_xprt *xprt = task->tk_xprt; local
1907 xprt_do_reserve(struct rpc_xprt *xprt, struct rpc_task *task) argument
1924 struct rpc_xprt *xprt = task->tk_xprt; local
1946 struct rpc_xprt *xprt = task->tk_xprt; local
1963 struct rpc_xprt *xprt; local
2022 xprt_init(struct rpc_xprt *xprt, struct net *net) argument
2060 struct rpc_xprt *xprt; local
2101 struct rpc_xprt *xprt = local
2128 xprt_destroy(struct rpc_xprt *xprt) argument
2162 xprt_get(struct rpc_xprt *xprt) argument
2175 xprt_put(struct rpc_xprt *xprt) argument
2182 xprt_set_offline_locked(struct rpc_xprt *xprt, struct rpc_xprt_switch *xps) argument
2191 xprt_set_online_locked(struct rpc_xprt *xprt, struct rpc_xprt_switch *xps) argument
2200 xprt_delete_locked(struct rpc_xprt *xprt, struct rpc_xprt_switch *xps) argument
[all...]
H A Dbackchannel_rqst.c12 #include <linux/sunrpc/xprt.h>
22 unsigned int xprt_bc_max_slots(struct rpc_xprt *xprt) argument
31 static inline int xprt_need_to_requeue(struct rpc_xprt *xprt) argument
33 return xprt->bc_alloc_count < xprt->bc_alloc_max;
75 static struct rpc_rqst *xprt_alloc_bc_req(struct rpc_xprt *xprt) argument
85 req->rq_xprt = xprt;
123 int xprt_setup_backchannel(struct rpc_xprt *xprt, unsigned int min_reqs) argument
125 if (!xprt->ops->bc_setup)
127 return xprt
131 xprt_setup_bc(struct rpc_xprt *xprt, unsigned int min_reqs) argument
202 xprt_destroy_backchannel(struct rpc_xprt *xprt, unsigned int max_reqs) argument
209 xprt_destroy_bc(struct rpc_xprt *xprt, unsigned int max_reqs) argument
236 xprt_get_bc_request(struct rpc_xprt *xprt, __be32 xid, struct rpc_rqst *new) argument
269 struct rpc_xprt *xprt = req->rq_xprt; local
276 struct rpc_xprt *xprt = req->rq_xprt; local
324 xprt_lookup_bc_request(struct rpc_xprt *xprt, __be32 xid) argument
356 struct rpc_xprt *xprt = req->rq_xprt; local
[all...]
H A Dsysfs.h12 struct rpc_xprt *xprt; member in struct:rpc_sysfs_xprt_switch
17 struct rpc_xprt *xprt; member in struct:rpc_sysfs_xprt
29 struct rpc_xprt *xprt, gfp_t gfp_flags);
30 void rpc_sysfs_xprt_switch_destroy(struct rpc_xprt_switch *xprt);
32 struct rpc_xprt *xprt, gfp_t gfp_flags);
33 void rpc_sysfs_xprt_destroy(struct rpc_xprt *xprt);
H A Dsvc_xprt.c18 #include <linux/sunrpc/xprt.h>
30 static struct svc_deferred_req *svc_deferred_dequeue(struct svc_xprt *xprt);
34 static void svc_delete_xprt(struct svc_xprt *xprt);
56 * The XPT_BUSY bit in xprt->xpt_flags prevents a transport being
154 * @xprt: transport instance
159 void svc_xprt_deferred_close(struct svc_xprt *xprt) argument
161 if (!test_and_set_bit(XPT_CLOSE, &xprt->xpt_flags))
162 svc_xprt_enqueue(xprt);
168 struct svc_xprt *xprt = local
170 struct module *owner = xprt
185 svc_xprt_put(struct svc_xprt *xprt) argument
195 svc_xprt_init(struct net *net, struct svc_xprt_class *xcl, struct svc_xprt *xprt, struct svc_serv *serv) argument
233 struct svc_xprt *xprt; local
269 svc_xprt_received(struct svc_xprt *xprt) argument
365 svc_xprt_copy_addrs(struct svc_rqst *rqstp, struct svc_xprt *xprt) argument
392 svc_xprt_slots_in_range(struct svc_xprt *xprt) argument
400 svc_xprt_reserve_slot(struct svc_rqst *rqstp, struct svc_xprt *xprt) argument
413 struct svc_xprt *xprt = rqstp->rq_xprt; local
421 svc_xprt_ready(struct svc_xprt *xprt) argument
456 svc_xprt_enqueue(struct svc_xprt *xprt) argument
485 struct svc_xprt *xprt = NULL; local
505 struct svc_xprt *xprt = rqstp->rq_xprt; local
518 free_deferred(struct svc_xprt *xprt, struct svc_deferred_req *dr) argument
529 struct svc_xprt *xprt = rqstp->rq_xprt; local
615 struct svc_xprt *xprt = NULL; local
761 svc_handle_xprt(struct svc_rqst *rqstp, struct svc_xprt *xprt) argument
859 struct svc_xprt *xprt = rqstp->rq_xprt; local
907 struct svc_xprt *xprt; local
933 struct svc_xprt *xprt; local
975 struct svc_xprt *xprt; local
1003 call_xpt_users(struct svc_xprt *xprt) argument
1019 svc_delete_xprt(struct svc_xprt *xprt) argument
1050 svc_xprt_close(struct svc_xprt *xprt) argument
1069 struct svc_xprt *xprt; local
1086 struct svc_xprt *xprt; local
1144 struct svc_xprt *xprt = dr->xprt; local
1244 svc_deferred_dequeue(struct svc_xprt *xprt) argument
1282 struct svc_xprt *xprt; local
1308 svc_one_xprt_name(const struct svc_xprt *xprt, char *pos, int remaining) argument
1335 struct svc_xprt *xprt; local
[all...]
H A Dsysfs.c68 return xprt_get(x->xprt);
93 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); local
96 if (!xprt) {
100 ret = sprintf(buf, "%s\n", xprt->address_strings[RPC_DISPLAY_ADDR]);
101 xprt_put(xprt);
110 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); local
114 if (!xprt || !xprt_connected(xprt)) {
116 } else if (xprt->ops->get_srcaddr) {
117 ret = xprt
135 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); local
169 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); local
232 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); local
291 struct rpc_xprt *xprt = rpc_sysfs_xprt_kobj_get_xprt(kobj); local
379 struct rpc_sysfs_xprt *xprt; local
498 rpc_sysfs_xprt_alloc(struct kobject *parent, struct rpc_xprt *xprt, gfp_t gfp_flags) argument
546 rpc_sysfs_xprt_switch_setup(struct rpc_xprt_switch *xprt_switch, struct rpc_xprt *xprt, gfp_t gfp_flags) argument
570 rpc_sysfs_xprt_setup(struct rpc_xprt_switch *xprt_switch, struct rpc_xprt *xprt, gfp_t gfp_flags) argument
617 rpc_sysfs_xprt_destroy(struct rpc_xprt *xprt) argument
[all...]
H A Dxprtsock.c64 static void xs_close(struct rpc_xprt *xprt);
67 static void xs_tcp_set_socket_timeouts(struct rpc_xprt *xprt,
235 static inline struct sockaddr *xs_addr(struct rpc_xprt *xprt) argument
237 return (struct sockaddr *) &xprt->addr;
240 static inline struct sockaddr_un *xs_addr_un(struct rpc_xprt *xprt) argument
242 return (struct sockaddr_un *) &xprt->addr;
245 static inline struct sockaddr_in *xs_addr_in(struct rpc_xprt *xprt) argument
247 return (struct sockaddr_in *) &xprt->addr;
250 static inline struct sockaddr_in6 *xs_addr_in6(struct rpc_xprt *xprt) argument
252 return (struct sockaddr_in6 *) &xprt
255 xs_format_common_peer_addresses(struct rpc_xprt *xprt) argument
296 xs_format_common_peer_ports(struct rpc_xprt *xprt) argument
308 xs_format_peer_addresses(struct rpc_xprt *xprt, const char *protocol, const char *netid) argument
318 xs_update_peer_port(struct rpc_xprt *xprt) argument
326 xs_free_peer_addresses(struct rpc_xprt *xprt) argument
616 struct rpc_xprt *xprt = &transport->xprt; local
652 struct rpc_xprt *xprt = &transport->xprt; local
829 struct rpc_xprt *xprt = &transport->xprt; local
889 struct rpc_xprt *xprt = req->rq_xprt; local
932 struct rpc_xprt *xprt = req->rq_xprt; local
1003 struct rpc_xprt *xprt = req->rq_xprt; local
1089 struct rpc_xprt *xprt = req->rq_xprt; local
1192 xs_sock_reset_state_flags(struct rpc_xprt *xprt) argument
1210 xs_sock_reset_connection_flags(struct rpc_xprt *xprt) argument
1230 struct rpc_xprt *xprt; local
1252 struct rpc_xprt *xprt = &transport->xprt; local
1307 xs_close(struct rpc_xprt *xprt) argument
1319 xs_inject_disconnect(struct rpc_xprt *xprt) argument
1326 xs_xprt_free(struct rpc_xprt *xprt) argument
1337 xs_destroy(struct rpc_xprt *xprt) argument
1358 xs_udp_data_read_skb(struct rpc_xprt *xprt, struct sock *sk, struct sk_buff *skb) argument
1452 struct rpc_xprt *xprt; local
1482 xs_tcp_force_close(struct rpc_xprt *xprt) argument
1488 xs_tcp_bc_maxpayload(struct rpc_xprt *xprt) argument
1501 struct rpc_xprt *xprt; local
1521 struct rpc_xprt *xprt; local
1593 struct rpc_xprt *xprt; local
1642 xs_udp_do_set_buffer_size(struct rpc_xprt *xprt) argument
1666 xs_udp_set_buffer_size(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize) argument
1687 xs_udp_timer(struct rpc_xprt *xprt, struct rpc_task *task) argument
1731 xs_set_port(struct rpc_xprt *xprt, unsigned short port) argument
1759 xs_sock_srcport(struct rpc_xprt *xprt) argument
1770 xs_sock_srcaddr(struct rpc_xprt *xprt, char *buf, size_t buflen) argument
1859 xs_local_set_port(struct rpc_xprt *xprt, unsigned short port) argument
1918 xs_create_sock(struct rpc_xprt *xprt, struct sock_xprt *transport, int family, int type, int protocol, bool reuseport) argument
1953 xs_local_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) argument
1993 struct rpc_xprt *xprt = &transport->xprt; local
2050 xs_local_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument
2088 xs_set_memalloc(struct rpc_xprt *xprt) argument
2111 xs_enable_swap(struct rpc_xprt *xprt) argument
2131 xs_disable_swap(struct rpc_xprt *xprt) argument
2142 xs_set_memalloc(struct rpc_xprt *xprt) argument
2147 xs_enable_swap(struct rpc_xprt *xprt) argument
2153 xs_disable_swap(struct rpc_xprt *xprt) argument
2158 xs_udp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) argument
2193 struct rpc_xprt *xprt = &transport->xprt; local
2229 xs_tcp_shutdown(struct rpc_xprt *xprt) argument
2256 xs_tcp_set_socket_timeouts(struct rpc_xprt *xprt, struct socket *sock) argument
2296 xs_tcp_do_set_connect_timeout(struct rpc_xprt *xprt, unsigned long connect_timeout) argument
2315 xs_tcp_set_connect_timeout(struct rpc_xprt *xprt, unsigned long connect_timeout, unsigned long reconnect_timeout) argument
2330 xs_tcp_finish_connecting(struct rpc_xprt *xprt, struct socket *sock) argument
2398 struct rpc_xprt *xprt = &transport->xprt; local
2756 xs_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument
2827 xs_local_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument
2856 xs_udp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument
2880 xs_tcp_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument
2984 struct svc_xprt *xprt; local
3009 bc_close(struct rpc_xprt *xprt) argument
3014 bc_destroy(struct rpc_xprt *xprt) argument
3152 struct rpc_xprt *xprt; local
3203 struct rpc_xprt *xprt; local
3269 struct rpc_xprt *xprt; local
3346 struct rpc_xprt *xprt; local
3428 struct rpc_xprt *xprt; local
3516 struct rpc_xprt *xprt; local
[all...]
H A Dxprtmultipath.c18 #include <linux/sunrpc/xprt.h>
33 struct rpc_xprt *xprt)
35 if (unlikely(xprt_get(xprt) == NULL))
37 list_add_tail_rcu(&xprt->xprt_switch, &xps->xps_xprt_list);
40 xps->xps_net = xprt->xprt_net;
48 * @xprt: pointer to struct rpc_xprt
50 * Adds xprt to the end of the list of struct rpc_xprt in xps.
53 struct rpc_xprt *xprt)
55 if (xprt == NULL)
58 if (xps->xps_net == xprt
32 xprt_switch_add_xprt_locked(struct rpc_xprt_switch *xps, struct rpc_xprt *xprt) argument
52 rpc_xprt_switch_add_xprt(struct rpc_xprt_switch *xps, struct rpc_xprt *xprt) argument
64 xprt_switch_remove_xprt_locked(struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, bool offline) argument
86 rpc_xprt_switch_remove_xprt(struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, bool offline) argument
127 xprt_switch_alloc(struct rpc_xprt *xprt, gfp_t gfp_flags) argument
155 struct rpc_xprt *xprt; local
235 xprt_is_active(const struct rpc_xprt *xprt) argument
435 struct rpc_xprt *xprt; local
614 struct rpc_xprt *xprt; local
631 struct rpc_xprt *xprt; local
[all...]
H A Ddebugfs.c120 static int do_xprt_debugfs(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *numv) argument
127 if (IS_ERR_OR_NULL(xprt->debugfs))
130 xprt->debugfs->d_name.name);
134 strcpy(link, "xprt");
136 len = snprintf(link, sizeof(link), "xprt%d", *nump);
176 struct rpc_xprt *xprt = f->private; local
178 seq_printf(f, "netid: %s\n", xprt->address_strings[RPC_DISPLAY_NETID]);
179 seq_printf(f, "addr: %s\n", xprt->address_strings[RPC_DISPLAY_ADDR]);
180 seq_printf(f, "port: %s\n", xprt->address_strings[RPC_DISPLAY_PORT]);
181 seq_printf(f, "state: 0x%lx\n", xprt
189 struct rpc_xprt *xprt = inode->i_private; local
205 struct rpc_xprt *xprt = inode->i_private; local
220 rpc_xprt_debugfs_register(struct rpc_xprt *xprt) argument
241 rpc_xprt_debugfs_unregister(struct rpc_xprt *xprt) argument
[all...]
H A Dclnt.c269 struct rpc_xprt *xprt,
278 if (!xprt_bound(xprt))
282 rcu_assign_pointer(clnt->cl_xprt, xprt);
371 struct rpc_xprt *xprt,
418 timeout = xprt->timeout;
425 rpc_clnt_set_transport(clnt, xprt, timeout);
426 xprt->main = true;
447 trace_rpc_clnt_new(clnt, xprt, args);
461 xprt_put(xprt);
467 struct rpc_xprt *xprt)
268 rpc_clnt_set_transport(struct rpc_clnt *clnt, struct rpc_xprt *xprt, const struct rpc_timeout *timeout) argument
369 rpc_new_client(const struct rpc_create_args *args, struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, struct rpc_clnt *parent) argument
466 rpc_create_xprt(struct rpc_create_args *args, struct rpc_xprt *xprt) argument
536 struct rpc_xprt *xprt; local
642 struct rpc_xprt *xprt; local
745 struct rpc_xprt *xprt, *old; local
868 struct rpc_xprt *xprt = xprt_iter_get_next(&xpi); local
942 rpc_clnt_disconnect_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *dummy) argument
1092 rpc_task_get_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) argument
1108 rpc_task_release_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) argument
1123 struct rpc_xprt *xprt = task->tk_xprt; local
1154 struct rpc_xprt *xprt; local
1395 struct rpc_xprt *xprt; local
1422 struct rpc_xprt *xprt; local
1561 struct rpc_xprt *xprt; local
1586 struct rpc_xprt *xprt; local
1638 struct rpc_xprt *xprt; local
1651 struct rpc_xprt *xprt; local
1885 struct rpc_xprt *xprt = req->rq_xprt; local
2039 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local
2064 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local
2144 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local
2174 struct rpc_xprt *xprt = task->tk_rqstp->rq_xprt; local
2842 rpc_call_null_helper(struct rpc_clnt *clnt, struct rpc_xprt *xprt, struct rpc_cred *cred, int flags, const struct rpc_call_ops *ops, void *data) argument
2909 struct rpc_xprt *xprt; member in struct:rpc_cb_add_xprt_calldata
2942 rpc_clnt_test_and_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, void *in_max_connect) argument
2983 rpc_clnt_add_xprt_helper(struct rpc_clnt *clnt, struct rpc_xprt *xprt, struct rpc_add_xprt_test *data) argument
3025 rpc_clnt_setup_test_and_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt_switch *xps, struct rpc_xprt *xprt, void *data) argument
3077 struct rpc_xprt *xprt; local
3133 rpc_xprt_probe_trunked(struct rpc_clnt *clnt, struct rpc_xprt *xprt, struct rpc_add_xprt_test *data) argument
3174 struct rpc_xprt *xprt = xprt_iter_get_next(&xpi); local
3188 rpc_xprt_offline(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *data) argument
3240 rpc_xprt_set_connect_timeout(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *data) argument
3268 rpc_clnt_xprt_set_online(struct rpc_clnt *clnt, struct rpc_xprt *xprt) argument
3277 rpc_clnt_xprt_switch_add_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) argument
3292 rpc_clnt_xprt_switch_remove_xprt(struct rpc_clnt *clnt, struct rpc_xprt *xprt) argument
3366 rpc_clnt_swap_activate_callback(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *dummy) argument
3386 rpc_clnt_swap_deactivate_callback(struct rpc_clnt *clnt, struct rpc_xprt *xprt, void *dummy) argument
[all...]
H A Dsvcsock.c61 #include <linux/sunrpc/xprt.h>
127 * @xprt: the transport which owned the context
131 static void svc_tcp_release_ctxt(struct svc_xprt *xprt, void *ctxt) argument
137 * @xprt: the transport which owned the context
141 static void svc_udp_release_ctxt(struct svc_xprt *xprt, void *ctxt) argument
399 static int svc_tcp_has_wspace(struct svc_xprt *xprt) argument
401 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt);
403 if (test_bit(XPT_LISTENER, &xprt->xpt_flags))
408 static void svc_tcp_kill_temp_xprt(struct svc_xprt *xprt) argument
410 struct svc_sock *svsk = container_of(xprt, struc
428 struct svc_xprt *xprt = data; local
445 svc_tcp_handshake(struct svc_xprt *xprt) argument
688 struct svc_xprt *xprt = rqstp->rq_xprt; local
739 svc_udp_has_wspace(struct svc_xprt *xprt) argument
757 svc_udp_accept(struct svc_xprt *xprt) argument
763 svc_udp_kill_temp_xprt(struct svc_xprt *xprt) argument
880 svc_tcp_accept(struct svc_xprt *xprt) argument
1256 struct svc_xprt *xprt = rqstp->rq_xprt; local
1575 svc_sock_detach(struct svc_xprt *xprt) argument
1592 svc_tcp_sock_detach(struct svc_xprt *xprt) argument
1609 svc_sock_free(struct svc_xprt *xprt) argument
[all...]
H A Drpcb_clnt.c148 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);
642 * owner of the xprt. To do so, we walk back up the tree of parents
674 struct rpc_xprt *xprt; local
686 xprt = xprt_get(task->tk_xprt);
690 rpc_sleep_on_timeout(&xprt->binding, task,
691 NULL, jiffies + xprt->bind_timeout);
693 if (xprt_test_and_set_binding(xprt)) {
694 xprt_put(xprt);
798 struct rpc_xprt *xprt = map->r_xprt; local
[all...]
H A DMakefile11 sunrpc-y := clnt.o xprt.o socklib.o xprtsock.o sched.o \
H A Dsvcauth_unix.c338 ip_map_cached_get(struct svc_xprt *xprt) argument
343 if (test_bit(XPT_CACHE_AUTH, &xprt->xpt_flags)) {
344 spin_lock(&xprt->xpt_lock);
345 ipm = xprt->xpt_auth_cache;
347 sn = net_generic(xprt->xpt_net, sunrpc_net_id);
354 xprt->xpt_auth_cache = NULL;
355 spin_unlock(&xprt->xpt_lock);
361 spin_unlock(&xprt->xpt_lock);
367 ip_map_cached_put(struct svc_xprt *xprt, struct ip_map *ipm) argument
369 if (test_bit(XPT_CACHE_AUTH, &xprt
676 struct svc_xprt *xprt = rqstp->rq_xprt; local
835 struct svc_xprt *xprt = rqstp->rq_xprt; local
[all...]
/linux-master/include/linux/sunrpc/
H A Dxprt.h3 * linux/include/linux/sunrpc/xprt.h
30 #define RPC_MAXCWND(xprt) ((xprt)->max_reqs << RPC_CWNDSHIFT)
31 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd)
68 int rq_cong; /* has incremented xprt->cong */
138 void (*set_buffer_size)(struct rpc_xprt *xprt, size_t sndsize, size_t rcvsize);
139 int (*reserve_xprt)(struct rpc_xprt *xprt, struct rpc_task *task);
140 void (*release_xprt)(struct rpc_xprt *xprt, struc
396 xprt_enable_swap(struct rpc_xprt *xprt) argument
402 xprt_disable_swap(struct rpc_xprt *xprt) argument
451 xprt_set_connected(struct rpc_xprt *xprt) argument
456 xprt_clear_connected(struct rpc_xprt *xprt) argument
461 xprt_connected(struct rpc_xprt *xprt) argument
466 xprt_test_and_set_connected(struct rpc_xprt *xprt) argument
471 xprt_test_and_clear_connected(struct rpc_xprt *xprt) argument
476 xprt_clear_connecting(struct rpc_xprt *xprt) argument
483 xprt_connecting(struct rpc_xprt *xprt) argument
488 xprt_test_and_set_connecting(struct rpc_xprt *xprt) argument
493 xprt_set_bound(struct rpc_xprt *xprt) argument
498 xprt_bound(struct rpc_xprt *xprt) argument
503 xprt_clear_bound(struct rpc_xprt *xprt) argument
508 xprt_clear_binding(struct rpc_xprt *xprt) argument
515 xprt_test_and_set_binding(struct rpc_xprt *xprt) argument
[all...]
H A Dbc_xprt.h17 #include <linux/sunrpc/xprt.h>
21 struct rpc_rqst *xprt_lookup_bc_request(struct rpc_xprt *xprt, __be32 xid);
30 int xprt_setup_bc(struct rpc_xprt *xprt, unsigned int min_reqs);
31 void xprt_destroy_bc(struct rpc_xprt *xprt, unsigned int max_reqs);
33 unsigned int xprt_bc_max_slots(struct rpc_xprt *xprt);
48 static inline int xprt_setup_backchannel(struct rpc_xprt *xprt, argument
54 static inline void xprt_destroy_backchannel(struct rpc_xprt *xprt, argument
H A Dsvc_xprt.h26 void (*xpo_release_ctxt)(struct svc_xprt *xprt, void *ctxt);
30 void (*xpo_handshake)(struct svc_xprt *xprt);
44 * an xprt; intended for use by NFSv4.1, which needs to know when a
93 XPT_OLD, /* used for xprt aging mark+sweep */
99 XPT_HANDSHAKE, /* xprt requests a handshake */
128 static inline bool svc_xprt_is_dead(const struct svc_xprt *xprt) argument
130 return (test_bit(XPT_DEAD, &xprt->xpt_flags) != 0) ||
131 (test_bit(XPT_CLOSE, &xprt->xpt_flags) != 0);
143 void svc_xprt_received(struct svc_xprt *xprt);
144 void svc_xprt_enqueue(struct svc_xprt *xprt);
158 svc_xprt_get(struct svc_xprt *xprt) argument
162 svc_xprt_set_local(struct svc_xprt *xprt, const struct sockaddr *sa, const size_t salen) argument
169 svc_xprt_set_remote(struct svc_xprt *xprt, const struct sockaddr *sa, const size_t salen) argument
205 svc_xprt_local_port(const struct svc_xprt *xprt) argument
210 svc_xprt_remote_port(const struct svc_xprt *xprt) argument
[all...]
H A Dxprtmultipath.h47 extern struct rpc_xprt_switch *xprt_switch_alloc(struct rpc_xprt *xprt,
56 struct rpc_xprt *xprt);
58 struct rpc_xprt *xprt, bool offline);
H A Dxprtsock.h20 struct rpc_xprt xprt; member in struct:sock_xprt
H A Ddebug.h118 rpc_xprt_debugfs_register(struct rpc_xprt *xprt) argument
124 rpc_xprt_debugfs_unregister(struct rpc_xprt *xprt) argument
/linux-master/net/sunrpc/xprtrdma/
H A Dtransport.c148 xprt_rdma_format_addresses4(struct rpc_xprt *xprt, struct sockaddr *sap) argument
154 xprt->address_strings[RPC_DISPLAY_HEX_ADDR] = kstrdup(buf, GFP_KERNEL);
156 xprt->address_strings[RPC_DISPLAY_NETID] = RPCBIND_NETID_RDMA;
160 xprt_rdma_format_addresses6(struct rpc_xprt *xprt, struct sockaddr *sap) argument
166 xprt->address_strings[RPC_DISPLAY_HEX_ADDR] = kstrdup(buf, GFP_KERNEL);
168 xprt->address_strings[RPC_DISPLAY_NETID] = RPCBIND_NETID_RDMA6;
172 xprt_rdma_format_addresses(struct rpc_xprt *xprt, struct sockaddr *sap) argument
178 xprt_rdma_format_addresses4(xprt, sap);
181 xprt_rdma_format_addresses6(xprt, sap);
189 xprt
201 xprt_rdma_free_addresses(struct rpc_xprt *xprt) argument
228 struct rpc_xprt *xprt = &r_xprt->rx_xprt; local
260 xprt_rdma_inject_disconnect(struct rpc_xprt *xprt) argument
276 xprt_rdma_destroy(struct rpc_xprt *xprt) argument
305 struct rpc_xprt *xprt; local
375 xprt_rdma_close(struct rpc_xprt *xprt) argument
394 xprt_rdma_set_port(struct rpc_xprt *xprt, u16 port) argument
424 xprt_rdma_timer(struct rpc_xprt *xprt, struct rpc_task *task) argument
436 xprt_rdma_set_connect_timeout(struct rpc_xprt *xprt, unsigned long connect_timeout, unsigned long reconnect_timeout) argument
474 xprt_rdma_connect(struct rpc_xprt *xprt, struct rpc_task *task) argument
501 xprt_rdma_alloc_slot(struct rpc_xprt *xprt, struct rpc_task *task) argument
525 xprt_rdma_free_slot(struct rpc_xprt *xprt, struct rpc_rqst *rqst) argument
624 struct rpc_xprt *xprt = rqst->rq_xprt; local
669 xprt_rdma_print_stats(struct rpc_xprt *xprt, struct seq_file *seq) argument
711 xprt_rdma_enable_swap(struct rpc_xprt *xprt) argument
717 xprt_rdma_disable_swap(struct rpc_xprt *xprt) argument
[all...]
H A Dsvc_rdma_backchannel.c23 struct rpc_xprt *xprt = sxprt->xpt_bc_xprt; local
24 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
31 spin_lock(&xprt->queue_lock);
32 req = xprt_lookup_rqst(xprt, *rdma_resp);
42 spin_unlock(&xprt->queue_lock);
49 spin_lock(&xprt->transport_lock);
50 xprt->cwnd = credits << RPC_CWNDSHIFT;
51 spin_unlock(&xprt->transport_lock);
53 spin_lock(&xprt->queue_lock);
59 spin_unlock(&xprt
138 struct rpc_xprt *xprt = rqst->rq_xprt; local
197 xprt_rdma_bc_close(struct rpc_xprt *xprt) argument
204 xprt_rdma_bc_put(struct rpc_xprt *xprt) argument
237 struct rpc_xprt *xprt; local
[all...]
H A Dbackchannel.c8 #include <linux/sunrpc/xprt.h>
20 * @xprt: transport associated with these backchannel resources
25 int xprt_rdma_bc_setup(struct rpc_xprt *xprt, unsigned int reqs) argument
27 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
36 * @xprt: transport
40 size_t xprt_rdma_bc_maxpayload(struct rpc_xprt *xprt) argument
42 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
51 unsigned int xprt_rdma_bc_max_slots(struct rpc_xprt *xprt) argument
99 struct rpc_xprt *xprt = rqst->rq_xprt; local
100 struct rpcrdma_xprt *r_xprt = rpcx_to_rdmax(xprt);
131 xprt_rdma_bc_destroy(struct rpc_xprt *xprt, unsigned int reqs) argument
155 struct rpc_xprt *xprt = rqst->rq_xprt; local
169 struct rpc_xprt *xprt = &r_xprt->rx_xprt; local
222 struct rpc_xprt *xprt = &r_xprt->rx_xprt; local
[all...]
H A Dsvc_rdma_transport.c72 static struct svc_xprt *svc_rdma_accept(struct svc_xprt *xprt);
73 static void svc_rdma_detach(struct svc_xprt *xprt);
74 static void svc_rdma_free(struct svc_xprt *xprt);
75 static int svc_rdma_has_wspace(struct svc_xprt *xprt);
102 struct svc_xprt *xprt = context; local
104 trace_svcrdma_qp_error(event, (struct sockaddr *)&xprt->xpt_remote);
120 svc_xprt_deferred_close(xprt);
191 * This function creates a new xprt for the new connection and enqueues it on
192 * the accept queue for the listent xprt. When the listen thread is kicked, it
193 * will call the recvfrom method on the listen xprt whic
280 struct svc_xprt *xprt = &rdma->sc_xprt; local
371 svc_rdma_accept(struct svc_xprt *xprt) argument
544 svc_rdma_detach(struct svc_xprt *xprt) argument
587 svc_rdma_free(struct svc_xprt *xprt) argument
596 svc_rdma_has_wspace(struct svc_xprt *xprt) argument
612 svc_rdma_kill_temp_xprt(struct svc_xprt *xprt) argument
[all...]
/linux-master/include/trace/events/
H A Dsunrpc.h171 const struct rpc_xprt *xprt,
175 TP_ARGS(clnt, xprt, args),
182 __string(server, xprt->servername)
183 __string(addr, xprt->address_strings[RPC_DISPLAY_ADDR])
184 __string(port, xprt->address_strings[RPC_DISPLAY_PORT])
192 __assign_str(server, xprt->servername);
193 __assign_str(addr, xprt->address_strings[RPC_DISPLAY_ADDR]);
194 __assign_str(port, xprt->address_strings[RPC_DISPLAY_PORT]);
847 struct rpc_xprt *xprt,
851 TP_ARGS(xprt, socke
[all...]
/linux-master/fs/nfs/
H A Dcallback.c89 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, argument
97 xprt->bc_serv = serv;
100 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, argument
106 static int nfs_callback_start_svc(int minorversion, struct rpc_xprt *xprt, argument
112 nfs_callback_bc_serv(minorversion, xprt, serv);
141 struct net *net, struct rpc_xprt *xprt)
160 else if (xprt->ops->bc_setup)
223 int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt) argument
228 struct net *net = xprt->xprt_net;
238 ret = nfs_callback_up_net(minorversion, serv, net, xprt);
140 nfs_callback_up_net(int minorversion, struct svc_serv *serv, struct net *net, struct rpc_xprt *xprt) argument
[all...]

Completed in 428 milliseconds

12