Lines Matching refs:serv
499 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_udp_recvfrom() local
524 svc_sock_setbufsize(svsk, serv->sv_nrthreads + 3); in svc_udp_recvfrom()
594 if (serv->sv_stats) in svc_udp_recvfrom()
595 serv->sv_stats->netudpcnt++; in svc_udp_recvfrom()
619 struct svc_serv *serv = xprt->xpt_server; in svc_udp_has_wspace() local
627 required = atomic_read(&svsk->sk_xprt.xpt_reserved) + serv->sv_max_mesg; in svc_udp_has_wspace()
644 static struct svc_xprt *svc_udp_create(struct svc_serv *serv, in svc_udp_create() argument
649 return svc_create_socket(serv, IPPROTO_UDP, net, sa, salen, flags); in svc_udp_create()
673 static void svc_udp_init(struct svc_sock *svsk, struct svc_serv *serv) in svc_udp_init() argument
678 &svsk->sk_xprt, serv); in svc_udp_init()
778 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_accept() local
794 serv->sv_name); in svc_tcp_accept()
797 serv->sv_name, -err); in svc_tcp_accept()
805 serv->sv_name, -err); in svc_tcp_accept()
816 serv->sv_name, in svc_tcp_accept()
819 dprintk("%s: connect from %s\n", serv->sv_name, in svc_tcp_accept()
832 newsvsk = svc_setup_socket(serv, newsock, in svc_tcp_accept()
849 if (serv->sv_stats) in svc_tcp_accept()
850 serv->sv_stats->nettcpconn++; in svc_tcp_accept()
919 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_recv_record() local
942 serv->sv_max_mesg) { in svc_tcp_recv_record()
1034 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_recvfrom() local
1113 if (serv->sv_stats) in svc_tcp_recvfrom()
1114 serv->sv_stats->nettcpcnt++; in svc_tcp_recvfrom()
1162 static struct svc_xprt *svc_tcp_create(struct svc_serv *serv, in svc_tcp_create() argument
1167 return svc_create_socket(serv, IPPROTO_TCP, net, sa, salen, flags); in svc_tcp_create()
1203 static void svc_tcp_init(struct svc_sock *svsk, struct svc_serv *serv) in svc_tcp_init() argument
1208 &svsk->sk_xprt, serv); in svc_tcp_init()
1241 void svc_sock_update_bufs(struct svc_serv *serv) in svc_sock_update_bufs() argument
1249 spin_lock_bh(&serv->sv_lock); in svc_sock_update_bufs()
1250 list_for_each_entry(svsk, &serv->sv_permsocks, sk_xprt.xpt_list) in svc_sock_update_bufs()
1252 spin_unlock_bh(&serv->sv_lock); in svc_sock_update_bufs()
1259 static struct svc_sock *svc_setup_socket(struct svc_serv *serv, in svc_setup_socket() argument
1277 err = svc_register(serv, sock_net(sock->sk), inet->sk_family, in svc_setup_socket()
1301 svc_udp_init(svsk, serv); in svc_setup_socket()
1303 svc_tcp_init(svsk, serv); in svc_setup_socket()
1342 int svc_addsock(struct svc_serv *serv, const int fd, char *name_return, in svc_addsock() argument
1367 svsk = svc_setup_socket(serv, so, SVC_SOCK_DEFAULTS); in svc_addsock()
1377 svc_add_new_perm_xprt(serv, &svsk->sk_xprt); in svc_addsock()
1388 static struct svc_xprt *svc_create_socket(struct svc_serv *serv, in svc_create_socket() argument
1406 serv->sv_program->pg_name, protocol, in svc_create_socket()
1459 svsk = svc_setup_socket(serv, sock, flags); in svc_create_socket()