Lines Matching refs:sk_xprt

159 		container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt);  in svc_set_cmsg_data()
305 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_read_msg()
312 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_read_msg()
332 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_read_msg()
342 unsigned int max_mesg = svsk->sk_xprt.xpt_server->sv_max_mesg; in svc_sock_setbufsize()
375 trace_svcsock_data_ready(&svsk->sk_xprt, 0); in svc_data_ready()
376 if (test_bit(XPT_HANDSHAKE, &svsk->sk_xprt.xpt_flags)) in svc_data_ready()
378 if (!test_and_set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags)) in svc_data_ready()
379 svc_xprt_enqueue(&svsk->sk_xprt); in svc_data_ready()
393 trace_svcsock_write_space(&svsk->sk_xprt, 0); in svc_write_space()
395 svc_xprt_enqueue(&svsk->sk_xprt); in svc_write_space()
401 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_has_wspace()
410 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_kill_temp_xprt()
429 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_handshake_done()
447 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_handshake()
565 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_udp_recvfrom()
566 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_udp_recvfrom()
582 if (test_and_clear_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags)) in svc_udp_recvfrom()
593 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
610 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); /* there may be more data... */ in svc_udp_recvfrom()
614 trace_svcsock_udp_recv(&svsk->sk_xprt, len); in svc_udp_recvfrom()
660 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_recvfrom()
662 trace_svcsock_udp_recv_err(&svsk->sk_xprt, err); in svc_udp_recvfrom()
689 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_sendto()
741 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_has_wspace()
750 required = atomic_read(&svsk->sk_xprt.xpt_reserved) + serv->sv_max_mesg; in svc_udp_has_wspace()
799 &svsk->sk_xprt, serv); in svc_udp_init()
800 clear_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
811 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
812 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_udp_init()
855 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_listen_data_ready()
856 svc_xprt_enqueue(&svsk->sk_xprt); in svc_tcp_listen_data_ready()
871 trace_svcsock_tcp_state(&svsk->sk_xprt, svsk->sk_sock); in svc_tcp_state_change()
873 svc_xprt_deferred_close(&svsk->sk_xprt); in svc_tcp_state_change()
882 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_accept()
885 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_accept()
894 clear_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
904 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_accept()
927 svc_xprt_set_remote(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
932 svc_xprt_set_local(&newsvsk->sk_xprt, sin, slen); in svc_tcp_accept()
935 set_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
937 clear_bit(XPT_LOCAL, &newsvsk->sk_xprt.xpt_flags); in svc_tcp_accept()
941 return &newsvsk->sk_xprt; in svc_tcp_accept()
1030 trace_svcsock_marker(&svsk->sk_xprt, svsk->sk_marker); in svc_tcp_read_marker()
1032 svsk->sk_xprt.xpt_server->sv_max_mesg) in svc_tcp_read_marker()
1039 __func__, svsk->sk_xprt.xpt_server->sv_name, in svc_tcp_read_marker()
1041 svc_xprt_deferred_close(&svsk->sk_xprt); in svc_tcp_read_marker()
1048 struct rpc_xprt *bc_xprt = svsk->sk_xprt.xpt_bc_xprt; in receive_cb_reply()
1122 container_of(rqstp->rq_xprt, struct svc_sock, sk_xprt); in svc_tcp_recvfrom()
1123 struct svc_serv *serv = svsk->sk_xprt.xpt_server; in svc_tcp_recvfrom()
1129 clear_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_recvfrom()
1138 trace_svcsock_tcp_recv(&svsk->sk_xprt, len); in svc_tcp_recvfrom()
1157 if (test_bit(XPT_LOCAL, &svsk->sk_xprt.xpt_flags)) in svc_tcp_recvfrom()
1174 svc_xprt_copy_addrs(rqstp, &svsk->sk_xprt); in svc_tcp_recvfrom()
1195 trace_svcsock_tcp_recv_short(&svsk->sk_xprt, in svc_tcp_recvfrom()
1203 trace_svcsock_tcp_recv_eagain(&svsk->sk_xprt, 0); in svc_tcp_recvfrom()
1208 trace_svcsock_tcp_recv_err(&svsk->sk_xprt, len); in svc_tcp_recvfrom()
1209 svc_xprt_deferred_close(&svsk->sk_xprt); in svc_tcp_recvfrom()
1267 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sendto()
1347 &svsk->sk_xprt, serv); in svc_tcp_init()
1348 set_bit(XPT_CACHE_AUTH, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1349 set_bit(XPT_CONG_CTRL, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1351 strcpy(svsk->sk_xprt.xpt_remotebuf, "listener"); in svc_tcp_init()
1352 set_bit(XPT_LISTENER, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1354 set_bit(XPT_CONN, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1367 set_bit(XPT_DATA, &svsk->sk_xprt.xpt_flags); in svc_tcp_init()
1373 svc_xprt_deferred_close(&svsk->sk_xprt); in svc_tcp_init()
1387 list_for_each_entry(svsk, &serv->sv_permsocks, sk_xprt.xpt_list) in svc_sock_update_bufs()
1388 set_bit(XPT_CHNGBUF, &svsk->sk_xprt.xpt_flags); in svc_sock_update_bufs()
1494 svc_xprt_set_local(&svsk->sk_xprt, sin, salen); in svc_addsock()
1495 svsk->sk_xprt.xpt_cred = get_cred(cred); in svc_addsock()
1496 svc_add_new_perm_xprt(serv, &svsk->sk_xprt); in svc_addsock()
1578 svc_xprt_set_local(&svsk->sk_xprt, newsin, newlen); in svc_create_socket()
1591 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_detach()
1608 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sock_detach()
1625 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_free()