jeans/supervisor
jeans/supervisor
1
0
Fork 0
mirror of https://github.com/home-assistant/supervisor.git synced 2025-07-19 15:16:33 +00:00
Code Issues Packages Projects Releases Wiki Activity

Add X-Accel-Buffering to disable buffers in proxies (#5544)

Browse Source
This commit is contained in:
Stefan Agner 2025-01-14 10:42:41 +01:00 committed by GitHub
parent b07236b544
commit bd156ebb53
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
3 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
supervisor/api/host.py
View File

@ -258,6 +258,7 @@ class APIHost(CoreSysAttributes):
if not headers_returned: if not headers_returned:
if cursor: if cursor:
response.headers["X-First-Cursor"] = cursor response.headers["X-First-Cursor"] = cursor
response.headers["X-Accel-Buffering"] = "no"
await response.prepare(request) await response.prepare(request)
headers_returned = True headers_returned = True
# When client closes the connection while reading busy logs, we # When client closes the connection while reading busy logs, we

1
supervisor/api/ingress.py
View File

@ -277,6 +277,7 @@ class APIIngress(CoreSysAttributes):
response.content_type = content_type response.content_type = content_type
try: try:
response.headers["X-Accel-Buffering"] = "no"
await response.prepare(request) await response.prepare(request)
async for data in result.content.iter_chunked(4096): async for data in result.content.iter_chunked(4096):
await response.write(data) await response.write(data)

1
supervisor/api/proxy.py
View File

@ -95,6 +95,7 @@ class APIProxy(CoreSysAttributes):
response = web.StreamResponse() response = web.StreamResponse()
response.content_type = request.headers.get(CONTENT_TYPE) response.content_type = request.headers.get(CONTENT_TYPE)
try: try:
response.headers["X-Accel-Buffering"] = "no"
await response.prepare(request) await response.prepare(request)
async for data in client.content: async for data in client.content:
await response.write(data) await response.write(data)