diff --git a/src/flt_spoe.c b/src/flt_spoe.c index 39a56b11e..48bce2507 100644 --- a/src/flt_spoe.c +++ b/src/flt_spoe.c @@ -1114,7 +1114,7 @@ static int spoe_process_event(struct stream *s, struct spoe_context *ctx, } else if (ret == 0) { if ((s->scf->flags & SC_FL_ERROR) || - ((s->scf->flags & (SC_FL_EOS|SC_FL_ABRT_DONE)) && proxy_abrt_close_def(s->be, 1))) { + ((s->scf->flags & SC_FL_EOS) && proxy_abrt_close_def(s->be, 1))) { ctx->status_code = SPOE_CTX_ERR_INTERRUPT; spoe_stop_processing(agent, ctx); spoe_handle_processing_error(s, agent, ctx, dir); diff --git a/src/http_ana.c b/src/http_ana.c index 80726e9f6..8a00d5b79 100644 --- a/src/http_ana.c +++ b/src/http_ana.c @@ -2828,8 +2828,7 @@ static enum rule_result http_req_get_intercept_rule(struct proxy *px, struct lis int act_opts = 0; if ((s->scf->flags & SC_FL_ERROR) || - ((s->scf->flags & (SC_FL_EOS|SC_FL_ABRT_DONE)) && - proxy_abrt_close_def(px, 1))) + ((s->scf->flags & SC_FL_EOS) && proxy_abrt_close_def(px, 1))) act_opts |= ACT_OPT_FINAL | ACT_OPT_FINAL_EARLY; /* If "the current_rule_list" match the executed rule list, we are in @@ -3020,8 +3019,7 @@ static enum rule_result http_res_get_intercept_rule(struct proxy *px, struct lis if (final) act_opts |= ACT_OPT_FINAL; if ((s->scf->flags & SC_FL_ERROR) || - ((s->scf->flags & (SC_FL_EOS|SC_FL_ABRT_DONE)) && - proxy_abrt_close_def(px, 1))) + ((s->scf->flags & SC_FL_EOS) && proxy_abrt_close_def(px, 1))) act_opts |= ACT_OPT_FINAL | ACT_OPT_FINAL_EARLY; /* If "the current_rule_list" match the executed rule list, we are in @@ -4356,8 +4354,7 @@ enum rule_result http_wait_for_msg_body(struct stream *s, struct channel *chn, /* we get here if we need to wait for more data */ if ((s->scf->flags & SC_FL_ERROR) || - ((s->scf->flags & (SC_FL_EOS|SC_FL_ABRT_DONE)) && - proxy_abrt_close_def(s->be, 1))) + ((s->scf->flags & SC_FL_EOS) && proxy_abrt_close_def(s->be, 1))) ret = HTTP_RULE_RES_CONT; else if (!(chn_prod(chn)->flags & (SC_FL_ERROR|SC_FL_EOS|SC_FL_ABRT_DONE))) { if (!tick_isset(chn->analyse_exp))