gian/ceph-mirror
1
0
Fork 0
mirror of https://github.com/ceph/ceph synced 2026-08-01 22:45:39 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

Merge pull request #69833 from NitzanMordhai/wip-nitzan-ceph-daemon-adding-timeout

Browse Source 
pybind/ceph_daemon: add 10s timeout to admin socket client
This commit is contained in:
SrinivasaBharathKanta 2026-07-20 13:54:10 +05:30 committed by GitHub
commit 179b4aeed1
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/pybind/ceph_daemon.py
View File

@ -33,17 +33,21 @@ READ_CHUNK_SIZE = 4096
def admin_socket(asok_path: str,
cmd: List[str],
format: Optional[str] = '') -> bytes:
format: Optional[str] = '',
timeout: Optional[float] = 10) -> bytes:
"""
Send a daemon (--admin-daemon) command 'cmd'. asok_path is the
path to the admin socket; cmd is a list of strings; format may be
set to one of the formatted forms to get output in that form
(daemon commands don't support 'plain' output).
timeout is the socket timeout in seconds (default 10, matching the
AdminSocketClient); pass None for no timeout (blocking forever).
"""
def do_sockio(path: str, cmd_bytes: bytes) -> bytes:
""" helper: do all the actual low-level stream I/O """
sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
sock.settimeout(timeout)
sock.connect(path)
try:
sock.sendall(cmd_bytes + b'\0')