Home
last modified time | relevance | path

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

12

/linux/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()
745 xprt->ops->close(xprt); in xprt_autoclose()
851 mod_timer(&xprt->timer, xprt->last_used + xprt->idle_timeout); in xprt_schedule_autodisconnect()
873 xprt->ops->inject_disconnect(xprt); in xprt_inject_disconnect()
948 xprt->ops->connect(xprt, task); in xprt_connect()
1247 xprt->ops->timer(xprt, task); in xprt_timer()
1596 xprt->stat.req_u += xprt->stat.sends - xprt->stat.recvs; in xprt_request_transmit()
1909 xprt->ops->alloc_slot(xprt, task); in xprt_do_reserve()
1991 xprt->ops->free_slot(xprt, req); in xprt_release()
[all …]
A Dsvc_xprt.c174 put_net_track(xprt->xpt_net, &xprt->ns_tracker); in svc_xprt_free()
181 xprt->xpt_ops->xpo_free(xprt); in svc_xprt_free()
198 memset(xprt, 0, sizeof(*xprt)); in svc_xprt_init()
459 if (xprt->xpt_ops->xpo_has_wspace(xprt) && in svc_xprt_ready()
505 if (xprt) in svc_xprt_dequeue()
785 xprt->xpt_ops->xpo_kill_temp_xprt(xprt); in svc_handle_xprt()
798 newxpt = xprt->xpt_ops->xpo_accept(xprt); in svc_handle_xprt()
808 xprt->xpt_ops->xpo_handshake(xprt); in svc_handle_xprt()
1005 xprt); in svc_age_temp_xprts_now()
1036 xprt->xpt_ops->xpo_detach(xprt); in svc_delete_xprt()
[all …]
A Dxprtsock.c615 struct rpc_xprt *xprt = &transport->xprt; in xs_read_stream_call() local
651 struct rpc_xprt *xprt = &transport->xprt; in xs_read_stream_reply() local
828 struct rpc_xprt *xprt = &transport->xprt; in xs_nospace() local
890 container_of(xprt, struct sock_xprt, xprt); in xs_stream_abort_send_request()
933 container_of(xprt, struct sock_xprt, xprt); in xs_local_send_request()
1251 struct rpc_xprt *xprt = &transport->xprt; in xs_reset_transport() local
1321 xprt); in xs_inject_disconnect()
1992 struct rpc_xprt *xprt = &transport->xprt; in xs_local_setup_socket() local
2192 struct rpc_xprt *xprt = &transport->xprt; in xs_udp_setup_socket() local
2397 struct rpc_xprt *xprt = &transport->xprt; in xs_tcp_setup_socket() local
[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()
125 if (!xprt->ops->bc_setup) in xprt_setup_backchannel()
127 return xprt->ops->bc_setup(xprt, min_reqs); in xprt_setup_backchannel()
205 xprt->ops->bc_destroy(xprt, max_reqs); in xprt_destroy_backchannel()
219 xprt->bc_alloc_max -= min(max_reqs, xprt->bc_alloc_max); in xprt_destroy_bc()
224 xprt->bc_alloc_count--; in xprt_destroy_bc()
248 xprt->bc_alloc_count++; in xprt_get_bc_request()
310 xprt_put(xprt); in xprt_free_bc_rqst()
361 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()
563 rpc_xprt_switch->xprt = xprt; in rpc_sysfs_xprt_switch_setup()
[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()
442 if (!xprt) in xprt_switch_find_next_entry_roundrobin()
450 cur = xprt; in xprt_switch_find_next_entry_roundrobin()
452 return xprt; in xprt_switch_find_next_entry_roundrobin()
619 return xprt; in xprt_iter_get_xprt()
[all …]
A Dclnt.c551 if (xprt) { in rpc_create()
865 if (!xprt) in rpc_clnt_iterate_for_each_xprt()
1092 if (!xprt) in rpc_task_get_xprt()
1121 if (xprt) { in rpc_task_release_transport()
1587 xprt->ops->set_buffer_size(xprt, sndsize, rcvsize); in rpc_setbufsize()
1639 ret = xprt->ops->bc_maxpayload(xprt); in rpc_max_bc_payload()
1652 ret = xprt->ops->bc_num_slots(xprt); in rpc_num_bc_slots()
2967 data->xprt = xprt_get(xprt); in rpc_clnt_test_and_add_xprt()
3034 xprt = xprt_get(xprt); in rpc_clnt_setup_test_and_add_xprt()
3116 xprt->ops->set_connect_timeout(xprt, in rpc_clnt_add_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 Dsvcsock.c428 struct svc_xprt *xprt = data; in svc_tcp_handshake_done() local
452 .ta_data = xprt, in svc_tcp_handshake()
456 trace_svc_tls_upcall(xprt); in svc_tcp_handshake()
486 svc_xprt_enqueue(xprt); in svc_tcp_handshake()
494 svc_xprt_enqueue(xprt); in svc_tcp_handshake()
711 mutex_lock(&xprt->xpt_mutex); in svc_udp_sendto()
713 if (svc_xprt_is_dead(xprt)) in svc_udp_sendto()
1267 mutex_lock(&xprt->xpt_mutex); in svc_tcp_sendto()
1268 if (svc_xprt_is_dead(xprt)) in svc_tcp_sendto()
1282 xprt->xpt_server->sv_name, in svc_tcp_sendto()
[all …]
A Dsysfs.h12 struct rpc_xprt *xprt; member
17 struct rpc_xprt *xprt; member
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);
A Drpcb_clnt.c150 xprt_clear_binding(xprt); in rpcb_wake_rpcbind_waiters()
674 struct rpc_xprt *xprt; in rpcb_getport_async() local
694 xprt_put(xprt); in rpcb_getport_async()
699 if (xprt_bound(xprt)) { in rpcb_getport_async()
722 xprt->bind_index = 0; in rpcb_getport_async()
749 map->r_xprt = xprt; in rpcb_getport_async()
777 xprt->stat.bind_count++; in rpcb_getport_async()
788 xprt_put(xprt); in rpcb_getport_async()
808 xprt->bind_index++; in rpcb_getport_done()
823 xprt->ops->set_port(xprt, map->r_port); in rpcb_getport_done()
[all …]
A Dsvcauth_unix.c344 spin_lock(&xprt->xpt_lock); in ip_map_cached_get()
345 ipm = xprt->xpt_auth_cache; in ip_map_cached_get()
354 xprt->xpt_auth_cache = NULL; in ip_map_cached_get()
355 spin_unlock(&xprt->xpt_lock); in ip_map_cached_get()
361 spin_unlock(&xprt->xpt_lock); in ip_map_cached_get()
370 spin_lock(&xprt->xpt_lock); in ip_map_cached_put()
373 xprt->xpt_auth_cache = ipm; in ip_map_cached_put()
376 spin_unlock(&xprt->xpt_lock); in ip_map_cached_put()
698 ipm = ip_map_cached_get(xprt); in svcauth_unix_set_client()
874 trace_svc_tls_start(xprt); in svcauth_tls_accept()
[all …]
/linux/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
159 void (*close)(struct rpc_xprt *xprt);
160 void (*destroy)(struct rpc_xprt *xprt);
168 int (*bc_setup)(struct rpc_xprt *xprt,
386 void xprt_put(struct rpc_xprt *xprt);
396 xprt_enable_swap(struct rpc_xprt *xprt) in xprt_enable_swap() argument
398 return xprt->ops->enable_swap(xprt); in xprt_enable_swap()
404 xprt->ops->disable_swap(xprt); in xprt_disable_swap()
453 set_bit(XPRT_CONNECTED, &xprt->state); in xprt_set_connected()
[all …]
A Dsvc_xprt.h30 void (*xpo_handshake)(struct svc_xprt *xprt);
146 void svc_xprt_received(struct svc_xprt *xprt);
147 void svc_xprt_enqueue(struct svc_xprt *xprt);
148 void svc_xprt_put(struct svc_xprt *xprt);
150 void svc_xprt_close(struct svc_xprt *xprt);
165 kref_get(&xprt->xpt_ref); in svc_xprt_get()
171 memcpy(&xprt->xpt_local, sa, salen); in svc_xprt_set_local()
172 xprt->xpt_locallen = salen; in svc_xprt_set_local()
178 memcpy(&xprt->xpt_remote, sa, salen); in svc_xprt_set_remote()
179 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);
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, in xprt_setup_backchannel() argument
54 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);
/linux/net/sunrpc/xprtrdma/
A Dtransport.c285 xprt_free(xprt); in xprt_rdma_destroy()
304 struct rpc_xprt *xprt; in xprt_setup_rdma() local
317 if (!xprt) { in xprt_setup_rdma()
323 xprt->connect_timeout = xprt->timeout->to_initval; in xprt_setup_rdma()
324 xprt->max_reconnect_timeout = xprt->timeout->to_maxval; in xprt_setup_rdma()
342 memcpy(&xprt->addr, sap, xprt->addrlen); in xprt_setup_rdma()
352 xprt_free(xprt); in xprt_setup_rdma()
362 return xprt; in xprt_setup_rdma()
449 to = *xprt->timeout; in xprt_rdma_set_connect_timeout()
683 xprt->stat.sends, in xprt_rdma_print_stats()
[all …]
A Dsvc_rdma_backchannel.c207 xprt_free(xprt); in xprt_rdma_bc_put()
237 struct rpc_xprt *xprt; in xprt_setup_rdma_bc() local
246 if (!xprt) in xprt_setup_rdma_bc()
250 xprt_set_bound(xprt); in xprt_setup_rdma_bc()
252 xprt->bind_timeout = 0; in xprt_setup_rdma_bc()
254 xprt->idle_timeout = 0; in xprt_setup_rdma_bc()
261 xprt_rdma_format_addresses(xprt, (struct sockaddr *)&xprt->addr); in xprt_setup_rdma_bc()
262 xprt->resvport = 0; in xprt_setup_rdma_bc()
269 xprt_get(xprt); in xprt_setup_rdma_bc()
274 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.c75 static void svc_rdma_detach(struct svc_xprt *xprt);
76 static void svc_rdma_free(struct svc_xprt *xprt);
77 static int svc_rdma_has_wspace(struct svc_xprt *xprt);
104 struct svc_xprt *xprt = context; in qp_event_handler() local
122 svc_xprt_deferred_close(xprt); in qp_event_handler()
331 struct svc_xprt *xprt = &rdma->sc_xprt; in svc_rdma_cma_handler() local
339 svc_xprt_enqueue(xprt); in svc_rdma_cma_handler()
342 svc_xprt_deferred_close(xprt); in svc_rdma_cma_handler()
420 clear_bit(XPT_CONN, &xprt->xpt_flags); in svc_rdma_accept()
583 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.c241 void svc_rdma_release_ctxt(struct svc_xprt *xprt, void *vctxt) in svc_rdma_release_ctxt() argument
245 container_of(xprt, struct svcxprt_rdma, sc_xprt); in svc_rdma_release_ctxt()
750 if (!xprt->xpt_bc_xprt) in svc_rdma_is_reverse_direction_reply()
918 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_recvfrom() local
920 container_of(xprt, struct svcxprt_rdma, sc_xprt); in svc_rdma_recvfrom()
937 svc_xprt_received(xprt); in svc_rdma_recvfrom()
946 clear_bit(XPT_DATA, &xprt->xpt_flags); in svc_rdma_recvfrom()
950 svc_xprt_received(xprt); in svc_rdma_recvfrom()
966 if (svc_rdma_is_reverse_direction_reply(xprt, ctxt)) in svc_rdma_recvfrom()
978 svc_xprt_copy_addrs(rqstp, xprt); in svc_rdma_recvfrom()
[all …]
/linux/include/trace/events/
A Dsunrpc.h1009 TP_ARGS(xprt),
1034 TP_ARGS(xprt))
1180 TP_ARGS(xprt, task),
1226 TP_ARGS(xprt, task),
1307 TP_ARGS(xprt),
1330 __string(addr, xprt ? xprt->address_strings[RPC_DISPLAY_ADDR] :
1332 __string(port, xprt ? xprt->address_strings[RPC_DISPLAY_PORT] :
1537 TP_ARGS(clnt, xprt),
2063 TP_ARGS(xprt),
2081 TP_ARGS(xprt))
[all …]
/linux/fs/nfs/
A Dcallback.c91 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, in nfs_callback_bc_serv() argument
99 xprt->bc_serv = serv; in nfs_callback_bc_serv()
102 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, in nfs_callback_bc_serv() argument
108 static int nfs_callback_start_svc(int minorversion, struct rpc_xprt *xprt, in nfs_callback_start_svc() argument
114 nfs_callback_bc_serv(minorversion, xprt, serv); in nfs_callback_start_svc()
143 struct net *net, struct rpc_xprt *xprt) in nfs_callback_up_net() argument
162 else if (xprt->ops->bc_setup) in nfs_callback_up_net()
225 int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt) in nfs_callback_up() argument
230 struct net *net = xprt->xprt_net; in nfs_callback_up()
240 ret = nfs_callback_up_net(minorversion, serv, net, xprt); in nfs_callback_up()
[all …]
/linux/fs/nfsd/
A Dnfsctl.c741 struct svc_xprt *xprt; in __write_ports_addxprt() local
771 if (xprt != NULL) { in __write_ports_addxprt()
772 svc_xprt_close(xprt); in __write_ports_addxprt()
773 svc_xprt_put(xprt); in __write_ports_addxprt()
1957 struct svc_xprt *xprt, *tmp; in nfsd_nl_listener_set_doit() local
2045 svc_xprt_close(xprt); in nfsd_nl_listener_set_doit()
2075 if (xprt) { in nfsd_nl_listener_set_doit()
2076 svc_xprt_put(xprt); in nfsd_nl_listener_set_doit()
2105 struct svc_xprt *xprt; in nfsd_nl_listener_get_doit() local
2140 xprt->xpt_class->xcl_name) || in nfsd_nl_listener_get_doit()
[all …]

Completed in 104 milliseconds

12