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

Auto-restart vtbufferd on exit

Browse Source 
If vtbuffer is interrupted, then restart it.
This commit is contained in:
Jarrod Johnson
2026-07-02 12:13:24 -04:00
parent 752d04939b
commit a8cd9a24d5
1 changed files with 12 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
confluent_server/confluent/consoleserver.py
+12 -2
View File
@@ -603,13 +603,23 @@ async def _start_tenant_sessions(cfm):
event=log.Events.stacktrace)
cfm.watch_nodecollection(_nodechange)
running = True
async def run_buffer_daemon():
global _bufferdaemon
while running:
_bufferdaemon = await asyncio.subprocess.create_subprocess_exec(
'/opt/confluent/bin/vtbufferd', 'confluent-vtbuffer')
await _bufferdaemon.wait()
async def initialize():
global _tracelog
global _bufferdaemon
_tracelog = log.Logger('trace')
_bufferdaemon = await asyncio.subprocess.create_subprocess_exec(
'/opt/confluent/bin/vtbufferd', 'confluent-vtbuffer')
tasks.spawn(run_buffer_daemon())
#_bufferdaemon = await asyncio.subprocess.create_subprocess_exec(
# '/opt/confluent/bin/vtbufferd', 'confluent-vtbuffer')
#_bufferdaemon = subprocess.Popen(
# ['/opt/confluent/bin/vtbufferd', 'confluent-vtbuffer'], bufsize=0, stdin=subprocess.DEVNULL,
# stdout=subprocess.DEVNULL)