commit 386346f5eb34ae251111f4e8be3cda06d4626b57
author Willy Tarreau <w@1wt.eu> Tue May 10 08:46:07 2022 +0200
committer Willy Tarreau <w@1wt.eu> Fri May 13 14:27:57 2022 +0200
tree 66877f3a721002a586ef1a7436796c393c6621b0
parent b112b1d02a6bdfc0de10e22e129d7daa65624bc4

MINOR: conn_stream: make cs_set_error() work on the endpoint instead

Wherever we need to report an error, we have an even easier access to
the endpoint than the conn_stream. Let's first adjust the API to use
the endpoint and rename the function accordingly to cs_ep_set_error().

include/haproxy/conn_stream.h

diff --git a/include/haproxy/conn_stream.h b/include/haproxy/conn_stream.h
index 2d5cc4f..ae2d9f0 100644
--- a/include/haproxy/conn_stream.h
+++ b/include/haproxy/conn_stream.h
@@ -205,13 +205,13 @@
 	cs_conn_shutr(cs, CO_SHR_DRAIN);
 }
 
-/* sets CS_EP_ERROR or CS_EP_ERR_PENDING on the cs */
-static inline void cs_set_error(struct conn_stream *cs)
+/* sets CS_EP_ERROR or CS_EP_ERR_PENDING on the endpoint */
+static inline void cs_ep_set_error(struct cs_endpoint *endp)
 {
-	if (cs->endp->flags & CS_EP_EOS)
-		cs->endp->flags |= CS_EP_ERROR;
+	if (endp->flags & CS_EP_EOS)
+		endp->flags |= CS_EP_ERROR;
 	else
-		cs->endp->flags |= CS_EP_ERR_PENDING;
+		endp->flags |= CS_EP_ERR_PENDING;
 }
 
 /* Retrieves any valid conn_stream from this connection, preferably the first

src/mux_fcgi.c

diff --git a/src/mux_fcgi.c b/src/mux_fcgi.c
index 087e42b..ce392c9 100644
--- a/src/mux_fcgi.c
+++ b/src/mux_fcgi.c
@@ -917,7 +917,7 @@
 			TRACE_STATE("switching to ERROR", FCGI_EV_FSTRM_ERR, fstrm->fconn->conn, fstrm);
 		}
 		if (fstrm->cs)
-			cs_set_error(fstrm->cs);
+			cs_ep_set_error(fstrm->cs->endp);
 	}
 }
 
@@ -4113,7 +4113,7 @@
 
 	if (fstrm->state == FCGI_SS_ERROR) {
 		TRACE_DEVEL("reporting error to the app-layer stream", FCGI_EV_STRM_SEND|FCGI_EV_FSTRM_ERR|FCGI_EV_STRM_ERR, fconn->conn, fstrm);
-		cs_set_error(cs);
+		cs_ep_set_error(cs->endp);
 		if (!(fstrm->flags & FCGI_SF_BEGIN_SENT) || fcgi_strm_send_abort(fconn, fstrm))
 			fcgi_strm_close(fstrm);
 	}

src/mux_h2.c

diff --git a/src/mux_h2.c b/src/mux_h2.c
index b13ac8a..5e56177 100644
--- a/src/mux_h2.c
+++ b/src/mux_h2.c
@@ -1274,7 +1274,7 @@
 		if (h2s->st < H2_SS_ERROR)
 			h2s->st = H2_SS_ERROR;
 		if (h2s->cs)
-			cs_set_error(h2s->cs);
+			cs_ep_set_error(h2s->endp);
 	}
 }
 
@@ -2749,7 +2749,7 @@
 	h2s_close(h2s);
 
 	if (h2s->cs) {
-		cs_set_error(h2s->cs);
+		cs_ep_set_error(h2s->endp);
 		h2s_alert(h2s);
 	}
 
@@ -6662,7 +6662,7 @@
 	/* RST are sent similarly to frame acks */
 	if (h2s->st == H2_SS_ERROR || h2s->flags & H2_SF_RST_RCVD) {
 		TRACE_DEVEL("reporting RST/error to the app-layer stream", H2_EV_H2S_SEND|H2_EV_H2S_ERR|H2_EV_STRM_ERR, h2s->h2c->conn, h2s);
-		cs_set_error(cs);
+		cs_ep_set_error(cs->endp);
 		if (h2s_send_rst_stream(h2s->h2c, h2s) > 0)
 			h2s_close(h2s);
 	}