Lines Matching refs:sk_xprt

124 			container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt);  in svc_tcp_release_rqst()
156 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
255 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_read_msg()
264 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_read_msg()
287 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_read_msg()
297 unsigned int max_mesg = svsk->sk_xprt.xpt_server->sv_max_mesg; in svc_sock_setbufsize()
328 trace_svcsock_data_ready(&svsk->sk_xprt, 0); in svc_data_ready()
329 if (!test_and_set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags)) in svc_data_ready()
330 svc_xprt_enqueue(&svsk->sk_xprt); in svc_data_ready()
344 trace_svcsock_write_space(&svsk->sk_xprt, 0); in svc_write_space()
346 svc_xprt_enqueue(&svsk->sk_xprt); in svc_write_space()
352 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_has_wspace()
361 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_kill_temp_xprt()
434 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom()
435 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_udp_recvfrom()
451 if (test_and_clear_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags)) in svc_udp_recvfrom()
462 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
479 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); /* there may be more data... */ in svc_udp_recvfrom()
483 trace_svcsock_udp_recv(&svsk->sk_xprt, len); in svc_udp_recvfrom()
527 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
529 trace_svcsock_udp_recv_err(&svsk->sk_xprt, err); in svc_udp_recvfrom()
554 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_sendto()
600 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_has_wspace()
609 required = atomic_read(&svsk->sk_xprt.xpt_reserved) + serv->sv_max_mesg; in svc_udp_has_wspace()
659 &svsk->sk_xprt, serv); in svc_udp_init()
660 clear_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
671 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
672 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
713 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_listen_data_ready()
714 svc_xprt_enqueue(&svsk->sk_xprt); in svc_tcp_listen_data_ready()
730 trace_svcsock_tcp_state(&svsk->sk_xprt, svsk->sk_sock); in svc_tcp_state_change()
732 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_state_change()
733 svc_xprt_enqueue(&svsk->sk_xprt); in svc_tcp_state_change()
743 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_accept()
746 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_accept()
755 clear_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
767 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
790 svc_xprt_set_remote(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
795 svc_xprt_set_local(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
798 set_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
800 clear_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
804 return &newsvsk->sk_xprt; in svc_tcp_accept()
893 trace_svcsock_marker(&svsk->sk_xprt, svsk->sk_marker); in svc_tcp_read_marker()
895 svsk->sk_xprt.xpt_server->sv_max_mesg) in svc_tcp_read_marker()
902 __func__, svsk->sk_xprt.xpt_server->sv_name, in svc_tcp_read_marker()
904 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_read_marker()
911 struct rpc_xprt *bc_xprt = svsk->sk_xprt.xpt_bc_xprt; in receive_cb_reply()
982 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_recvfrom()
983 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_recvfrom()
989 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_recvfrom()
998 trace_svcsock_tcp_recv(&svsk->sk_xprt, len); in svc_tcp_recvfrom()
1017 if (test_bit(XPT_LOCAL, &svsk->sk_xprt.xpt_flags)) in svc_tcp_recvfrom()
1034 svc_xprt_copy_addrs(rqstp, &svsk->sk_xprt); in svc_tcp_recvfrom()
1047 trace_svcsock_tcp_recv_short(&svsk->sk_xprt, in svc_tcp_recvfrom()
1054 trace_svcsock_tcp_recv_eagain(&svsk->sk_xprt, 0); in svc_tcp_recvfrom()
1059 trace_svcsock_tcp_recv_err(&svsk->sk_xprt, len); in svc_tcp_recvfrom()
1060 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_recvfrom()
1164 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sendto()
1248 &svsk->sk_xprt, serv); in svc_tcp_init()
1249 set_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1250 set_bit(XPT_CONG_CTRL, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1252 strcpy(svsk->sk_xprt.xpt_remotebuf, "listener"); in svc_tcp_init()
1253 set_bit(XPT_LISTENER, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1255 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1268 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1274 set_bit(XPT_CLOSE, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1288 list_for_each_entry(svsk, &serv->sv_permsocks, sk_xprt.xpt_list) in svc_sock_update_bufs()
1289 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_sock_update_bufs()
1407 svc_xprt_set_local(&svsk->sk_xprt, sin, salen); in svc_addsock()
1408 svsk->sk_xprt.xpt_cred = get_cred(cred); in svc_addsock()
1409 svc_add_new_perm_xprt(serv, &svsk->sk_xprt); in svc_addsock()
1487 svc_xprt_set_local(&svsk->sk_xprt, newsin, newlen); in svc_create_socket()
1500 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_detach()
1517 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sock_detach()
1532 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_free()