48 lines
1.5 KiB
Diff
48 lines
1.5 KiB
Diff
From c10a2b4ab02efa9f3172aae2741f084a1c477adc Mon Sep 17 00:00:00 2001
|
|
From: xuezhixin <xuezhixin@uniontech.com>
|
|
Date: Mon, 13 Nov 2023 15:56:28 +0800
|
|
Subject: [PATCH] =?UTF-8?q?agent=E8=BF=81=E7=A7=BB=E6=A3=80=E6=B5=8B?=
|
|
=?UTF-8?q?=E4=BB=BB=E5=8A=A1=E6=89=A7=E8=A1=8C?=
|
|
MIME-Version: 1.0
|
|
Content-Type: text/plain; charset=UTF-8
|
|
Content-Transfer-Encoding: 8bit
|
|
|
|
---
|
|
sysmig_agent/fork.py | 23 +++++++++++++++++++++++
|
|
1 file changed, 23 insertions(+)
|
|
|
|
diff --git a/sysmig_agent/fork.py b/sysmig_agent/fork.py
|
|
index a128722..daea65f 100644
|
|
--- a/sysmig_agent/fork.py
|
|
+++ b/sysmig_agent/fork.py
|
|
@@ -38,3 +38,26 @@ def up_to_date_sql_abi():
|
|
# 获取abi progress 更新数据库内
|
|
sql_abi_progress(abi_process)
|
|
return 0
|
|
+
|
|
+
|
|
+# ABI系统检测
|
|
+def timed_task_abi(task_id):
|
|
+ time_task = BackgroundScheduler(timezone='Asia/Shanghai')
|
|
+ task_id=str(task_id)
|
|
+ p = time_task.add_job(up_to_date_sql_abi, 'interval', seconds=3)
|
|
+ time_task.start()
|
|
+ try:
|
|
+ task_statue='1'
|
|
+ p_abi = Process(target=migrate_before_abi_chk, args=(q,task_statue,))
|
|
+ p_abi.start()
|
|
+ p_abi.join()
|
|
+ # Determine whether the message queue is dead or empty to end the timer
|
|
+ while not q.empty():
|
|
+ continue
|
|
+ time_task.shutdown()
|
|
+ except (KeyboardInterrupt, SystemExit):
|
|
+ # Not strictly necessary if daemonic mode is enabled but should be done if possible
|
|
+ time_task.shutdown()
|
|
+ print('Exit The Job!')
|
|
+
|
|
+
|
|
--
|
|
2.20.1
|
|
|