MAJOR: filters/http: Rewrite the HTTP compression as a filter
HTTP compression has been rewritten to use the filter API. This is more a PoC
than other thing for now. It allocates memory to work. So, if only for that, it
should be rewritten.
In the mean time, the implementation has been refactored to allow its use with
other filters. However, there are limitations that should be respected:
- No filter placed after the compression one is allowed to change input data
(in 'http_data' callback).
- No filter placed before the compression one is allowed to change forwarded
data (in 'http_forward_data' callback).
For now, these limitations are informal, so you should be careful when you use
several filters.
About the configuration, 'compression' keywords are still supported and must be
used to configure the HTTP compression behavior. In absence of a 'filter' line
for the compression filter, it is added in the filter chain when the first
compression' line is parsed. This is an easy way to do when you do not use other
filters. But another filter exists, an error is reported so that the user must
explicitly declare the filter.
For example:
listen tst
...
compression algo gzip
compression offload
...
filter flt_1
filter compression
filter flt_2
...
diff --git a/src/proxy.c b/src/proxy.c
index 2014c73..f22c746 100644
--- a/src/proxy.c
+++ b/src/proxy.c
@@ -1130,8 +1130,6 @@
*/
int stream_set_backend(struct stream *s, struct proxy *be)
{
- struct filter *filter;
-
if (s->flags & SF_BE_ASSIGNED)
return 1;
s->be = be;
@@ -1140,19 +1138,8 @@
be->be_counters.conn_max = be->beconn;
proxy_inc_be_ctr(be);
- if (strm_fe(s) != be) {
- list_for_each_entry(filter, &be->filters, list) {
- struct filter *f = pool_alloc2(pool2_filter);
- if (!f)
- return 0; /* not enough memory */
- memset(f, 0, sizeof(*f));
- f->id = filter->id;
- f->ops = filter->ops;
- f->conf = filter->conf;
- f->is_backend_filter = 1;
- LIST_ADDQ(&s->strm_flt.filters, &f->list);
- }
- }
+ if (flt_set_stream_backend(s, be) < 0)
+ return 0;
/* assign new parameters to the stream from the new backend */
s->si[1].flags &= ~SI_FL_INDEP_STR;