Home
last modified time | relevance | path

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

123

/openbmc/linux/net/sunrpc/
H 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 …]
H 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()
443 if (xprt->xpt_ops->xpo_has_wspace(xprt) && in svc_xprt_ready()
794 xprt->xpt_ops->xpo_kill_temp_xprt(xprt); in svc_handle_xprt()
807 newxpt = xprt->xpt_ops->xpo_accept(xprt); in svc_handle_xprt()
817 xprt->xpt_ops->xpo_handshake(xprt); in svc_handle_xprt()
996 xprt); in svc_age_temp_xprts_now()
1027 xprt->xpt_ops->xpo_detach(xprt); in svc_delete_xprt()
1029 xprt->xpt_bc_xprt->ops->close(xprt->xpt_bc_xprt); in svc_delete_xprt()
[all …]
H 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 …]
H 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
922 container_of(xprt, struct sock_xprt, xprt); in xs_local_send_request()
1239 struct rpc_xprt *xprt = &transport->xprt; in xs_reset_transport() local
1309 xprt); in xs_inject_disconnect()
1973 struct rpc_xprt *xprt = &transport->xprt; in xs_local_setup_socket() local
2173 struct rpc_xprt *xprt = &transport->xprt; in xs_udp_setup_socket() local
2280 container_of(xprt, struct sock_xprt, xprt); in xs_tcp_do_set_connect_timeout()
2378 struct rpc_xprt *xprt = &transport->xprt; in xs_tcp_setup_socket() local
[all …]
H 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 …]
H 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 …]
H A Dclnt.c550 if (xprt) { in rpc_create()
855 if (!xprt) in rpc_clnt_iterate_for_each_xprt()
1082 if (!xprt) in rpc_task_get_xprt()
1111 if (xprt) { in rpc_task_release_transport()
1575 xprt->ops->set_buffer_size(xprt, sndsize, rcvsize); in rpc_setbufsize()
1627 ret = xprt->ops->bc_maxpayload(xprt); in rpc_max_bc_payload()
1640 ret = xprt->ops->bc_num_slots(xprt); in rpc_num_bc_slots()
2951 data->xprt = xprt_get(xprt); in rpc_clnt_test_and_add_xprt()
3018 xprt = xprt_get(xprt); in rpc_clnt_setup_test_and_add_xprt()
3100 xprt->ops->set_connect_timeout(xprt, in rpc_clnt_add_xprt()
[all …]
H 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 …]
H 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);
H 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()
1277 mutex_lock(&xprt->xpt_mutex); in svc_tcp_sendto()
1278 if (svc_xprt_is_dead(xprt)) in svc_tcp_sendto()
1292 xprt->xpt_server->sv_name, in svc_tcp_sendto()
[all …]
H 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 …]
H 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()
873 trace_svc_tls_start(xprt); in svcauth_tls_accept()
[all …]
/openbmc/linux/net/sunrpc/xprtrdma/
H A Dtransport.c286 xprt_free(xprt); in xprt_rdma_destroy()
305 struct rpc_xprt *xprt; in xprt_setup_rdma() local
318 if (!xprt) { in xprt_setup_rdma()
324 xprt->connect_timeout = xprt->timeout->to_initval; in xprt_setup_rdma()
325 xprt->max_reconnect_timeout = xprt->timeout->to_maxval; in xprt_setup_rdma()
343 memcpy(&xprt->addr, sap, xprt->addrlen); in xprt_setup_rdma()
353 xprt_free(xprt); in xprt_setup_rdma()
363 return xprt; in xprt_setup_rdma()
450 to = *xprt->timeout; in xprt_rdma_set_connect_timeout()
684 xprt->stat.sends, in xprt_rdma_print_stats()
[all …]
H A Dsvc_rdma_backchannel.c210 xprt_free(xprt); in xprt_rdma_bc_put()
240 struct rpc_xprt *xprt; in xprt_setup_rdma_bc() local
249 if (!xprt) in xprt_setup_rdma_bc()
253 xprt_set_bound(xprt); in xprt_setup_rdma_bc()
255 xprt->bind_timeout = 0; in xprt_setup_rdma_bc()
257 xprt->idle_timeout = 0; in xprt_setup_rdma_bc()
264 xprt_rdma_format_addresses(xprt, (struct sockaddr *)&xprt->addr); in xprt_setup_rdma_bc()
265 xprt->resvport = 0; in xprt_setup_rdma_bc()
272 xprt_get(xprt); in xprt_setup_rdma_bc()
277 xprt_get(xprt); in xprt_setup_rdma_bc()
[all …]
H 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 …]
H 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 …]
H 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 …]
H A Dsvc_rdma_recvfrom.c247 void svc_rdma_release_ctxt(struct svc_xprt *xprt, void *vctxt) in svc_rdma_release_ctxt() argument
251 container_of(xprt, struct svcxprt_rdma, sc_xprt); in svc_rdma_release_ctxt()
730 static bool svc_rdma_is_reverse_direction_reply(struct svc_xprt *xprt, in svc_rdma_is_reverse_direction_reply() argument
735 if (!xprt->xpt_bc_xprt) in svc_rdma_is_reverse_direction_reply()
787 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_rdma_recvfrom() local
789 container_of(xprt, struct svcxprt_rdma, sc_xprt); in svc_rdma_recvfrom()
808 clear_bit(XPT_DATA, &xprt->xpt_flags); in svc_rdma_recvfrom()
812 svc_xprt_received(xprt); in svc_rdma_recvfrom()
828 if (svc_rdma_is_reverse_direction_reply(xprt, ctxt)) in svc_rdma_recvfrom()
842 svc_xprt_copy_addrs(rqstp, xprt); in svc_rdma_recvfrom()
[all …]
/openbmc/linux/include/linux/sunrpc/
H A Dxprt.h30 #define RPC_MAXCWND(xprt) ((xprt)->max_reqs << RPC_CWNDSHIFT) argument
31 #define RPCXPRT_CONGESTED(xprt) ((xprt)->cong >= (xprt)->cwnd) argument
168 void (*close)(struct rpc_xprt *xprt);
169 void (*destroy)(struct rpc_xprt *xprt);
177 int (*bc_setup)(struct rpc_xprt *xprt,
395 void xprt_put(struct rpc_xprt *xprt);
405 xprt_enable_swap(struct rpc_xprt *xprt) in xprt_enable_swap() argument
407 return xprt->ops->enable_swap(xprt); in xprt_enable_swap()
413 xprt->ops->disable_swap(xprt); in xprt_disable_swap()
462 set_bit(XPRT_CONNECTED, &xprt->state); in xprt_set_connected()
[all …]
H A Dsvc_xprt.h30 void (*xpo_handshake)(struct svc_xprt *xprt);
143 void svc_xprt_received(struct svc_xprt *xprt);
144 void svc_xprt_enqueue(struct svc_xprt *xprt);
145 void svc_xprt_put(struct svc_xprt *xprt);
147 void svc_xprt_close(struct svc_xprt *xprt);
160 kref_get(&xprt->xpt_ref); in svc_xprt_get()
166 memcpy(&xprt->xpt_local, sa, salen); in svc_xprt_set_local()
167 xprt->xpt_locallen = salen; in svc_xprt_set_local()
173 memcpy(&xprt->xpt_remote, sa, salen); in svc_xprt_set_remote()
174 xprt->xpt_remotelen = salen; in svc_xprt_set_remote()
[all …]
H 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
/openbmc/linux/include/trace/events/
H A Dsunrpc.h1007 TP_ARGS(xprt),
1032 TP_ARGS(xprt))
1179 TP_ARGS(xprt, task),
1225 TP_ARGS(xprt, task),
1306 TP_ARGS(xprt),
1329 __string(addr, xprt ? xprt->address_strings[RPC_DISPLAY_ADDR] :
1331 __string(port, xprt ? xprt->address_strings[RPC_DISPLAY_PORT] :
1538 TP_ARGS(clnt, xprt),
2067 TP_ARGS(xprt),
2085 TP_ARGS(xprt))
[all …]
/openbmc/openbmc/meta-openembedded/meta-networking/recipes-protocols/openl2tp/openl2tp/
H A D0002-user-ipv6-structures.patch20 @@ -450,10 +450,12 @@ int l2tp_api_rpc_check_request(SVCXPRT *xprt)
24 - ((xprt->xp_raddr.sin_addr.s_addr != htonl(INADDR_LOOPBACK)) &&
25 - (xprt->xp_raddr.sin_addr.s_addr != htonl(INADDR_ANY)))) {
26 + ((memcmp(&xprt->xp_raddr.sin6_addr, &in6addr_loopback, sizeof(struct in6_addr)) != 0) &&
27 + (memcmp(&xprt->xp_raddr.sin6_addr, &in6addr_any, sizeof(struct in6_addr)) != 0))) {
29 + inet_ntop(AF_INET6, &xprt->xp_raddr.sin6_addr, straddr, sizeof(straddr));
31 - l2tp_log(LOG_ERR, "Rejecting RPC request from %s", inet_ntoa(xprt->xp_raddr.sin_addr));
34 svcerr_auth(xprt, AUTH_TOOWEAK);
/openbmc/openbmc/meta-openembedded/meta-networking/recipes-daemons/ippool/ippool/
H A D0003-musl-fixes.patch55 - ((xprt->xp_raddr.sin_addr.s_addr != htonl(INADDR_LOOPBACK)) &&
56 - (xprt->xp_raddr.sin_addr.s_addr != htonl(INADDR_ANY)))) {
57 + ((xprt->xp_raddr.sin6_addr.s6_addr != htonl(INADDR_LOOPBACK)) &&
58 + (xprt->xp_raddr.sin6_addr.s6_addr != htonl(INADDR_ANY)))) {
60 + inet_ntop(AF_INET6, &xprt->xp_raddr.sin6_addr, straddr, sizeof(straddr));
63 - ippool_log(LOG_ERR, "Rejecting RPC request from %s", inet_ntoa(xprt->xp_raddr.sin_addr));
66 svcerr_auth(xprt, AUTH_TOOWEAK);
/openbmc/linux/fs/nfs/
H A Dcallback.c128 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, in nfs_callback_bc_serv() argument
136 xprt->bc_serv = serv; in nfs_callback_bc_serv()
139 static inline void nfs_callback_bc_serv(u32 minorversion, struct rpc_xprt *xprt, in nfs_callback_bc_serv() argument
145 static int nfs_callback_start_svc(int minorversion, struct rpc_xprt *xprt, in nfs_callback_start_svc() argument
151 nfs_callback_bc_serv(minorversion, xprt, serv); in nfs_callback_start_svc()
180 struct net *net, struct rpc_xprt *xprt) in nfs_callback_up_net() argument
199 else if (xprt->ops->bc_setup) in nfs_callback_up_net()
265 int nfs_callback_up(u32 minorversion, struct rpc_xprt *xprt) in nfs_callback_up() argument
270 struct net *net = xprt->xprt_net; in nfs_callback_up()
280 ret = nfs_callback_up_net(minorversion, serv, net, xprt); in nfs_callback_up()
[all …]

123