diff --git a/src/mux_fcgi.c b/src/mux_fcgi.c index 6a7a13f92..7254add05 100644 --- a/src/mux_fcgi.c +++ b/src/mux_fcgi.c @@ -3712,7 +3712,6 @@ static int fcgi_subscribe(struct conn_stream *cs, int event_type, struct wait_ev struct fcgi_conn *fconn = fstrm->fconn; BUG_ON(event_type & ~(SUB_RETRY_SEND|SUB_RETRY_RECV)); - BUG_ON(fstrm->subs && fstrm->subs->events & event_type); BUG_ON(fstrm->subs && fstrm->subs != es); es->events |= event_type; diff --git a/src/mux_h1.c b/src/mux_h1.c index a07654b4d..2e2dbf943 100644 --- a/src/mux_h1.c +++ b/src/mux_h1.c @@ -2587,7 +2587,6 @@ static int h1_subscribe(struct conn_stream *cs, int event_type, struct wait_even return -1; BUG_ON(event_type & ~(SUB_RETRY_SEND|SUB_RETRY_RECV)); - BUG_ON(h1s->subs && h1s->subs->events & event_type); BUG_ON(h1s->subs && h1s->subs != es); es->events |= event_type; diff --git a/src/mux_h2.c b/src/mux_h2.c index 478f3c4fc..b8728970b 100644 --- a/src/mux_h2.c +++ b/src/mux_h2.c @@ -5611,7 +5611,6 @@ static int h2_subscribe(struct conn_stream *cs, int event_type, struct wait_even TRACE_ENTER(H2_EV_STRM_SEND|H2_EV_STRM_RECV, h2c->conn, h2s); BUG_ON(event_type & ~(SUB_RETRY_SEND|SUB_RETRY_RECV)); - BUG_ON(h2s->subs && h2s->subs->events & event_type); BUG_ON(h2s->subs && h2s->subs != es); es->events |= event_type; diff --git a/src/ssl_sock.c b/src/ssl_sock.c index efb6b0e0e..2688117e5 100644 --- a/src/ssl_sock.c +++ b/src/ssl_sock.c @@ -6473,7 +6473,6 @@ static int ssl_subscribe(struct connection *conn, void *xprt_ctx, int event_type return -1; BUG_ON(event_type & ~(SUB_RETRY_SEND|SUB_RETRY_RECV)); - BUG_ON(ctx->subs && ctx->subs->events & event_type); BUG_ON(ctx->subs && ctx->subs != es); ctx->subs = es; diff --git a/src/xprt_handshake.c b/src/xprt_handshake.c index 89446af37..bfbd52237 100644 --- a/src/xprt_handshake.c +++ b/src/xprt_handshake.c @@ -203,7 +203,6 @@ static int xprt_handshake_subscribe(struct connection *conn, void *xprt_ctx, int struct xprt_handshake_ctx *ctx = xprt_ctx; BUG_ON(event_type & ~(SUB_RETRY_SEND|SUB_RETRY_RECV)); - BUG_ON(ctx->subs && ctx->subs->events & event_type); BUG_ON(ctx->subs && ctx->subs != es); ctx->subs = es;