diff --git a/src/mux_h2.c b/src/mux_h2.c index 65cefa4bd..39770e83d 100644 --- a/src/mux_h2.c +++ b/src/mux_h2.c @@ -2989,12 +2989,8 @@ static int h2_process(struct h2c *h2c) h2_release_mbuf(h2c); if (h2c->task) { - if (eb_is_empty(&h2c->streams_by_id) || br_data(h2c->mbuf)) { - h2c->task->expire = tick_add(now_ms, h2c->last_sid < 0 ? h2c->timeout : h2c->shut_timeout); - task_queue(h2c->task); - } - else - h2c->task->expire = TICK_ETERNITY; + h2c->task->expire = tick_add(now_ms, h2c->last_sid < 0 ? h2c->timeout : h2c->shut_timeout); + task_queue(h2c->task); } h2_send(h2c); @@ -3244,12 +3240,8 @@ static void h2_detach(struct conn_stream *cs) h2_release(h2c); } else if (h2c->task) { - if (eb_is_empty(&h2c->streams_by_id) || br_data(h2c->mbuf)) { - h2c->task->expire = tick_add(now_ms, h2c->last_sid < 0 ? h2c->timeout : h2c->shut_timeout); - task_queue(h2c->task); - } - else - h2c->task->expire = TICK_ETERNITY; + h2c->task->expire = tick_add(now_ms, h2c->last_sid < 0 ? h2c->timeout : h2c->shut_timeout); + task_queue(h2c->task); } }