Commit eb65fae6 authored by ibuler's avatar ibuler

[Update] 修改model

parent 9ae0d620
...@@ -360,7 +360,8 @@ class BaseServer(object): ...@@ -360,7 +360,8 @@ class BaseServer(object):
def close(self): def close(self):
logger.info("Close server to {}".format(self)) logger.info("Close server to {}".format(self))
self.r_input_output_data_filter(b'') self.s_input_state_filter(b'')
self.s_parse_input_output_filter(b'')
self.chan.close() self.chan.close()
def __getattr__(self, item): def __getattr__(self, item):
......
...@@ -117,14 +117,6 @@ class CommandRecorder(object): ...@@ -117,14 +117,6 @@ class CommandRecorder(object):
storage = None storage = None
_cache = [] _cache = []
def __new__(cls, *args, **kwargs):
if cls._cache:
return cls._cache[0]
else:
self = super(CommandRecorder, cls).__new__(cls, *args, **kwargs)
cls._cache.append(self)
return self
def __init__(self): def __init__(self):
super(CommandRecorder, self).__init__() super(CommandRecorder, self).__init__()
self.queue = MemoryQueue() self.queue = MemoryQueue()
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment