Lines Matching refs:sk_xprt

125 			container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt);  in svc_release_skb()
155 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
248 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_sendto()
332 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_recvfrom()
340 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_recvfrom()
347 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_recvfrom()
412 test_bit(XPT_BUSY, &svsk->sk_xprt.xpt_flags)); in svc_data_ready()
417 if (!test_and_set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags)) in svc_data_ready()
418 svc_xprt_enqueue(&svsk->sk_xprt); in svc_data_ready()
431 svsk, sk, test_bit(XPT_BUSY, &svsk->sk_xprt.xpt_flags)); in svc_write_space()
436 svc_xprt_enqueue(&svsk->sk_xprt); in svc_write_space()
442 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_has_wspace()
458 svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_kill_temp_xprt()
525 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom()
526 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_udp_recvfrom()
542 if (test_and_clear_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags)) in svc_udp_recvfrom()
555 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
566 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
578 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); /* there may be more data... */ in svc_udp_recvfrom()
651 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_has_wspace()
660 required = atomic_read(&svsk->sk_xprt.xpt_reserved) + serv->sv_max_mesg; in svc_udp_has_wspace()
712 &svsk->sk_xprt, serv); in svc_udp_init()
713 clear_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
722 3 * svsk->sk_xprt.xpt_server->sv_max_mesg, in svc_udp_init()
723 3 * svsk->sk_xprt.xpt_server->sv_max_mesg); in svc_udp_init()
726 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
727 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
776 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_listen_data_ready()
777 svc_xprt_enqueue(&svsk->sk_xprt); in svc_tcp_listen_data_ready()
800 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_state_change()
801 svc_xprt_enqueue(&svsk->sk_xprt); in svc_tcp_state_change()
811 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_accept()
814 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_accept()
825 clear_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
836 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
872 svc_xprt_set_remote(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
879 svc_xprt_set_local(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
882 set_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
884 clear_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
888 return &newsvsk->sk_xprt; in svc_tcp_accept()
955 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_recv_record()
989 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_recv_record()
995 struct rpc_xprt *bc_xprt = svsk->sk_xprt.xpt_bc_xprt; in receive_cb_reply()
1068 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_recvfrom()
1069 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_recvfrom()
1078 svsk, test_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags), in svc_tcp_recvfrom()
1079 test_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags), in svc_tcp_recvfrom()
1080 test_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags)); in svc_tcp_recvfrom()
1131 if (test_bit(XPT_LOCAL, &svsk->sk_xprt.xpt_flags)) in svc_tcp_recvfrom()
1148 svc_xprt_copy_addrs(rqstp, &svsk->sk_xprt); in svc_tcp_recvfrom()
1161 svsk->sk_xprt.xpt_server->sv_name, -len); in svc_tcp_recvfrom()
1162 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_recvfrom()
1310 &svsk->sk_xprt, serv); in svc_tcp_init()
1311 set_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1312 set_bit(XPT_CONG_CTRL, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1315 strcpy(svsk->sk_xprt.xpt_remotebuf, "listener"); in svc_tcp_init()
1316 set_bit(XPT_LISTENER, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1318 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1332 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1338 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1352 list_for_each_entry(svsk, &serv->sv_permsocks, sk_xprt.xpt_list) in svc_sock_update_bufs()
1353 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_sock_update_bufs()
1410 test_bit(XPT_LISTENER, &svsk->sk_xprt.xpt_flags), in svc_setup_socket()
1411 test_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags)); in svc_setup_socket()
1476 svc_xprt_set_local(&svsk->sk_xprt, sin, salen); in svc_addsock()
1477 svc_add_new_perm_xprt(serv, &svsk->sk_xprt); in svc_addsock()
1564 svc_xprt_set_local(&svsk->sk_xprt, newsin, newlen); in svc_create_socket()
1578 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_detach()
1597 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sock_detach()
1614 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_free()
1647 xprt = &svsk->sk_xprt; in svc_bc_create_socket()
1649 set_bit(XPT_CONG_CTRL, &svsk->sk_xprt.xpt_flags); in svc_bc_create_socket()
1662 kfree(container_of(xprt, struct svc_sock, sk_xprt)); in svc_bc_sock_free()