| /linux/fs/nfs/ |
| H A D | callback.c | 34 struct svc_serv *serv; member
41 static int nfs4_callback_up_net(struct svc_serv *serv, struct net *net) in nfs4_callback_up_net() argument
47 ret = svc_xprt_create(serv, "tcp", net, PF_INET, in nfs4_callback_up_net()
56 ret = svc_xprt_create(serv, "tcp", net, PF_INET6, in nfs4_callback_up_net()
91 struct svc_serv *serv) in nfs_callback_bc_serv() argument
98 xprt->bc_serv = serv; in nfs_callback_bc_serv()
102 struct svc_serv *serv) in nfs_callback_start_svc() argument
107 nfs_callback_bc_serv(minorversion, xprt, serv); in nfs_callback_start_svc()
112 if (serv->sv_nrthreads == nrservs) in nfs_callback_start_svc()
115 ret = svc_set_num_threads(serv, 0, nrservs); in nfs_callback_start_svc()
[all …]
|
| /linux/tools/testing/selftests/bpf/prog_tests/ |
| H A D | sock_destroy.c | 38 int serv = -1, clien = -1, accept_serv = -1, n; in test_tcp_client() local
40 serv = start_server(AF_INET6, SOCK_STREAM, NULL, 0, 0); in test_tcp_client()
41 if (!ASSERT_GE(serv, 0, "start_server")) in test_tcp_client()
44 clien = connect_to_fd(serv, 0); in test_tcp_client()
48 accept_serv = accept(serv, NULL, NULL); in test_tcp_client()
69 if (serv != -1) in test_tcp_client()
70 close(serv); in test_tcp_client()
75 int serv = -1, clien = -1, accept_serv = -1, n, serv_port; in test_tcp_server() local
77 serv = start_server(AF_INET6, SOCK_STREAM, NULL, 0, 0); in test_tcp_server()
78 if (!ASSERT_GE(serv, 0, "start_server")) in test_tcp_server()
[all …]
|
| H A D | sock_addr.c | 2283 int serv = -1, client = -1, err; in test_bind() local
2285 serv = test->ops->start_server(test->socket_family, test->socket_type, in test_bind()
2288 if (serv < 0) { in test_bind()
2299 err = cmp_sock_addr(test->ops->getsockname, serv, &expected_addr, in test_bind()
2314 if (serv != -1) in test_bind()
2315 test->ops->close(serv); in test_bind()
2326 int serv = -1, client = -1, err; in test_connect() local
2328 serv = start_server(test->socket_family, test->socket_type, in test_connect()
2330 if (!ASSERT_GE(serv, 0, "start_server")) in test_connect()
2374 if (serv != -1) in test_connect()
[all …]
|
| /linux/net/sunrpc/ |
| H A D | svc.c | 39 static void svc_unregister(const struct svc_serv *serv, struct net *net);
247 unsigned int svc_serv_nrpools(const struct svc_serv *serv) in svc_serv_nrpools() argument
249 return serv->sv_is_pooled ? svc_pool_map.npools : 1; in svc_serv_nrpools()
263 struct svc_pool *svc_pool_for_cpu(struct svc_serv *serv) in svc_pool_for_cpu() argument
265 unsigned int nrpools = svc_serv_nrpools(serv); in svc_pool_for_cpu()
270 return serv->sv_pools; in svc_pool_for_cpu()
285 struct svc_pool *pool = &serv->sv_pools[pidx]; in svc_pool_for_cpu()
298 return &serv->sv_pools[pidx]; in svc_pool_for_cpu()
301 static int svc_rpcb_setup(struct svc_serv *serv, struct net *net) in svc_rpcb_setup() argument
310 svc_unregister(serv, net); in svc_rpcb_setup()
[all …]
|
| H A D | svc_xprt.c | 196 struct svc_xprt *xprt, struct svc_serv *serv) in svc_xprt_init() argument
202 xprt->xpt_server = serv; in svc_xprt_init()
254 void svc_add_new_perm_xprt(struct svc_serv *serv, struct svc_xprt *new) in svc_add_new_perm_xprt() argument
257 spin_lock_bh(&serv->sv_lock); in svc_add_new_perm_xprt()
258 list_add(&new->xpt_list, &serv->sv_permsocks); in svc_add_new_perm_xprt()
259 spin_unlock_bh(&serv->sv_lock); in svc_add_new_perm_xprt()
263 static int _svc_xprt_create(struct svc_serv *serv, const char *xprt_name, in _svc_xprt_create() argument
281 newxprt = xcl->xcl_ops->xpo_create(serv, net, sap, len, flags); in _svc_xprt_create()
283 trace_svc_xprt_create_err(serv->sv_programs->pg_name, in _svc_xprt_create()
290 svc_add_new_perm_xprt(serv, newxprt); in _svc_xprt_create()
[all …]
|
| H A D | svcsock.c | 612 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_udp_recvfrom()
637 svc_sock_setbufsize(svsk, serv->sv_nrthreads + 3); in svc_udp_recvfrom()
692 if (serv->sv_stats) in svc_udp_recvfrom()
693 serv->sv_stats->netudpcnt++; in svc_udp_recvfrom()
788 struct svc_serv *serv = xprt->xpt_server; in svc_udp_has_wspace()
796 required = atomic_read(&svsk->sk_xprt.xpt_reserved) + serv->sv_max_mesg; in svc_udp_accept()
813 static struct svc_xprt *svc_udp_create(struct svc_serv *serv,
818 return svc_create_socket(serv, IPPROTO_UDP, net, sa, salen, flags);
842 static void svc_udp_init(struct svc_sock *svsk, struct svc_serv *serv) in svc_udp_init()
845 &svsk->sk_xprt, serv); in svc_udp_init()
604 struct svc_serv *serv = svsk->sk_xprt.xpt_server; svc_udp_recvfrom() local
779 struct svc_serv *serv = xprt->xpt_server; svc_udp_has_wspace() local
804 svc_udp_create(struct svc_serv * serv,struct net * net,struct sockaddr * sa,int salen,int flags) svc_udp_create() argument
833 svc_udp_init(struct svc_sock * svsk,struct svc_serv * serv) svc_udp_init() argument
923 struct svc_serv *serv = svsk->sk_xprt.xpt_server; svc_tcp_accept() local
1149 struct svc_serv *serv = svsk->sk_xprt.xpt_server; svc_tcp_recvfrom() local
1313 svc_tcp_create(struct svc_serv * serv,struct net * net,struct sockaddr * sa,int salen,int flags) svc_tcp_create() argument
1355 svc_tcp_init(struct svc_sock * svsk,struct svc_serv * serv) svc_tcp_init() argument
1393 svc_sock_update_bufs(struct svc_serv * serv) svc_sock_update_bufs() argument
1407 svc_sock_sendpages(struct svc_serv * serv,struct socket * sock,int flags) svc_sock_sendpages() argument
1424 svc_setup_socket(struct svc_serv * serv,struct socket * sock,int flags) svc_setup_socket() argument
1504 svc_addsock(struct svc_serv * serv,struct net * net,const int fd,char * name_return,const size_t len,const struct cred * cred) svc_addsock() argument
1553 svc_create_socket(struct svc_serv * serv,int protocol,struct net * net,struct sockaddr * sin,int len,int flags) svc_create_socket() argument
[all...] |
| H A D | backchannel_rqst.c | 31 void xprt_svc_destroy_nullify_bc(struct rpc_xprt *xprt, struct svc_serv **serv) in xprt_svc_destroy_nullify_bc() argument
33 struct svc_serv *bc_serv = *serv; in xprt_svc_destroy_nullify_bc()
42 svc_destroy(serv); in xprt_svc_destroy_nullify_bc()
|
| H A D | sunrpc.h | 44 void svc_sock_update_bufs(struct svc_serv *serv);
|
| /linux/include/linux/sunrpc/ |
| H A D | bc_xprt.h | 36 void xprt_svc_destroy_nullify_bc(struct rpc_xprt *xprt, struct svc_serv **serv);
46 static inline void set_bc_enabled(struct svc_serv *serv) in set_bc_enabled() argument
48 serv->sv_bc_enabled = true; in set_bc_enabled()
67 static inline void set_bc_enabled(struct svc_serv *serv) in set_bc_enabled() argument
79 static inline void xprt_svc_destroy_nullify_bc(struct rpc_xprt *xprt, struct svc_serv **serv) in xprt_svc_destroy_nullify_bc() argument
81 svc_destroy(serv); in xprt_svc_destroy_nullify_bc()
|
| H A D | svc_xprt.h | 122 struct svc_serv *serv = xpt->xpt_server; in svc_xprt_set_valid() local
124 spin_lock(&serv->sv_lock); in svc_xprt_set_valid()
125 serv->sv_tmpcnt -= 1; in svc_xprt_set_valid()
126 spin_unlock(&serv->sv_lock); in svc_xprt_set_valid()
164 int svc_xprt_create_from_sa(struct svc_serv *serv, const char *xprt_name,
167 int svc_xprt_create(struct svc_serv *serv, const char *xprt_name,
171 void svc_xprt_destroy_all(struct svc_serv *serv, struct net *net,
180 struct svc_xprt *svc_find_listener(struct svc_serv *serv, const char *xcl_name,
182 struct svc_xprt *svc_find_xprt(struct svc_serv *serv, const char *xcl_name,
185 int svc_xprt_names(struct svc_serv *serv, char *buf, const int buflen);
[all …]
|
| H A D | svc.h | 102 struct svc_serv *serv; member
181 static inline unsigned long svc_serv_maxpages(const struct svc_serv *serv) in svc_serv_maxpages() argument
183 return DIV_ROUND_UP(serv->sv_max_mesg, PAGE_SIZE) + 2 + 1; in svc_serv_maxpages()
452 void svc_rpcb_cleanup(struct svc_serv *serv, struct net *net);
453 int svc_bind(struct svc_serv *serv, struct net *net);
459 int svc_new_thread(struct svc_serv *serv, struct svc_pool *pool);
466 int svc_set_pool_threads(struct svc_serv *serv, struct svc_pool *pool,
468 int svc_set_num_threads(struct svc_serv *serv, unsigned int min_threads,
470 unsigned int svc_serv_maxthreads(const struct svc_serv *serv);
480 struct svc_pool *svc_pool_for_cpu(struct svc_serv *serv);
[all …]
|
| /linux/fs/lockd/ |
| H A D | svc.c | 157 static int create_lockd_listener(struct svc_serv *serv, const char *name, in create_lockd_listener() argument
164 xprt = svc_find_xprt(serv, name, net, family, 0); in create_lockd_listener()
166 return svc_xprt_create(serv, name, net, family, port, in create_lockd_listener()
172 static int create_lockd_family(struct svc_serv *serv, struct net *net, in create_lockd_family() argument
178 err = create_lockd_listener(serv, "udp", net, family, in create_lockd_family()
183 return create_lockd_listener(serv, "tcp", net, family, in create_lockd_family()
197 static int make_socks(struct svc_serv *serv, struct net *net, in make_socks() argument
203 err = create_lockd_family(serv, net, PF_INET, cred); in make_socks()
207 err = create_lockd_family(serv, net, PF_INET6, cred); in make_socks()
218 svc_xprt_destroy_all(serv, net, true); in make_socks()
[all …]
|
| /linux/fs/nfsd/ |
| H A D | nfssvc.c | 511 struct svc_serv *serv = nn->nfsd_serv; in nfsd_destroy_serv() local
533 svc_xprt_destroy_all(serv, net, true); in nfsd_destroy_serv()
535 svc_destroy(&serv); in nfsd_destroy_serv()
580 struct svc_serv *serv; in nfsd_shutdown_threads() local
583 serv = nn->nfsd_serv; in nfsd_shutdown_threads()
584 if (serv == NULL) { in nfsd_shutdown_threads()
590 svc_set_num_threads(serv, 0, 0); in nfsd_shutdown_threads()
606 struct svc_serv *serv; in nfsd_create_serv() local
622 serv = svc_create_pooled(nfsd_programs, ARRAY_SIZE(nfsd_programs), in nfsd_create_serv()
625 if (serv == NULL) { in nfsd_create_serv()
[all …]
|
| H A D | nfsctl.c | 737 struct svc_serv *serv; in __write_ports_addfd() local
748 serv = nn->nfsd_serv; in __write_ports_addfd()
749 err = svc_addsock(serv, net, fd, buf, SIMPLE_TRANSACTION_LIMIT, cred); in __write_ports_addfd()
751 if (!serv->sv_nrthreads && list_empty(&nn->nfsd_serv->sv_permsocks)) in __write_ports_addfd()
767 struct svc_serv *serv; in __write_ports_addxprt() local
780 serv = nn->nfsd_serv; in __write_ports_addxprt()
781 err = svc_xprt_create(serv, transport, net, in __write_ports_addxprt()
786 err = svc_xprt_create(serv, transport, net, in __write_ports_addxprt()
793 xprt = svc_find_xprt(serv, transport, net, PF_INET, port); in __write_ports_addxprt()
799 if (!serv->sv_nrthreads && list_empty(&nn->nfsd_serv->sv_permsocks)) in __write_ports_addxprt()
[all …]
|
| H A D | filecache.c | 455 struct svc_serv *serv; in nfsd_file_dispose_list_delayed() local
466 serv = nn->nfsd_serv; in nfsd_file_dispose_list_delayed()
467 if (serv) in nfsd_file_dispose_list_delayed()
468 svc_wake_up(serv); in nfsd_file_dispose_list_delayed()
500 struct svc_serv *serv = nn->nfsd_serv; in nfsd_file_net_dispose() local
502 if (serv) in nfsd_file_net_dispose()
503 svc_wake_up(serv); in nfsd_file_net_dispose()
|
| H A D | netns.h | 162 #define nfsd_serv nfsd_info.serv
|
| /linux/tools/usb/usbip/libsrc/ |
| H A D | vhci_driver.c | 431 char serv[NI_MAXSERV] = "unknown port"; in usbip_vhci_imported_device_dump() local
439 ret = read_record(idev->port, host, sizeof(host), serv, sizeof(serv), in usbip_vhci_imported_device_dump()
457 host, serv, remote_busid); in usbip_vhci_imported_device_dump()
|
| /linux/net/sunrpc/xprtrdma/ |
| H A D | svc_rdma_transport.c | 67 static struct svcxprt_rdma *svc_rdma_create_xprt(struct svc_serv *serv,
71 static struct svc_xprt *svc_rdma_create(struct svc_serv *serv,
180 static struct svcxprt_rdma *svc_rdma_create_xprt(struct svc_serv *serv, in svc_rdma_create_xprt() argument
192 svc_xprt_init(net, &svc_rdma_class, &cma_xprt->sc_xprt, serv); in svc_rdma_create_xprt()
378 static struct svc_xprt *svc_rdma_create(struct svc_serv *serv, in svc_rdma_create() argument
388 cma_xprt = svc_rdma_create_xprt(serv, net, NUMA_NO_NODE); in svc_rdma_create()
|
| /linux/tools/perf/Documentation/ |
| H A D | examples.txt | 97 0.90% git-update-serv /lib64/libc-2.5.so
98 0.73% git-update-serv /lib64/ld-2.5.so
|
| /linux/tools/testing/selftests/net/mptcp/ |
| H A D | mptcp_connect.c | 170 char *serv, socklen_t servlen) in xgetnameinfo() argument
173 int err = getnameinfo(addr, addrlen, host, hostlen, serv, servlen, in xgetnameinfo()
|