Lines Matching refs:sk_xprt
148 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_set_cmsg_data()
247 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_read_msg()
254 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_read_msg()
274 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_read_msg()
284 unsigned int max_mesg = svsk->sk_xprt.xpt_server->sv_max_mesg; in svc_sock_setbufsize()
317 trace_svcsock_data_ready(&svsk->sk_xprt, 0); in svc_data_ready()
318 if (!test_and_set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags)) in svc_data_ready()
319 svc_xprt_enqueue(&svsk->sk_xprt); in svc_data_ready()
333 trace_svcsock_write_space(&svsk->sk_xprt, 0); in svc_write_space()
335 svc_xprt_enqueue(&svsk->sk_xprt); in svc_write_space()
341 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_has_wspace()
350 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_kill_temp_xprt()
423 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom()
424 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_udp_recvfrom()
440 if (test_and_clear_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags)) in svc_udp_recvfrom()
451 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
468 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); /* there may be more data... */ in svc_udp_recvfrom()
472 trace_svcsock_udp_recv(&svsk->sk_xprt, len); in svc_udp_recvfrom()
518 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
520 trace_svcsock_udp_recv_err(&svsk->sk_xprt, err); in svc_udp_recvfrom()
547 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_sendto()
596 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_has_wspace()
605 required = atomic_read(&svsk->sk_xprt.xpt_reserved) + serv->sv_max_mesg; in svc_udp_has_wspace()
654 &svsk->sk_xprt, serv); in svc_udp_init()
655 clear_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
666 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
667 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
710 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_listen_data_ready()
711 svc_xprt_enqueue(&svsk->sk_xprt); in svc_tcp_listen_data_ready()
727 trace_svcsock_tcp_state(&svsk->sk_xprt, svsk->sk_sock); in svc_tcp_state_change()
729 svc_xprt_deferred_close(&svsk->sk_xprt); in svc_tcp_state_change()
738 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_accept()
741 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_accept()
750 clear_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
762 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
785 svc_xprt_set_remote(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
790 svc_xprt_set_local(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
793 set_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
795 clear_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
799 return &newsvsk->sk_xprt; in svc_tcp_accept()
888 trace_svcsock_marker(&svsk->sk_xprt, svsk->sk_marker); in svc_tcp_read_marker()
890 svsk->sk_xprt.xpt_server->sv_max_mesg) in svc_tcp_read_marker()
897 __func__, svsk->sk_xprt.xpt_server->sv_name, in svc_tcp_read_marker()
899 svc_xprt_deferred_close(&svsk->sk_xprt); in svc_tcp_read_marker()
906 struct rpc_xprt *bc_xprt = svsk->sk_xprt.xpt_bc_xprt; in receive_cb_reply()
977 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_recvfrom()
978 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_recvfrom()
984 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_recvfrom()
993 trace_svcsock_tcp_recv(&svsk->sk_xprt, len); in svc_tcp_recvfrom()
1012 if (test_bit(XPT_LOCAL, &svsk->sk_xprt.xpt_flags)) in svc_tcp_recvfrom()
1029 svc_xprt_copy_addrs(rqstp, &svsk->sk_xprt); in svc_tcp_recvfrom()
1044 trace_svcsock_tcp_recv_short(&svsk->sk_xprt, in svc_tcp_recvfrom()
1051 trace_svcsock_tcp_recv_eagain(&svsk->sk_xprt, 0); in svc_tcp_recvfrom()
1056 trace_svcsock_tcp_recv_err(&svsk->sk_xprt, len); in svc_tcp_recvfrom()
1057 svc_xprt_deferred_close(&svsk->sk_xprt); in svc_tcp_recvfrom()
1158 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sendto()
1243 &svsk->sk_xprt, serv); in svc_tcp_init()
1244 set_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1245 set_bit(XPT_CONG_CTRL, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1247 strcpy(svsk->sk_xprt.xpt_remotebuf, "listener"); in svc_tcp_init()
1248 set_bit(XPT_LISTENER, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1250 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1263 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1269 svc_xprt_deferred_close(&svsk->sk_xprt); in svc_tcp_init()
1283 list_for_each_entry(svsk, &serv->sv_permsocks, sk_xprt.xpt_list) in svc_sock_update_bufs()
1284 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_sock_update_bufs()
1402 svc_xprt_set_local(&svsk->sk_xprt, sin, salen); in svc_addsock()
1403 svsk->sk_xprt.xpt_cred = get_cred(cred); in svc_addsock()
1404 svc_add_new_perm_xprt(serv, &svsk->sk_xprt); in svc_addsock()
1482 svc_xprt_set_local(&svsk->sk_xprt, newsin, newlen); in svc_create_socket()
1495 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_detach()
1512 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sock_detach()
1527 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_free()