github
/
jumpserver
mirror of https://github.com/jumpserver/jumpserver
1
0
Fork 0
Code Issues Releases Wiki Activity

fix: settings 订阅不稳定

pull/5953/head
xinwen 2021-04-13 18:33:00 +08:00 committed by 老广
parent ce6b9de07c
commit 9944474ba0
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/settings/signals_handler.py
View File

@ -6,6 +6,7 @@ import threading
from django.dispatch import receiver from django.dispatch import receiver
from django.db.models.signals import post_save, pre_save from django.db.models.signals import post_save, pre_save
from django.utils.functional import LazyObject from django.utils.functional import LazyObject
from django.db import close_old_connections
from jumpserver.utils import current_request from jumpserver.utils import current_request
from common.decorator import on_transaction_commit from common.decorator import on_transaction_commit
@ -75,6 +76,7 @@ def subscribe_settings_change(sender, **kwargs):
try: try:
sub = setting_pub_sub.subscribe() sub = setting_pub_sub.subscribe()
for msg in sub.listen(): for msg in sub.listen():
close_old_connections()
if msg["type"] != "message": if msg["type"] != "message":
continue continue
item = msg['data'].decode() item = msg['data'].decode()
@ -82,6 +84,7 @@ def subscribe_settings_change(sender, **kwargs):
Setting.refresh_item(item) Setting.refresh_item(item)
except Exception as e: except Exception as e:
logger.exception(f'subscribe_settings_change: {e}') logger.exception(f'subscribe_settings_change: {e}')
close_old_connections()
Setting.refresh_all_settings() Setting.refresh_all_settings()
t = threading.Thread(target=keep_subscribe) t = threading.Thread(target=keep_subscribe)