Lines Matching refs:xprt
350 static int svc_tcp_has_wspace(struct svc_xprt *xprt) in svc_tcp_has_wspace() argument
352 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_has_wspace()
354 if (test_bit(XPT_LISTENER, &xprt->xpt_flags)) in svc_tcp_has_wspace()
359 static void svc_tcp_kill_temp_xprt(struct svc_xprt *xprt) in svc_tcp_kill_temp_xprt() argument
361 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_kill_temp_xprt()
553 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_udp_sendto() local
554 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_sendto()
574 mutex_lock(&xprt->xpt_mutex); in svc_udp_sendto()
576 if (svc_xprt_is_dead(xprt)) in svc_udp_sendto()
586 trace_svcsock_udp_send(xprt, err); in svc_udp_sendto()
588 mutex_unlock(&xprt->xpt_mutex); in svc_udp_sendto()
594 mutex_unlock(&xprt->xpt_mutex); in svc_udp_sendto()
598 static int svc_udp_has_wspace(struct svc_xprt *xprt) in svc_udp_has_wspace() argument
600 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_udp_has_wspace()
601 struct svc_serv *serv = xprt->xpt_server; in svc_udp_has_wspace()
616 static struct svc_xprt *svc_udp_accept(struct svc_xprt *xprt) in svc_udp_accept() argument
622 static void svc_udp_kill_temp_xprt(struct svc_xprt *xprt) in svc_udp_kill_temp_xprt() argument
741 static struct svc_xprt *svc_tcp_accept(struct svc_xprt *xprt) in svc_tcp_accept() argument
743 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_accept()
764 trace_svcsock_accept_err(xprt, serv->sv_name, err); in svc_tcp_accept()
771 trace_svcsock_getpeername_err(xprt, serv->sv_name, err); in svc_tcp_accept()
1161 struct svc_xprt *xprt = rqstp->rq_xprt; in svc_tcp_sendto() local
1162 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sendto()
1174 mutex_lock(&xprt->xpt_mutex); in svc_tcp_sendto()
1175 if (svc_xprt_is_dead(xprt)) in svc_tcp_sendto()
1179 trace_svcsock_tcp_send(xprt, err < 0 ? (long)err : sent); in svc_tcp_sendto()
1182 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1186 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1190 xprt->xpt_server->sv_name, in svc_tcp_sendto()
1193 set_bit(XPT_CLOSE, &xprt->xpt_flags); in svc_tcp_sendto()
1194 svc_xprt_enqueue(xprt); in svc_tcp_sendto()
1195 mutex_unlock(&xprt->xpt_mutex); in svc_tcp_sendto()
1496 static void svc_sock_detach(struct svc_xprt *xprt) in svc_sock_detach() argument
1498 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_detach()
1513 static void svc_tcp_sock_detach(struct svc_xprt *xprt) in svc_tcp_sock_detach() argument
1515 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_tcp_sock_detach()
1517 svc_sock_detach(xprt); in svc_tcp_sock_detach()
1519 if (!test_bit(XPT_LISTENER, &xprt->xpt_flags)) { in svc_tcp_sock_detach()
1528 static void svc_sock_free(struct svc_xprt *xprt) in svc_sock_free() argument
1530 struct svc_sock *svsk = container_of(xprt, struct svc_sock, sk_xprt); in svc_sock_free()