445 	struct svc_serv *serv = svsk->sk_xprt.xpt_server;  in svc_tcp_has_wspace()  local
450 	required = atomic_read(&xprt->xpt_reserved) + serv->sv_max_mesg;  in svc_tcp_has_wspace()
541 	struct svc_serv	*serv = svsk->sk_xprt.xpt_server;  in svc_udp_recvfrom()  local
567 				(serv->sv_nrthreads+3) * serv->sv_max_mesg,  in svc_udp_recvfrom()
568 				(serv->sv_nrthreads+3) * serv->sv_max_mesg);  in svc_udp_recvfrom()
639 	if (serv->sv_stats)  in svc_udp_recvfrom()
640 		serv->sv_stats->netudpcnt++;  in svc_udp_recvfrom()
669 	struct svc_serv	*serv = xprt->xpt_server;  in svc_udp_has_wspace()  local
677 	required = atomic_read(&svsk->sk_xprt.xpt_reserved) + serv->sv_max_mesg;  in svc_udp_has_wspace()
690 static struct svc_xprt *svc_udp_create(struct svc_serv *serv,  in svc_udp_create()  argument
695 	return svc_create_socket(serv, IPPROTO_UDP, net, sa, salen, flags);  in svc_udp_create()
719 static void svc_udp_init(struct svc_sock *svsk, struct svc_serv *serv)  in svc_udp_init()  argument
724 		      &svsk->sk_xprt, serv);  in svc_udp_init()
838 	struct svc_serv	*serv = svsk->sk_xprt.xpt_server;  in svc_tcp_accept()  local
854 			       serv->sv_name);  in svc_tcp_accept()
857 					     serv->sv_name, -err);  in svc_tcp_accept()
865 				     serv->sv_name, -err);  in svc_tcp_accept()
875 			serv->sv_name,  in svc_tcp_accept()
878 	dprintk("%s: connect from %s\n", serv->sv_name,  in svc_tcp_accept()
886 	newsvsk = svc_setup_socket(serv, newsock,  in svc_tcp_accept()
902 	if (serv->sv_stats)  in svc_tcp_accept()
903 		serv->sv_stats->nettcpconn++;  in svc_tcp_accept()
972 	struct svc_serv	*serv = svsk->sk_xprt.xpt_server;  in svc_tcp_recv_record()  local
994 							serv->sv_max_mesg) {  in svc_tcp_recv_record()
1086 	struct svc_serv	*serv = svsk->sk_xprt.xpt_server;  in svc_tcp_recvfrom()  local
1166 	if (serv->sv_stats)  in svc_tcp_recvfrom()
1167 		serv->sv_stats->nettcpcnt++;  in svc_tcp_recvfrom()
1226 static struct svc_xprt *svc_tcp_create(struct svc_serv *serv,  in svc_tcp_create()  argument
1231 	return svc_create_socket(serv, IPPROTO_TCP, net, sa, salen, flags);  in svc_tcp_create()
1240 static struct svc_xprt *svc_bc_tcp_create(struct svc_serv *serv,  in svc_bc_tcp_create()  argument
1245 	return svc_bc_create_socket(serv, IPPROTO_TCP, net, sa, salen, flags);  in svc_bc_tcp_create()
1322 static void svc_tcp_init(struct svc_sock *svsk, struct svc_serv *serv)  in svc_tcp_init()  argument
1327 		      &svsk->sk_xprt, serv);  in svc_tcp_init()
1353 void svc_sock_update_bufs(struct svc_serv *serv)  in svc_sock_update_bufs()  argument
1361 	spin_lock_bh(&serv->sv_lock);  in svc_sock_update_bufs()
1362 	list_for_each_entry(svsk, &serv->sv_permsocks, sk_xprt.xpt_list)  in svc_sock_update_bufs()
1364 	spin_unlock_bh(&serv->sv_lock);  in svc_sock_update_bufs()
1372 static struct svc_sock *svc_setup_socket(struct svc_serv *serv,  in svc_setup_socket()  argument
1390 		err = svc_register(serv, sock_net(sock->sk), inet->sk_family,  in svc_setup_socket()
1408 		svc_udp_init(svsk, serv);  in svc_setup_socket()
1413 		svc_sock_setbufsize(svsk->sk_sock, 4 * serv->sv_max_mesg,  in svc_setup_socket()
1414 					4 * serv->sv_max_mesg);  in svc_setup_socket()
1415 		svc_tcp_init(svsk, serv);  in svc_setup_socket()
1451 int svc_addsock(struct svc_serv *serv, const int fd, char *name_return,  in svc_addsock()  argument
1476 	svsk = svc_setup_socket(serv, so, SVC_SOCK_DEFAULTS);  in svc_addsock()
1484 	svc_add_new_perm_xprt(serv, &svsk->sk_xprt);  in svc_addsock()
1495 static struct svc_xprt *svc_create_socket(struct svc_serv *serv,  in svc_create_socket()  argument
1513 			serv->sv_program->pg_name, protocol,  in svc_create_socket()
1566 	svsk = svc_setup_socket(serv, sock, flags);  in svc_create_socket()
1637 static struct svc_xprt *svc_bc_create_socket(struct svc_serv *serv,  in svc_bc_create_socket()  argument
1657 	svc_xprt_init(net, &svc_tcp_bc_class, xprt, serv);  in svc_bc_create_socket()
1659 	serv->sv_bc_xprt = xprt;  in svc_bc_create_socket()