diff --git a/include/haproxy/conn_stream.h b/include/haproxy/conn_stream.h index 5bfffd9c2..3faaebc00 100644 --- a/include/haproxy/conn_stream.h +++ b/include/haproxy/conn_stream.h @@ -411,10 +411,4 @@ static inline void cs_stop_get(struct stconn *cs) sc_ep_clr(cs, SE_FL_WANT_GET); } -/* Report that a stream connector won't get any more data from the output buffer */ -static inline void cs_done_get(struct stconn *cs) -{ - sc_ep_clr(cs, SE_FL_WANT_GET | SE_FL_WAIT_DATA); -} - #endif /* _HAPROXY_CONN_STREAM_H */ diff --git a/src/conn_stream.c b/src/conn_stream.c index e3c206680..3d68625ec 100644 --- a/src/conn_stream.c +++ b/src/conn_stream.c @@ -547,7 +547,6 @@ static void sc_app_shutw(struct stconn *cs) return; oc->flags |= CF_SHUTW; oc->wex = TICK_ETERNITY; - cs_done_get(cs); if (tick_isset(cs->hcto)) { ic->rto = cs->hcto; @@ -691,7 +690,6 @@ static void sc_app_shutw_conn(struct stconn *cs) return; oc->flags |= CF_SHUTW; oc->wex = TICK_ETERNITY; - cs_done_get(cs); if (tick_isset(cs->hcto)) { ic->rto = cs->hcto; @@ -919,7 +917,6 @@ static void sc_app_shutw_applet(struct stconn *cs) return; oc->flags |= CF_SHUTW; oc->wex = TICK_ETERNITY; - cs_done_get(cs); if (tick_isset(cs->hcto)) { ic->rto = cs->hcto; @@ -1274,8 +1271,6 @@ static void sc_conn_read0(struct stconn *cs) oc->flags |= CF_SHUTW; oc->wex = TICK_ETERNITY; - cs_done_get(cs); - cs->state = SC_ST_DIS; __sc_strm(cs)->conn_exp = TICK_ETERNITY; return;