Lines Matching refs:xprt
131 static void svc_tcp_release_ctxt(struct svc_xprt *xprt, void *ctxt) in svc_tcp_release_ctxt() argument
141 static void svc_udp_release_ctxt(struct svc_xprt *xprt, void *ctxt) in svc_udp_release_ctxt() argument
399 static int svc_tcp_has_wspace(struct svc_xprt *xprt) in svc_tcp_has_wspace() argument
401 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_has_wspace()
403 if (test_bit(XPT_LISTENER, &xprt->xpt_flags)) in svc_tcp_has_wspace()
408 static void svc_tcp_kill_temp_xprt(struct svc_xprt *xprt) in svc_tcp_kill_temp_xprt() argument
410 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_kill_temp_xprt()
428 struct svc_xprt *xprt = data; in svc_tcp_handshake_done() local
429 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_handshake_done()
433 set_bit(XPT_PEER_AUTH, &xprt->xpt_flags); in svc_tcp_handshake_done()
434 set_bit(XPT_TLS_SESSION, &xprt->xpt_flags); in svc_tcp_handshake_done()
436 clear_bit(XPT_HANDSHAKE, &xprt->xpt_flags); in svc_tcp_handshake_done()
445 static void svc_tcp_handshake(struct svc_xprt *xprt) in svc_tcp_handshake() argument
447 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_handshake()
452 .ta_data = xprt, in svc_tcp_handshake()
456 trace_svc_tls_upcall(xprt); in svc_tcp_handshake()
458 clear_bit(XPT_TLS_SESSION, &xprt->xpt_flags); in svc_tcp_handshake()
463 trace_svc_tls_not_started(xprt); in svc_tcp_handshake()
471 trace_svc_tls_timed_out(xprt); in svc_tcp_handshake()
476 if (!test_bit(XPT_TLS_SESSION, &xprt->xpt_flags)) { in svc_tcp_handshake()
477 trace_svc_tls_unavailable(xprt); in svc_tcp_handshake()
485 set_bit(XPT_DATA, &xprt->xpt_flags); in svc_tcp_handshake()
486 svc_xprt_enqueue(xprt); in svc_tcp_handshake()
490 set_bit(XPT_CLOSE, &xprt->xpt_flags); in svc_tcp_handshake()
492 clear_bit(XPT_HANDSHAKE, &xprt->xpt_flags); in svc_tcp_handshake()
493 set_bit(XPT_DATA, &xprt->xpt_flags); in svc_tcp_handshake()
494 svc_xprt_enqueue(xprt); in svc_tcp_handshake()
688 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_udp_sendto() local
689 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_sendto()
706 svc_udp_release_ctxt(xprt, rqstp->rq_xprt_ctxt); in svc_udp_sendto()
711 mutex_lock(&xprt->xpt_mutex); in svc_udp_sendto()
713 if (svc_xprt_is_dead(xprt)) in svc_udp_sendto()
729 trace_svcsock_udp_send(xprt, err); in svc_udp_sendto()
731 mutex_unlock(&xprt->xpt_mutex); in svc_udp_sendto()
735 mutex_unlock(&xprt->xpt_mutex); in svc_udp_sendto()
739 static int svc_udp_has_wspace(struct svc_xprt *xprt) in svc_udp_has_wspace() argument
741 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_has_wspace()
742 struct svc_serv *serv = xprt->xpt_server; in svc_udp_has_wspace()
757 static struct svc_xprt *svc_udp_accept(struct svc_xprt *xprt) in svc_udp_accept() argument
763 static void svc_udp_kill_temp_xprt(struct svc_xprt *xprt) in svc_udp_kill_temp_xprt() argument
880 static struct svc_xprt *svc_tcp_accept(struct svc_xprt *xprt) in svc_tcp_accept() argument
882 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_accept()
898 trace_svcsock_accept_err(xprt, serv->sv_name, err); in svc_tcp_accept()
908 trace_svcsock_getpeername_err(xprt, serv->sv_name, err); in svc_tcp_accept()
1256 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_tcp_sendto() local
1257 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sendto()
1264 svc_tcp_release_ctxt(xprt, rqstp->rq_xprt_ctxt); in svc_tcp_sendto()
1267 mutex_lock(&xprt->xpt_mutex); in svc_tcp_sendto()
1268 if (svc_xprt_is_dead(xprt)) in svc_tcp_sendto()
1271 trace_svcsock_tcp_send(xprt, err < 0 ? (long)err : sent); in svc_tcp_sendto()
1274 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1278 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1282 xprt->xpt_server->sv_name, in svc_tcp_sendto()
1285 svc_xprt_deferred_close(xprt); in svc_tcp_sendto()
1286 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1579 static void svc_sock_detach(struct svc_xprt *xprt) in svc_sock_detach() argument
1581 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_detach()
1596 static void svc_tcp_sock_detach(struct svc_xprt *xprt) in svc_tcp_sock_detach() argument
1598 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sock_detach()
1602 svc_sock_detach(xprt); in svc_tcp_sock_detach()
1604 if (!test_bit(XPT_LISTENER, &xprt->xpt_flags)) { in svc_tcp_sock_detach()
1613 static void svc_sock_free(struct svc_xprt *xprt) in svc_sock_free() argument
1615 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_free()