admin/Codex-Launcher---Any-AI-Porovider
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases 4 Wiki Activity

v2.2.1: add 180s upstream timeout to prevent hanging connections

Browse Source 
- All urlopen() calls now have timeout=180 to prevent infinite hangs
- Crof upstream can idle between SSE chunks, causing proxy to block forever
- Tested: kimi-k2.6 + mimo-v2.5-pro both stream completed successfully
This commit is contained in:
Roman
2026-05-20 14:04:11 +04:00
Unverified
parent 881f4f35d2
commit 60106955ab
2 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

BIN
codex-launcher_2.2.1_all.deb
View File

Binary file not shown.

6
src/translate-proxy.py
View File

@@ -1035,7 +1035,7 @@ class Handler(http.server.BaseHTTPRequestHandler):
if stream: if stream:
try: try:
upstream = urllib.request.urlopen(req) upstream = urllib.request.urlopen(req, timeout=180)
except urllib.error.HTTPError as e: except urllib.error.HTTPError as e:
err = e.read().decode() err = e.read().decode()
return self.send_json(e.code, {"error": {"type": "upstream_error", "message": err}}) return self.send_json(e.code, {"error": {"type": "upstream_error", "message": err}})
@@ -1064,7 +1064,7 @@ class Handler(http.server.BaseHTTPRequestHandler):
store_response(last_resp_id, body.get("input", ""), last_output) store_response(last_resp_id, body.get("input", ""), last_output)
else: else:
try: try:
upstream = urllib.request.urlopen(req) upstream = urllib.request.urlopen(req, timeout=180)
except urllib.error.HTTPError as e: except urllib.error.HTTPError as e:
err = e.read().decode() err = e.read().decode()
return self.send_json(e.code, {"error": {"type": "upstream_error", "message": err}}) return self.send_json(e.code, {"error": {"type": "upstream_error", "message": err}})
@@ -1081,7 +1081,7 @@ class Handler(http.server.BaseHTTPRequestHandler):
def _forward(self, req, stream, model, nonstream_fn, stream_fn, input_data=None): def _forward(self, req, stream, model, nonstream_fn, stream_fn, input_data=None):
try: try:
upstream = urllib.request.urlopen(req) upstream = urllib.request.urlopen(req, timeout=180)
except urllib.error.HTTPError as e: except urllib.error.HTTPError as e:
err = e.read().decode() err = e.read().decode()
return self.send_json(e.code, {"error": {"type": "upstream_error", "message": err}}) return self.send_json(e.code, {"error": {"type": "upstream_error", "message": err}})