Commit 634a514f authored by liuzheng712's avatar liuzheng712 Committed by liuzheng

Merge branch 'dev' of bitbucket.org:jumpserver/coco into dev

parents d5bfe97b 4ae7b664
FROM jumpserver/python:v3 FROM registry.fit2cloud.com/jumpserver/python:v3
MAINTAINER Jumpserver Team <ibuler@qq.com> MAINTAINER Jumpserver Team <ibuler@qq.com>
COPY . /opt/coco COPY . /opt/coco
......
...@@ -174,11 +174,10 @@ class ServerCommandRecorder(CommandRecorder, metaclass=Singleton): ...@@ -174,11 +174,10 @@ class ServerCommandRecorder(CommandRecorder, metaclass=Singleton):
thread.start() thread.start()
def session_start(self, session_id): def session_start(self, session_id):
print("When session {} start exec".format(session_id)) pass
def session_end(self, session_id): def session_end(self, session_id):
self.stop_evt.set() pass
print("When session {} end start".format(session_id))
def __del__(self): def __del__(self):
print("{} has been gc".format(self)) print("{} has been gc".format(self))
......
...@@ -21,7 +21,7 @@ class Session: ...@@ -21,7 +21,7 @@ class Session:
self._sharers = [] # Join to the session, read and write self._sharers = [] # Join to the session, read and write
self.replaying = True self.replaying = True
self.date_created = datetime.datetime.now() self.date_created = datetime.datetime.now()
self.date_finished = None self.date_end = None
self.stop_evt = threading.Event() self.stop_evt = threading.Event()
self.sel = selectors.DefaultSelector() self.sel = selectors.DefaultSelector()
self._command_recorder = command_recorder self._command_recorder = command_recorder
...@@ -160,7 +160,7 @@ class Session: ...@@ -160,7 +160,7 @@ class Session:
logger.info("Close the session: {} ".format(self.id)) logger.info("Close the session: {} ".format(self.id))
self.stop_evt.set() self.stop_evt.set()
self.post_bridge() self.post_bridge()
self.date_finished = datetime.datetime.now() self.date_end = datetime.datetime.now()
self.server.close() self.server.close()
def to_json(self): def to_json(self):
...@@ -172,7 +172,7 @@ class Session: ...@@ -172,7 +172,7 @@ class Session:
"login_from": "ST", "login_from": "ST",
"is_finished": True if self.stop_evt.is_set() else False, "is_finished": True if self.stop_evt.is_set() else False,
"date_start": self.date_created.strftime("%Y-%m-%d %H:%M:%S"), "date_start": self.date_created.strftime("%Y-%m-%d %H:%M:%S"),
"date_finished": self.date_finished.strftime("%Y-%m-%d %H:%M:%S") if self.date_finished else None "date_end": self.date_end.strftime("%Y-%m-%d %H:%M:%S") if self.date_end else None
} }
def __str__(self): def __str__(self):
...@@ -182,4 +182,4 @@ class Session: ...@@ -182,4 +182,4 @@ class Session:
return self.id return self.id
def __del__(self): def __del__(self):
logger.info("Session {} object has been GC") logger.info("Session {} object has been GC".format(self.id))
...@@ -15,7 +15,7 @@ class Config: ...@@ -15,7 +15,7 @@ class Config:
# APP_NAME = "localhost" # APP_NAME = "localhost"
# Jumpserver项目的url, api请求注册会使用 # Jumpserver项目的url, api请求注册会使用
CORE_HOST = os.environ.get("CORE_HOST") or 'http://jumpserver:8080' CORE_HOST = os.environ.get("CORE_HOST") or 'http://core:8080'
# 启动时绑定的ip, 默认 0.0.0.0 # 启动时绑定的ip, 默认 0.0.0.0
# BIND_HOST = '0.0.0.0' # BIND_HOST = '0.0.0.0'
......
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