mirrors/hermes-agent
1
0
Fork 0
mirror of https://github.com/NousResearch/hermes-agent.git synced 2026-04-25 00:51:20 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Revert "fix: enable TCP keepalives to detect dead provider connections (#10324)"

Browse source 
This reverts commit 64fee35dc0.
This commit is contained in:
Teknium 2026-04-16 03:58:50 -07:00
parent e66b373351
commit e07dbde582
No known key found for this signature in database
1 changed files with 0 additions and 23 deletions
Download patch file Download diff file Expand all files Collapse all files

23
run_agent.py
View file

@ -4366,29 +4366,6 @@ class AIAgent:
self._client_log_context(),
)
return client
# Inject TCP keepalives to detect dead connections faster (#10324).
# Without keepalives, a provider that drops mid-stream leaves the
# socket in CLOSE-WAIT and epoll_wait may never fire, causing the
# agent to hang indefinitely. Keepalive probes detect the dead
# peer within ~60s (30s idle + 3×10s probes).
if "http_client" not in client_kwargs:
try:
import httpx as _httpx
import socket as _socket
_sock_opts = [(_socket.SOL_SOCKET, _socket.SO_KEEPALIVE, 1)]
if hasattr(_socket, "TCP_KEEPIDLE"):
# Linux
_sock_opts.append((_socket.IPPROTO_TCP, _socket.TCP_KEEPIDLE, 30))
_sock_opts.append((_socket.IPPROTO_TCP, _socket.TCP_KEEPINTVL, 10))
_sock_opts.append((_socket.IPPROTO_TCP, _socket.TCP_KEEPCNT, 3))
elif hasattr(_socket, "TCP_KEEPALIVE"):
# macOS (uses TCP_KEEPALIVE instead of TCP_KEEPIDLE)
_sock_opts.append((_socket.IPPROTO_TCP, _socket.TCP_KEEPALIVE, 30))
client_kwargs["http_client"] = _httpx.Client(
transport=_httpx.HTTPTransport(socket_options=_sock_opts),
)
except Exception:
pass # Fall through to default transport if socket opts fail
client = OpenAI(**client_kwargs)
logger.info(
"OpenAI client created (%s, shared=%s) %s",