2
0
mirror of https://github.com/xcat2/confluent.git synced 2024-11-25 11:01:09 +00:00

Stub out buffering for shell sessions

This is not yet handled anyway.

For future, establish norm of a nodeid
to prefix multiple distinct sessions.
This commit is contained in:
Jarrod Johnson 2022-02-22 08:49:31 -05:00
parent 8fab8238ed
commit 3cf9edeeb8
2 changed files with 7 additions and 2 deletions

View File

@ -126,6 +126,7 @@ class ConsoleHandler(object):
'collective.manager'))
def __init__(self, node, configmanager, width=80, height=24):
self.termprefix = 'c_'
self.clearpending = False
self.clearerror = False
self.initsize = (width, height)
@ -190,7 +191,7 @@ class ConsoleHandler(object):
if self.pendingbytes is not None:
self.pendingbytes += data
self.pendingbytes = b''
nodeid = self._plugin_path.format(self.node)
nodeid = self.termprefix + self.node
try:
send_output(nodeid, data)
data = self.pendingbytes
@ -548,7 +549,7 @@ class ConsoleHandler(object):
'connectstate': self.connectstate,
'clientcount': len(self.livesessions),
}
nodeid = self._plugin_path.format(self.node)
nodeid = self.termprefix + self.node
retdata = get_buffer_output(nodeid)
return retdata, connstate

View File

@ -37,6 +37,10 @@ class _ShellHandler(consoleserver.ConsoleHandler):
# suppress logging through proving a stub 'log' function
return
def feedbuffer(self, data):
return
#return super().feedbuffer(data)
def _got_disconnected(self):
self.connectstate = 'closed'
self._send_rcpts({'connectstate': self.connectstate})