2
0
mirror of https://github.com/xcat2/confluent.git synced 2025-02-02 20:13:26 +00:00

Remove disused bufferlock

We no longer use a lock on buffer communication, eliminate
the stale variable.
This commit is contained in:
Jarrod Johnson 2024-02-22 15:07:12 -05:00
parent 72e26caf36
commit fa5b1c671e

View File

@ -49,7 +49,6 @@ _handled_consoles = {}
_tracelog = None
_bufferdaemon = None
_bufferlock = None
try:
range = xrange
@ -602,8 +601,6 @@ def _start_tenant_sessions(cfm):
def initialize():
global _tracelog
global _bufferdaemon
global _bufferlock
_bufferlock = semaphore.Semaphore()
_tracelog = log.Logger('trace')
_bufferdaemon = subprocess.Popen(
['/opt/confluent/bin/vtbufferd', 'confluent-vtbuffer'], bufsize=0, stdin=subprocess.DEVNULL,