Lines Matching refs:sk_xprt
126 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_release_skb()
144 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
237 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_sendto()
321 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_recvfrom()
329 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_recvfrom()
336 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_recvfrom()
413 test_bit(XPT_BUSY, &svsk->sk_xprt.xpt_flags)); in svc_udp_data_ready()
414 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_data_ready()
415 svc_xprt_enqueue(&svsk->sk_xprt); in svc_udp_data_ready()
431 svsk, sk, test_bit(XPT_BUSY, &svsk->sk_xprt.xpt_flags)); in svc_write_space()
432 svc_xprt_enqueue(&svsk->sk_xprt); in svc_write_space()
444 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_has_wspace()
445 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_has_wspace()
466 if (!svsk || svc_tcp_has_wspace(&svsk->sk_xprt)) in svc_tcp_write_space()
473 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_adjust_wspace()
540 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom()
541 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_udp_recvfrom()
557 if (test_and_clear_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags)) in svc_udp_recvfrom()
570 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
581 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
593 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); /* there may be more data... */ in svc_udp_recvfrom()
668 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_has_wspace()
677 required = atomic_read(&svsk->sk_xprt.xpt_reserved) + serv->sv_max_mesg; in svc_udp_has_wspace()
724 &svsk->sk_xprt, serv); in svc_udp_init()
725 clear_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
734 3 * svsk->sk_xprt.xpt_server->sv_max_mesg, in svc_udp_init()
735 3 * svsk->sk_xprt.xpt_server->sv_max_mesg); in svc_udp_init()
738 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
739 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
783 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_listen_data_ready()
784 svc_xprt_enqueue(&svsk->sk_xprt); in svc_tcp_listen_data_ready()
808 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_state_change()
809 svc_xprt_enqueue(&svsk->sk_xprt); in svc_tcp_state_change()
823 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_data_ready()
824 svc_xprt_enqueue(&svsk->sk_xprt); in svc_tcp_data_ready()
835 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_accept()
838 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_accept()
849 clear_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
860 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
890 svc_xprt_set_remote(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
896 svc_xprt_set_local(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
899 set_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
901 clear_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
905 return &newsvsk->sk_xprt; in svc_tcp_accept()
972 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_recv_record()
1006 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_recv_record()
1012 struct rpc_xprt *bc_xprt = svsk->sk_xprt.xpt_bc_xprt; in receive_cb_reply()
1085 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_recvfrom()
1086 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_recvfrom()
1095 svsk, test_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags), in svc_tcp_recvfrom()
1096 test_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags), in svc_tcp_recvfrom()
1097 test_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags)); in svc_tcp_recvfrom()
1148 if (test_bit(XPT_LOCAL, &svsk->sk_xprt.xpt_flags)) in svc_tcp_recvfrom()
1165 svc_xprt_copy_addrs(rqstp, &svsk->sk_xprt); in svc_tcp_recvfrom()
1178 svsk->sk_xprt.xpt_server->sv_name, -len); in svc_tcp_recvfrom()
1179 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_recvfrom()
1327 &svsk->sk_xprt, serv); in svc_tcp_init()
1328 set_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1331 set_bit(XPT_LISTENER, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1333 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1347 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1349 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1362 list_for_each_entry(svsk, &serv->sv_permsocks, sk_xprt.xpt_list) in svc_sock_update_bufs()
1363 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_sock_update_bufs()
1483 svc_xprt_set_local(&svsk->sk_xprt, sin, salen); in svc_addsock()
1484 svc_add_new_perm_xprt(serv, &svsk->sk_xprt); in svc_addsock()
1571 svc_xprt_set_local(&svsk->sk_xprt, newsin, newlen); in svc_create_socket()
1585 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_detach()
1606 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sock_detach()
1623 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_free()
1656 xprt = &svsk->sk_xprt; in svc_bc_create_socket()
1670 kfree(container_of(xprt, struct svc_sock, sk_xprt)); in svc_bc_sock_free()