net/sunrpc/svcsock.c

566 	struct svc_serv	*serv = svsk->sk_xprt.xpt_server;
591 	    svc_sock_setbufsize(svsk, serv->sv_nrthreads + 3);
650 	if (serv->sv_stats)
651 		serv->sv_stats->netudpcnt++;
742 	struct svc_serv	*serv = xprt->xpt_server;
750 	required = atomic_read(&svsk->sk_xprt.xpt_reserved) + serv->sv_max_mesg;
767 static struct svc_xprt *svc_udp_create(struct svc_serv *serv,
772 	return svc_create_socket(serv, IPPROTO_UDP, net, sa, salen, flags);
796 static void svc_udp_init(struct svc_sock *svsk, struct svc_serv *serv)
799 		      &svsk->sk_xprt, serv);
885 	struct svc_serv	*serv = svsk->sk_xprt.xpt_server;
898 			trace_svcsock_accept_err(xprt, serv->sv_name, err);
908 		trace_svcsock_getpeername_err(xprt, serv->sv_name, err);
923 	newsvsk = svc_setup_socket(serv, newsock,
938 	if (serv->sv_stats)
939 		serv->sv_stats->nettcpconn++;
1113 	struct svc_serv	*serv = svsk->sk_xprt.xpt_server;
1165 	if (serv->sv_stats)
1166 		serv->sv_stats->nettcpcnt++;
1290 static struct svc_xprt *svc_tcp_create(struct svc_serv *serv,
1295 	return svc_create_socket(serv, IPPROTO_TCP, net, sa, salen, flags);
1332 static void svc_tcp_init(struct svc_sock *svsk, struct svc_serv *serv)
1337 		      &svsk->sk_xprt, serv);
1368 void svc_sock_update_bufs(struct svc_serv *serv)
1376 	spin_lock_bh(&serv->sv_lock);
1377 	list_for_each_entry(svsk, &serv->sv_permsocks, sk_xprt.xpt_list)
1379 	spin_unlock_bh(&serv->sv_lock);
1386 static struct svc_sock *svc_setup_socket(struct svc_serv *serv,
1403 		err = svc_register(serv, sock_net(sock->sk), inet->sk_family,
1427 		svc_udp_init(svsk, serv);
1429 		svc_tcp_init(svsk, serv);
1437  * @serv: pointer to RPC service to which to add a new listener
1448 int svc_addsock(struct svc_serv *serv, struct net *net, const int fd,
1476 	svsk = svc_setup_socket(serv, so, SVC_SOCK_DEFAULTS);
1486 	svc_add_new_perm_xprt(serv, &svsk->sk_xprt);
1497 static struct svc_xprt *svc_create_socket(struct svc_serv *serv,
1559 	svsk = svc_setup_socket(serv, sock, flags);