istream/brotli: offload to worker thread

CM4all · Jan 14, 2025 · 47da976 · 47da976
1 parent 7b67301
commit 47da976
Show file tree

Hide file tree

Showing 5 changed files with 82 additions and 286 deletions.
diff --git a/debian/changelog b/debian/changelog
@@ -10,6 +10,7 @@ cm4all-beng-proxy (19.1) unstable; urgency=low
   * {http,nghttp2}/server: use optimized per-request memory allocator
   * access_log: send multiple log datagrams with sendmmsg()
   * translation/cache: reduce CPU and memory overhead
+  * brotli: offload to worker thread
 
  --   
 

diff --git a/src/bp/Response.cxx b/src/bp/Response.cxx
@@ -42,6 +42,7 @@
 #include "translation/Transformation.hxx"
 #include "translation/Service.hxx"
 #include "http/Address.hxx"
+#include "thread/Pool.hxx"
 #include "co/Task.hxx"
 #include "uri/Relocate.hxx"
 #include "uri/Verify.hxx"
@@ -205,7 +206,9 @@ Request::ApplyAutoCompress(HttpHeaders &response_headers,
 			      resource_tag,
 			      response_headers, response_body, "br",
 			      [this, &response_headers](auto &&i){
-				      return NewBrotliEncoderIstream(pool, std::move(i),
+				      return NewBrotliEncoderIstream(pool,
+								     thread_pool_get_queue(instance.event_loop),
+								     std::move(i),
 								     {.text_mode = IsTextMimeType(response_headers)});
 			      }))
 		return;