Commit 7227baa8 authored by ibuler's avatar ibuler

[Change] 修改session id字段

parent a8b07acb
...@@ -146,24 +146,18 @@ class Coco: ...@@ -146,24 +146,18 @@ class Coco:
def keep_push_record(self): def keep_push_record(self):
threads = [] threads = []
def push_command(q, callback, size=10): def worker(q, callback, size=10):
while not self.stop_evt.is_set():
data_set = q.mget(size)
if data_set and not callback(data_set):
q.mput(data_set)
def push_replay(q, callback, size=10):
while not self.stop_evt.is_set(): while not self.stop_evt.is_set():
data_set = q.mget(size) data_set = q.mget(size)
if data_set and not callback(data_set): if data_set and not callback(data_set):
q.mput(data_set) q.mput(data_set)
for i in range(self.config['MAX_PUSH_THREADS']): for i in range(self.config['MAX_PUSH_THREADS']):
t = threading.Thread(target=push_command, args=( t = threading.Thread(target=worker, args=(
self._command_queue, self._command_recorder.record_command, self._command_queue, self._command_recorder.record_command,
)) ))
threads.append(t) threads.append(t)
t = threading.Thread(target=push_replay, args=( t = threading.Thread(target=worker, args=(
self._replay_queue, self._replay_recorder.record_replay, self._replay_queue, self._replay_recorder.record_replay,
)) ))
threads.append(t) threads.append(t)
......
...@@ -139,7 +139,7 @@ class Session: ...@@ -139,7 +139,7 @@ class Session:
def to_json(self): def to_json(self):
return { return {
"uuid": self.id, "id": self.id,
"user": self.client.user.username, "user": self.client.user.username,
"asset": self.server.asset.hostname, "asset": self.server.asset.hostname,
"system_user": self.server.system_user.username, "system_user": self.server.system_user.username,
......
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