Home
last modified time | relevance | path

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

123456

/linux/net/sunrpc/
A Dxprt.c451 xprt->ops->release_xprt(xprt, task); in xprt_release_write()
579 xprt->cong, xprt->cwnd, cwnd); in xprt_adjust_cwnd()
741 xprt->ops->close(xprt); in xprt_autoclose()
847 mod_timer(&xprt->timer, xprt->last_used + xprt->idle_timeout); in xprt_schedule_autodisconnect()
934 xprt->ops->close(xprt); in xprt_connect()
949 xprt->ops->connect(xprt, task); in xprt_connect()
1242 xprt->ops->timer(xprt, task); in xprt_timer()
1579 xprt->stat.req_u += xprt->stat.sends - xprt->stat.recvs; in xprt_request_transmit()
1895 xprt->ops->alloc_slot(xprt, task); in xprt_do_reserve()
1979 xprt->ops->free_slot(xprt, req); in xprt_release()
[all …]
A Dxprtsock.c562 struct rpc_xprt *xprt = &transport->xprt; in xs_read_stream_call() local
598 struct rpc_xprt *xprt = &transport->xprt; in xs_read_stream_reply() local
847 container_of(xprt, struct sock_xprt, xprt); in xs_local_send_request()
1177 struct rpc_xprt *xprt = &transport->xprt; in xs_reset_transport() local
1233 xprt); in xs_inject_disconnect()
1851 struct rpc_xprt *xprt = &transport->xprt; in xs_local_setup_socket() local
1941 xprt); in xs_set_memalloc()
2047 struct rpc_xprt *xprt = &transport->xprt; in xs_udp_setup_socket() local
2227 struct rpc_xprt *xprt = &transport->xprt; in xs_tcp_setup_socket() local
2249 xprt, -status, xprt_connected(xprt), in xs_tcp_setup_socket()
[all …]
A Dsvc_xprt.c171 xprt->xpt_ops->xpo_free(xprt); in svc_xprt_free()
188 memset(xprt, 0, sizeof(*xprt)); in svc_xprt_init()
275 xprt->xpt_server->sv_ops->svo_enqueue_xprt(xprt); in svc_xprt_received()
418 if (xprt->xpt_ops->xpo_has_wspace(xprt) && in svc_xprt_ready()
482 xprt->xpt_server->sv_ops->svo_enqueue_xprt(xprt); in svc_xprt_enqueue()
808 xprt->xpt_ops->xpo_kill_temp_xprt(xprt); in svc_handle_xprt()
821 newxpt = xprt->xpt_ops->xpo_accept(xprt); in svc_handle_xprt()
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.c47 return xprt->bc_alloc_count < xprt->bc_alloc_max; in xprt_need_to_requeue()
88 req->rq_xprt = xprt; in xprt_alloc_bc_req()
129 if (!xprt->ops->bc_setup) in xprt_setup_backchannel()
131 return xprt->ops->bc_setup(xprt, min_reqs); in xprt_setup_backchannel()
209 xprt->ops->bc_destroy(xprt, max_reqs); in xprt_destroy_backchannel()
223 xprt->bc_alloc_max -= min(max_reqs, xprt->bc_alloc_max); in xprt_destroy_bc()
228 xprt->bc_alloc_count--; in xprt_destroy_bc()
252 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.c96 if (!xprt) in rpc_sysfs_xprt_dstaddr_show()
112 if (!xprt || !xprt_connected(xprt)) { in rpc_sysfs_xprt_srcaddr_show()
117 sock = container_of(xprt, struct sock_xprt, xprt); in rpc_sysfs_xprt_srcaddr_show()
134 if (!xprt || !xprt_connected(xprt)) { in rpc_sysfs_xprt_info_show()
144 xprt->last_used, xprt->cong, xprt->cwnd, xprt->max_reqs, in rpc_sysfs_xprt_info_show()
145 xprt->min_reqs, xprt->num_reqs, xprt->binding.qlen, in rpc_sysfs_xprt_info_show()
146 xprt->sending.qlen, xprt->pending.qlen, in rpc_sysfs_xprt_info_show()
147 xprt->backlog.qlen, xprt->main, in rpc_sysfs_xprt_info_show()
166 if (!xprt) in rpc_sysfs_xprt_state_show()
563 rpc_xprt_switch->xprt = xprt; in rpc_sysfs_xprt_switch_setup()
[all …]
A Dxprtmultipath.c32 struct rpc_xprt *xprt) in xprt_switch_add_xprt_locked() argument
52 struct rpc_xprt *xprt) in rpc_xprt_switch_add_xprt() argument
54 if (xprt == NULL) in rpc_xprt_switch_add_xprt()
64 struct rpc_xprt *xprt) in xprt_switch_remove_xprt_locked() argument
90 xprt_put(xprt); in rpc_xprt_switch_remove_xprt()
159 xprt_put(xprt); in xprt_switch_free_entries()
376 if (!xprt) in xprt_switch_find_next_entry_roundrobin()
384 cur = xprt; in xprt_switch_find_next_entry_roundrobin()
386 return xprt; in xprt_switch_find_next_entry_roundrobin()
534 return xprt; in xprt_iter_get_xprt()
[all …]
A Dclnt.c819 if (!xprt) in rpc_clnt_iterate_for_each_xprt()
993 if (!xprt) in rpc_task_get_xprt()
1022 if (xprt) { in rpc_task_release_transport()
1476 xprt->ops->set_buffer_size(xprt, sndsize, rcvsize); in rpc_setbufsize()
1528 ret = xprt->ops->bc_maxpayload(xprt); in rpc_max_bc_payload()
1541 ret = xprt->ops->bc_num_slots(xprt); in rpc_num_bc_slots()
2800 data->xprt = xprt_get(xprt); in rpc_clnt_test_and_add_xprt()
2842 xprt = xprt_get(xprt); in rpc_clnt_setup_test_and_add_xprt()
2927 xprt->ops->set_connect_timeout(xprt, in rpc_clnt_add_xprt()
2959 xprt->ops->set_connect_timeout(xprt, in rpc_xprt_set_connect_timeout()
[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.c577 mutex_lock(&xprt->xpt_mutex); in svc_udp_sendto()
579 if (svc_xprt_is_dead(xprt)) in svc_udp_sendto()
591 mutex_unlock(&xprt->xpt_mutex); in svc_udp_sendto()
597 mutex_unlock(&xprt->xpt_mutex); in svc_udp_sendto()
1171 mutex_lock(&xprt->xpt_mutex); in svc_tcp_sendto()
1172 if (svc_xprt_is_dead(xprt)) in svc_tcp_sendto()
1182 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1187 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1191 xprt->xpt_server->sv_name, in svc_tcp_sendto()
1194 svc_xprt_deferred_close(xprt); in svc_tcp_sendto()
[all …]
A Dsvcauth_unix.c342 spin_lock(&xprt->xpt_lock); in ip_map_cached_get()
343 ipm = xprt->xpt_auth_cache; in ip_map_cached_get()
352 xprt->xpt_auth_cache = NULL; in ip_map_cached_get()
353 spin_unlock(&xprt->xpt_lock); in ip_map_cached_get()
359 spin_unlock(&xprt->xpt_lock); in ip_map_cached_get()
368 spin_lock(&xprt->xpt_lock); in ip_map_cached_put()
371 xprt->xpt_auth_cache = ipm; in ip_map_cached_put()
374 spin_unlock(&xprt->xpt_lock); in ip_map_cached_put()
666 struct net *net = xprt->xpt_net; in svcauth_unix_set_client()
687 ipm = ip_map_cached_get(xprt); in svcauth_unix_set_client()
[all …]
/linux/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()
698 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.c108 if (!xprt_connected(xprt)) in xprt_rdma_bc_send_reply()
126 xprt_rdma_close(xprt); in xprt_rdma_bc_send_reply()
139 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_destroy()
165 spin_lock(&xprt->bc_pa_lock); in xprt_rdma_bc_free_rqst()
168 xprt_put(xprt); in xprt_rdma_bc_free_rqst()
178 spin_lock(&xprt->bc_pa_lock); in rpcrdma_bc_rqst_get()
204 xprt->bc_alloc_count++; in rpcrdma_bc_rqst_get()
206 rqst->rq_xprt = xprt; in rpcrdma_bc_rqst_get()
268 bc_serv = xprt->bc_serv; in rpcrdma_bc_receive_call()
269 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);
104 struct svc_xprt *xprt = context; in qp_event_handler() local
122 svc_xprt_deferred_close(xprt); in qp_event_handler()
275 struct svc_xprt *xprt = &rdma->sc_xprt; in svc_rdma_cma_handler() local
283 svc_xprt_enqueue(xprt); in svc_rdma_cma_handler()
287 svc_xprt_deferred_close(xprt); in svc_rdma_cma_handler()
379 clear_bit(XPT_CONN, &xprt->xpt_flags); in svc_rdma_accept()
536 static void svc_rdma_detach(struct svc_xprt *xprt) in svc_rdma_detach() argument
[all …]
A Drpc_rdma.c1003 spin_lock(&xprt->transport_lock); in rpcrdma_update_cwnd()
1020 xprt->cong = 0; in rpcrdma_reset_cwnd()
1360 spin_lock(&xprt->queue_lock); in rpcrdma_unpin_rqst()
1362 spin_unlock(&xprt->queue_lock); in rpcrdma_unpin_rqst()
1397 spin_lock(&xprt->queue_lock); in rpcrdma_complete_rqst()
1400 spin_unlock(&xprt->queue_lock); in rpcrdma_complete_rqst()
1439 if (xprt->reestablish_timeout) in rpcrdma_reply_handler()
1440 xprt->reestablish_timeout = 0; in rpcrdma_reply_handler()
1462 spin_lock(&xprt->queue_lock); in rpcrdma_reply_handler()
1467 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()
836 if (svc_rdma_is_reverse_direction_reply(xprt, ctxt)) in svc_rdma_recvfrom()
850 svc_xprt_copy_addrs(rqstp, xprt); in svc_rdma_recvfrom()
/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
149 void (*close)(struct rpc_xprt *xprt);
150 void (*destroy)(struct rpc_xprt *xprt);
158 int (*bc_setup)(struct rpc_xprt *xprt,
371 void xprt_put(struct rpc_xprt *xprt);
381 xprt_enable_swap(struct rpc_xprt *xprt) in xprt_enable_swap() argument
383 return xprt->ops->enable_swap(xprt); in xprt_enable_swap()
389 xprt->ops->disable_swap(xprt); in xprt_disable_swap()
438 set_bit(XPRT_CONNECTED, &xprt->state); in xprt_set_connected()
[all …]
A Dsvc_xprt.h123 (test_bit(XPT_CLOSE, &xprt->xpt_flags) != 0); in svc_xprt_is_dead()
133 void svc_xprt_received(struct svc_xprt *xprt);
135 void svc_xprt_enqueue(struct svc_xprt *xprt);
136 void svc_xprt_put(struct svc_xprt *xprt);
138 void svc_close_xprt(struct svc_xprt *xprt);
151 kref_get(&xprt->xpt_ref); in svc_xprt_get()
157 memcpy(&xprt->xpt_local, sa, salen); in svc_xprt_set_local()
158 xprt->xpt_locallen = salen; in svc_xprt_set_local()
164 memcpy(&xprt->xpt_remote, sa, salen); in svc_xprt_set_remote()
165 xprt->xpt_remotelen = salen; in svc_xprt_set_remote()
[all …]
A Dbc_xprt.h35 struct rpc_rqst *xprt_lookup_bc_request(struct rpc_xprt *xprt, __be32 xid);
43 int xprt_setup_bc(struct rpc_xprt *xprt, unsigned int min_reqs);
44 void xprt_destroy_bc(struct rpc_xprt *xprt, unsigned int max_reqs);
46 unsigned int xprt_bc_max_slots(struct rpc_xprt *xprt);
61 static inline int xprt_setup_backchannel(struct rpc_xprt *xprt, in xprt_setup_backchannel() argument
67 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);
A Dclnt.h146 struct rpc_xprt *xprt,
179 struct rpc_xprt *xprt);
220 struct rpc_xprt *xprt,
/linux/include/trace/events/
A Dsunrpc.h963 TP_ARGS(xprt),
988 TP_ARGS(xprt))
1113 TP_ARGS(xprt, status),
1136 TP_ARGS(xprt, task),
1179 TP_ARGS(xprt, task),
1259 __string(addr, xprt ? xprt->address_strings[RPC_DISPLAY_ADDR] :
1261 __string(port, xprt ? xprt->address_strings[RPC_DISPLAY_PORT] :
1774 TP_ARGS(xprt, rqst),
1795 TP_ARGS(xprt),
1816 TP_ARGS(xprt))
[all …]
/linux/fs/nfs/
A Dcallback.c144 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, in nfs_callback_bc_serv() argument
152 xprt->bc_serv = serv; in nfs_callback_bc_serv()
155 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, in nfs_callback_bc_serv() argument
161 static int nfs_callback_start_svc(int minorversion, struct rpc_xprt *xprt, in nfs_callback_start_svc() argument
167 nfs_callback_bc_serv(minorversion, xprt, serv); in nfs_callback_start_svc()
196 struct net *net, struct rpc_xprt *xprt) in nfs_callback_up_net() argument
215 else if (xprt->ops->bc_setup) in nfs_callback_up_net()
314 int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt) in nfs_callback_up() argument
319 struct net *net = xprt->xprt_net; in nfs_callback_up()
329 ret = nfs_callback_up_net(minorversion, serv, net, xprt); in nfs_callback_up()
[all …]

Completed in 81 milliseconds

123456