xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2026-09-02 07:26:04 +00:00
Code Issues Projects Releases Wiki Activity

Do not aggressively respawn buffer daemon.

Browse Source 
Start buffer daemon only when needed.

Limit restarts to once every 30 seconds.
This commit is contained in:
Jarrod Johnson
2026-08-20 07:23:40 -04:00
parent 7347125b6f
commit 29a9d417d6
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
confluent_server/confluent/consoleserver.py
+9 -1
View File
@@ -61,6 +61,8 @@ def chunk_output(output, n):
yield output[i:i + n]
def get_buffer_output(nodename):
if _bufferdaemon is None:
eventlet.spawn(run_buffer_daemon)
out = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
out.setsockopt(socket.SOL_SOCKET, socket.SO_PASSCRED, 1)
out.connect("\x00confluent-vtbuffer")
@@ -85,6 +87,8 @@ def get_buffer_output(nodename):
def send_output(nodename, output):
if not isinstance(nodename, bytes):
nodename = nodename.encode('utf8')
if _bufferdaemon is None:
eventlet.spawn(run_buffer_daemon)
out = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
out.setsockopt(socket.SOL_SOCKET, socket.SO_PASSCRED, 1)
out.connect("\x00confluent-vtbuffer")
@@ -602,16 +606,20 @@ running = True
def run_buffer_daemon():
global _bufferdaemon
while running:
minrestartdeadline = time.time() + 30 # Do not restart more than once every 30 seconds
_bufferdaemon = subprocess.Popen(
['/opt/confluent/bin/vtbufferd', 'confluent-vtbuffer'], bufsize=0, stdin=subprocess.DEVNULL,
stdout=subprocess.DEVNULL)
_bufferdaemon.wait()
# Ensure we do not restart more than once every 30 seconds
sleep_time = minrestartdeadline - time.time()
if sleep_time > 0:
eventlet.sleep(sleep_time)
def initialize():
global _tracelog
global _bufferdaemon
_tracelog = log.Logger('trace')
eventlet.spawn(run_buffer_daemon)
def start_console_sessions():
configmodule.hook_new_configmanagers(_start_tenant_sessions)