diff --git a/confluent_server/confluent/consoleserver.py b/confluent_server/confluent/consoleserver.py index 7b165f71..37274792 100644 --- a/confluent_server/confluent/consoleserver.py +++ b/confluent_server/confluent/consoleserver.py @@ -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 diff --git a/confluent_server/confluent/shellserver.py b/confluent_server/confluent/shellserver.py index 7a2c1027..5c23edc3 100644 --- a/confluent_server/confluent/shellserver.py +++ b/confluent_server/confluent/shellserver.py @@ -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})