mirrors/haproxy
1
0
Fork 0
mirror of https://git.haproxy.org/git/haproxy.git/ synced 2026-03-14 03:22:06 +01:00
Code Issues Projects Releases Wiki Activity

MINOR: filters: Use filter API as far as poissible to break loops on filters

Browse Source 
When the filters API was refactored to improve loops on filters, some places
were not updated (or not fully updated). Some loops were not relying on
resume_filter_list_break() while it was possible. So let's do so with this
patch.
This commit is contained in:
Christopher Faulet 2026-03-04 09:05:14 +01:00
parent 9f1e9ee0ed
commit 3eadf887f7
1 changed files with 3 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
src/filters.c
View File

@ -741,8 +741,7 @@ flt_http_payload(struct stream *s, struct http_msg *msg, unsigned int len)
filter->calls++;
ret = FLT_OPS(filter)->http_payload(s, filter, msg, out + offset, data - offset);
if (ret < 0) {
s->last_entity.type = STRM_ENTITY_FILTER;
s->last_entity.ptr = filter;
resume_filter_list_break(s, msg->chn, filter, ret);
goto end;
}
data = ret + *flt_off - *strm_off;
@ -888,8 +887,7 @@ flt_post_analyze(struct stream *s, struct channel *chn, unsigned int an_bit)
filter->calls++;
ret = FLT_OPS(filter)->channel_post_analyze(s, filter, chn, an_bit);
if (ret < 0) {
s->last_entity.type = STRM_ENTITY_FILTER;
s->last_entity.ptr = filter;
resume_filter_list_break(s, chn, filter, ret);
break;
}
filter->post_analyzers &= ~an_bit;
@ -1053,8 +1051,7 @@ flt_tcp_payload(struct stream *s, struct channel *chn, unsigned int len)
filter->calls++;
ret = FLT_OPS(filter)->tcp_payload(s, filter, chn, out + offset, data - offset);
if (ret < 0) {
s->last_entity.type = STRM_ENTITY_FILTER;
s->last_entity.ptr = filter;
resume_filter_list_break(s, chn, filter, ret);
goto end;
}
data = ret + *flt_off - *strm_off;