xCAT/confluent
2
0
Fork 0
mirror of https://github.com/xcat2/confluent.git synced 2025-01-11 18:28:11 +00:00
Code Issues Projects Releases Wiki Activity

Aggregate vt buffer feeds

Browse Source 
If we start developing a backlog
of content to feed to the buffer manager,
aggregate updates to batch submit them more efficiently.
This commit is contained in:
Jarrod Johnson 2021-07-19 11:16:12 -04:00
parent a8b54ff434
commit db735a654d
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
confluent_server/confluent/consoleserver.py
View File

@ -143,6 +143,7 @@ class ConsoleHandler(object):
#self.termstream.attach(self.buffer)
self.livesessions = set([])
self.utf8decoder = codecs.getincrementaldecoder('utf-8')()
self.pendingbytes = None
if self._logtobuffer:
self.logger = log.Logger(node, console=True,
tenant=configmanager.tenant)
@ -186,8 +187,15 @@ class ConsoleHandler(object):
def feedbuffer(self, data):
if not isinstance(data, bytes):
data = data.encode('utf-8')
if self.pendingbytes is not None:
self.pendingbytes += data
self.pendingbytes = b''
try:
send_output(self.node, data)
data = self.pendingbytes
self.pendingbytes = None
if data:
send_output(self.node, data)
except Exception:
_tracelog.log(traceback.format_exc(), ltype=log.DataTypes.event,
event=log.Events.stacktrace)