Home
last modified time | relevance | path

Searched refs:xprt (Results 1 – 25 of 44) sorted by relevance

12

/linux-6.3-rc2/net/sunrpc/
A Dxprt.c452 xprt->ops->release_xprt(xprt, task); in xprt_release_write()
580 xprt->cong, xprt->cwnd, cwnd); in xprt_adjust_cwnd()
742 xprt->ops->close(xprt); in xprt_autoclose()
848 mod_timer(&xprt->timer, xprt->last_used + xprt->idle_timeout); in xprt_schedule_autodisconnect()
870 xprt->ops->inject_disconnect(xprt); in xprt_inject_disconnect()
945 xprt->ops->connect(xprt, task); in xprt_connect()
1244 xprt->ops->timer(xprt, task); in xprt_timer()
1584 xprt->stat.req_u += xprt->stat.sends - xprt->stat.recvs; in xprt_request_transmit()
1897 xprt->ops->alloc_slot(xprt, task); in xprt_do_reserve()
1979 xprt->ops->free_slot(xprt, req); in xprt_release()
[all …]
A Dxprtsock.c564 struct rpc_xprt *xprt = &transport->xprt; in xs_read_stream_call() local
600 struct rpc_xprt *xprt = &transport->xprt; in xs_read_stream_reply() local
773 struct rpc_xprt *xprt = &transport->xprt; in xs_nospace() local
867 container_of(xprt, struct sock_xprt, xprt); in xs_local_send_request()
1184 struct rpc_xprt *xprt = &transport->xprt; in xs_reset_transport() local
1250 xprt); in xs_inject_disconnect()
1910 struct rpc_xprt *xprt = &transport->xprt; in xs_local_setup_socket() local
2008 xprt); in xs_set_memalloc()
2110 struct rpc_xprt *xprt = &transport->xprt; in xs_udp_setup_socket() local
2294 struct rpc_xprt *xprt = &transport->xprt; in xs_tcp_setup_socket() local
[all …]
A Dsvc_xprt.c165 put_net_track(xprt->xpt_net, &xprt->ns_tracker); in svc_xprt_free()
172 xprt->xpt_ops->xpo_free(xprt); in svc_xprt_free()
189 memset(xprt, 0, sizeof(*xprt)); in svc_xprt_init()
433 if (xprt->xpt_ops->xpo_has_wspace(xprt) && in svc_xprt_ready()
810 xprt->xpt_ops->xpo_kill_temp_xprt(xprt); in svc_handle_xprt()
823 newxpt = xprt->xpt_ops->xpo_accept(xprt); in svc_handle_xprt()
922 if (!xprt) in svc_send()
1015 xprt); in svc_age_temp_xprts_now()
1046 xprt->xpt_ops->xpo_detach(xprt); in svc_delete_xprt()
1048 xprt->xpt_bc_xprt->ops->close(xprt->xpt_bc_xprt); in svc_delete_xprt()
[all …]
A Dbackchannel_rqst.c33 return xprt->bc_alloc_count < xprt->bc_alloc_max; in xprt_need_to_requeue()
85 req->rq_xprt = xprt; in xprt_alloc_bc_req()
126 if (!xprt->ops->bc_setup) in xprt_setup_backchannel()
128 return xprt->ops->bc_setup(xprt, min_reqs); in xprt_setup_backchannel()
206 xprt->ops->bc_destroy(xprt, max_reqs); in xprt_destroy_backchannel()
220 xprt->bc_alloc_max -= min(max_reqs, xprt->bc_alloc_max); in xprt_destroy_bc()
225 xprt->bc_alloc_count--; in xprt_destroy_bc()
249 xprt->bc_alloc_count++; in xprt_get_bc_request()
311 xprt_put(xprt); in xprt_free_bc_rqst()
364 xprt->bc_alloc_count--; in xprt_complete_bc_request()
[all …]
A Dsysfs.c114 if (!xprt || !xprt_connected(xprt)) { in rpc_sysfs_xprt_srcaddr_show()
117 ret = xprt->ops->get_srcaddr(xprt, buf, buflen); in rpc_sysfs_xprt_srcaddr_show()
140 if (!xprt || !xprt_connected(xprt)) { in rpc_sysfs_xprt_info_show()
146 srcport = xprt->ops->get_srcport(xprt); in rpc_sysfs_xprt_info_show()
154 xprt->last_used, xprt->cong, xprt->cwnd, xprt->max_reqs, in rpc_sysfs_xprt_info_show()
155 xprt->min_reqs, xprt->num_reqs, xprt->binding.qlen, in rpc_sysfs_xprt_info_show()
156 xprt->sending.qlen, xprt->pending.qlen, in rpc_sysfs_xprt_info_show()
157 xprt->backlog.qlen, xprt->main, srcport, in rpc_sysfs_xprt_info_show()
174 if (!(xprt && xprt->state)) { in rpc_sysfs_xprt_state_show()
562 rpc_xprt_switch->xprt = xprt; in rpc_sysfs_xprt_switch_setup()
[all …]
A Dclnt.c543 if (xprt) { in rpc_create()
841 if (!xprt) in rpc_clnt_iterate_for_each_xprt()
1066 if (!xprt) in rpc_task_get_xprt()
1095 if (xprt) { in rpc_task_release_transport()
1559 xprt->ops->set_buffer_size(xprt, sndsize, rcvsize); in rpc_setbufsize()
1611 ret = xprt->ops->bc_maxpayload(xprt); in rpc_max_bc_payload()
1624 ret = xprt->ops->bc_num_slots(xprt); in rpc_num_bc_slots()
2917 data->xprt = xprt_get(xprt); in rpc_clnt_test_and_add_xprt()
2984 xprt = xprt_get(xprt); in rpc_clnt_setup_test_and_add_xprt()
3060 xprt->ops->set_connect_timeout(xprt, in rpc_clnt_add_xprt()
[all …]
A Dxprtmultipath.c33 struct rpc_xprt *xprt) in xprt_switch_add_xprt_locked() argument
53 struct rpc_xprt *xprt) in rpc_xprt_switch_add_xprt() argument
55 if (xprt == NULL) in rpc_xprt_switch_add_xprt()
92 xprt_put(xprt); in rpc_xprt_switch_remove_xprt()
155 struct rpc_xprt *xprt; in xprt_switch_free_entries() local
161 xprt_put(xprt); in xprt_switch_free_entries()
429 if (!xprt) in xprt_switch_find_next_entry_roundrobin()
437 cur = xprt; in xprt_switch_find_next_entry_roundrobin()
439 return xprt; in xprt_switch_find_next_entry_roundrobin()
606 return xprt; in xprt_iter_get_xprt()
[all …]
A Ddebugfs.c127 if (IS_ERR_OR_NULL(xprt->debugfs)) in do_xprt_debugfs()
130 xprt->debugfs->d_name.name); in do_xprt_debugfs()
176 struct rpc_xprt *xprt = f->private; in xprt_info_show() local
181 seq_printf(f, "state: 0x%lx\n", xprt->state); in xprt_info_show()
189 struct rpc_xprt *xprt = inode->i_private; in xprt_info_open() local
194 if (!xprt_get(xprt)) { in xprt_info_open()
205 struct rpc_xprt *xprt = inode->i_private; in xprt_info_release() local
207 xprt_put(xprt); in xprt_info_release()
236 debugfs_create_file("info", S_IFREG | 0400, xprt->debugfs, xprt, in rpc_xprt_debugfs_register()
243 debugfs_remove_recursive(xprt->debugfs); in rpc_xprt_debugfs_unregister()
[all …]
A Dsysfs.h19 struct rpc_xprt *xprt; member
24 struct rpc_xprt *xprt; member
36 struct rpc_xprt *xprt, gfp_t gfp_flags);
37 void rpc_sysfs_xprt_switch_destroy(struct rpc_xprt_switch *xprt);
39 struct rpc_xprt *xprt, gfp_t gfp_flags);
40 void rpc_sysfs_xprt_destroy(struct rpc_xprt *xprt);
A Drpcb_clnt.c149 xprt_clear_binding(xprt); in rpcb_wake_rpcbind_waiters()
651 struct rpc_xprt *xprt; in rpcb_getport_async() local
671 xprt_put(xprt); in rpcb_getport_async()
676 if (xprt_bound(xprt)) { in rpcb_getport_async()
699 xprt->bind_index = 0; in rpcb_getport_async()
726 map->r_xprt = xprt; in rpcb_getport_async()
750 xprt->stat.bind_count++; in rpcb_getport_async()
761 xprt_put(xprt); in rpcb_getport_async()
781 xprt->bind_index++; in rpcb_getport_done()
796 xprt->ops->set_port(xprt, map->r_port); in rpcb_getport_done()
[all …]
A Dsvcsock.c567 mutex_lock(&xprt->xpt_mutex); in svc_udp_sendto()
569 if (svc_xprt_is_dead(xprt)) in svc_udp_sendto()
584 mutex_unlock(&xprt->xpt_mutex); in svc_udp_sendto()
590 mutex_unlock(&xprt->xpt_mutex); in svc_udp_sendto()
1168 mutex_lock(&xprt->xpt_mutex); in svc_tcp_sendto()
1169 if (svc_xprt_is_dead(xprt)) in svc_tcp_sendto()
1179 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1184 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1188 xprt->xpt_server->sv_name, in svc_tcp_sendto()
1191 svc_xprt_deferred_close(xprt); in svc_tcp_sendto()
[all …]
A Dsvcauth_unix.c343 spin_lock(&xprt->xpt_lock); in ip_map_cached_get()
344 ipm = xprt->xpt_auth_cache; in ip_map_cached_get()
353 xprt->xpt_auth_cache = NULL; in ip_map_cached_get()
354 spin_unlock(&xprt->xpt_lock); in ip_map_cached_get()
360 spin_unlock(&xprt->xpt_lock); in ip_map_cached_get()
369 spin_lock(&xprt->xpt_lock); in ip_map_cached_put()
372 xprt->xpt_auth_cache = ipm; in ip_map_cached_put()
375 spin_unlock(&xprt->xpt_lock); in ip_map_cached_put()
667 struct net *net = xprt->xpt_net; in svcauth_unix_set_client()
688 ipm = ip_map_cached_get(xprt); in svcauth_unix_set_client()
[all …]
/linux-6.3-rc2/include/linux/sunrpc/
A Dxprt.h30 #define RPC_MAXCWND(xprt) ((xprt)->max_reqs << RPC_CWNDSHIFT) argument
31 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd) argument
153 void (*close)(struct rpc_xprt *xprt);
154 void (*destroy)(struct rpc_xprt *xprt);
162 int (*bc_setup)(struct rpc_xprt *xprt,
375 void xprt_put(struct rpc_xprt *xprt);
385 xprt_enable_swap(struct rpc_xprt *xprt) in xprt_enable_swap() argument
387 return xprt->ops->enable_swap(xprt); in xprt_enable_swap()
393 xprt->ops->disable_swap(xprt); in xprt_disable_swap()
442 set_bit(XPRT_CONNECTED, &xprt->state); in xprt_set_connected()
[all …]
A Dsvc_xprt.h124 (test_bit(XPT_CLOSE, &xprt->xpt_flags) != 0); in svc_xprt_is_dead()
136 void svc_xprt_received(struct svc_xprt *xprt);
137 void svc_xprt_enqueue(struct svc_xprt *xprt);
138 void svc_xprt_put(struct svc_xprt *xprt);
140 void svc_xprt_close(struct svc_xprt *xprt);
153 kref_get(&xprt->xpt_ref); in svc_xprt_get()
159 memcpy(&xprt->xpt_local, sa, salen); in svc_xprt_set_local()
160 xprt->xpt_locallen = salen; in svc_xprt_set_local()
166 memcpy(&xprt->xpt_remote, sa, salen); in svc_xprt_set_remote()
167 xprt->xpt_remotelen = salen; in svc_xprt_set_remote()
[all …]
A Dbc_xprt.h21 struct rpc_rqst *xprt_lookup_bc_request(struct rpc_xprt *xprt, __be32 xid);
29 int xprt_setup_bc(struct rpc_xprt *xprt, unsigned int min_reqs);
30 void xprt_destroy_bc(struct rpc_xprt *xprt, unsigned int max_reqs);
32 unsigned int xprt_bc_max_slots(struct rpc_xprt *xprt);
47 static inline int xprt_setup_backchannel(struct rpc_xprt *xprt, in xprt_setup_backchannel() argument
53 static inline void xprt_destroy_backchannel(struct rpc_xprt *xprt, in xprt_destroy_backchannel() argument
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);
A Dclnt.h146 struct rpc_xprt *xprt,
180 struct rpc_xprt *xprt);
221 struct rpc_xprt *xprt,
248 void rpc_clnt_xprt_set_online(struct rpc_clnt *clnt, struct rpc_xprt *xprt);
/linux-6.3-rc2/net/sunrpc/xprtrdma/
A Dtransport.c295 xprt_free(xprt); in xprt_rdma_destroy()
314 struct rpc_xprt *xprt; in xprt_setup_rdma() local
327 if (!xprt) { in xprt_setup_rdma()
333 xprt->connect_timeout = xprt->timeout->to_initval; in xprt_setup_rdma()
334 xprt->max_reconnect_timeout = xprt->timeout->to_maxval; in xprt_setup_rdma()
352 memcpy(&xprt->addr, sap, xprt->addrlen); in xprt_setup_rdma()
362 xprt_free(xprt); in xprt_setup_rdma()
372 return xprt; in xprt_setup_rdma()
459 to = *xprt->timeout; in xprt_rdma_set_connect_timeout()
693 xprt->stat.sends, in xprt_rdma_print_stats()
[all …]
A Dsvc_rdma_backchannel.c216 xprt_free(xprt); in xprt_rdma_bc_put()
246 struct rpc_xprt *xprt; in xprt_setup_rdma_bc() local
255 if (!xprt) in xprt_setup_rdma_bc()
259 xprt_set_bound(xprt); in xprt_setup_rdma_bc()
261 xprt->bind_timeout = 0; in xprt_setup_rdma_bc()
263 xprt->idle_timeout = 0; in xprt_setup_rdma_bc()
270 xprt_rdma_format_addresses(xprt, (struct sockaddr *)&xprt->addr); in xprt_setup_rdma_bc()
271 xprt->resvport = 0; in xprt_setup_rdma_bc()
278 xprt_get(xprt); in xprt_setup_rdma_bc()
283 xprt_get(xprt); in xprt_setup_rdma_bc()
[all …]
A Dbackchannel.c104 if (!xprt_connected(xprt)) in xprt_rdma_bc_send_reply()
122 xprt_rdma_close(xprt); in xprt_rdma_bc_send_reply()
135 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
161 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_free_rqst()
164 xprt_put(xprt); in xprt_rdma_bc_free_rqst()
174 spin_lock(&xprt->bc_pa_lock); in rpcrdma_bc_rqst_get()
200 xprt->bc_alloc_count++; in rpcrdma_bc_rqst_get()
202 rqst->rq_xprt = xprt; in rpcrdma_bc_rqst_get()
264 bc_serv = xprt->bc_serv; in rpcrdma_bc_receive_call()
265 xprt_get(xprt); in rpcrdma_bc_receive_call()
[all …]
A Dsvc_rdma_transport.c73 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; in qp_event_handler() local
120 svc_xprt_deferred_close(xprt); in qp_event_handler()
273 struct svc_xprt *xprt = &rdma->sc_xprt; in svc_rdma_cma_handler() local
281 svc_xprt_enqueue(xprt); in svc_rdma_cma_handler()
285 svc_xprt_deferred_close(xprt); in svc_rdma_cma_handler()
377 clear_bit(XPT_CONN, &xprt->xpt_flags); in svc_rdma_accept()
534 static void svc_rdma_detach(struct svc_xprt *xprt) in svc_rdma_detach() argument
[all …]
A Drpc_rdma.c1016 xprt->cong = 0; in rpcrdma_reset_cwnd()
1149 if (xprt->bc_serv == NULL) in rpcrdma_is_bcall()
1361 spin_lock(&xprt->queue_lock); in rpcrdma_unpin_rqst()
1363 spin_unlock(&xprt->queue_lock); in rpcrdma_unpin_rqst()
1398 spin_lock(&xprt->queue_lock); in rpcrdma_complete_rqst()
1401 spin_unlock(&xprt->queue_lock); in rpcrdma_complete_rqst()
1440 if (xprt->reestablish_timeout) in rpcrdma_reply_handler()
1441 xprt->reestablish_timeout = 0; in rpcrdma_reply_handler()
1463 spin_lock(&xprt->queue_lock); in rpcrdma_reply_handler()
1468 spin_unlock(&xprt->queue_lock); in rpcrdma_reply_handler()
[all …]
A Dsvc_rdma_recvfrom.c252 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_release_rqst() local
254 container_of(xprt, struct svcxprt_rdma, sc_xprt); in svc_rdma_release_rqst()
735 static bool svc_rdma_is_reverse_direction_reply(struct svc_xprt *xprt, in svc_rdma_is_reverse_direction_reply() argument
740 if (!xprt->xpt_bc_xprt) in svc_rdma_is_reverse_direction_reply()
794 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_recvfrom() local
796 container_of(xprt, struct svcxprt_rdma, sc_xprt); in svc_rdma_recvfrom()
809 clear_bit(XPT_DATA, &xprt->xpt_flags); in svc_rdma_recvfrom()
813 svc_xprt_received(xprt); in svc_rdma_recvfrom()
835 if (svc_rdma_is_reverse_direction_reply(xprt, ctxt)) in svc_rdma_recvfrom()
849 svc_xprt_copy_addrs(rqstp, xprt); in svc_rdma_recvfrom()
/linux-6.3-rc2/include/trace/events/
A Dsunrpc.h975 TP_ARGS(xprt),
1000 TP_ARGS(xprt))
1124 TP_ARGS(xprt, status),
1147 TP_ARGS(xprt, task),
1193 TP_ARGS(xprt, task),
1274 TP_ARGS(xprt),
1297 __string(addr, xprt ? xprt->address_strings[RPC_DISPLAY_ADDR] :
1299 __string(port, xprt ? xprt->address_strings[RPC_DISPLAY_PORT] :
1896 TP_ARGS(xprt, rqst),
1943 TP_ARGS(xprt),
[all …]
/linux-6.3-rc2/fs/nfs/
A Dcallback.c143 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, in nfs_callback_bc_serv() argument
151 xprt->bc_serv = serv; in nfs_callback_bc_serv()
154 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, in nfs_callback_bc_serv() argument
160 static int nfs_callback_start_svc(int minorversion, struct rpc_xprt *xprt, in nfs_callback_start_svc() argument
166 nfs_callback_bc_serv(minorversion, xprt, serv); in nfs_callback_start_svc()
195 struct net *net, struct rpc_xprt *xprt) in nfs_callback_up_net() argument
214 else if (xprt->ops->bc_setup) in nfs_callback_up_net()
280 int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt) in nfs_callback_up() argument
285 struct net *net = xprt->xprt_net; in nfs_callback_up()
295 ret = nfs_callback_up_net(minorversion, serv, net, xprt); in nfs_callback_up()
[all …]

Completed in 66 milliseconds

12