From bd23aa246b1ad06b3ac464b3620ca8f28fc160cb Mon Sep 17 00:00:00 2001
From: yang-feida <yang_feida@126.com>
Date: Wed, 17 Sep 2025 15:01:58 +0800
Subject: [PATCH] =?UTF-8?q?kmc=20sem=20key=20=E6=94=B9=E4=B8=BA=E5=AE=9A?=
 =?UTF-8?q?=E5=80=BC?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 omniadvisor/config/common_config.ini          | 6 +++++-
 omniadvisor/src/common/constant.py            | 5 +++++
 omniadvisor/src/common/kmc_toolkit/KmcUtil.py | 3 ++-
 3 files changed, 12 insertions(+), 2 deletions(-)

diff --git a/omniadvisor/config/common_config.ini b/omniadvisor/config/common_config.ini
index 053d720600..e97916d431 100755
--- a/omniadvisor/config/common_config.ini
+++ b/omniadvisor/config/common_config.ini
@@ -34,4 +34,8 @@ spark.output.merge.switch=False
 
 [webpage]
 # admin 页面显示的时区
-admin.timezone=Asia/Shanghai
\ No newline at end of file
+admin.timezone=Asia/Shanghai
+
+[kmc]
+# 这个参数的范围在 0x1111 -> 0x9999
+kmc.semkey=0x1111
\ No newline at end of file
diff --git a/omniadvisor/src/common/constant.py b/omniadvisor/src/common/constant.py
index 4a14610779..e7a0b699ee 100644
--- a/omniadvisor/src/common/constant.py
+++ b/omniadvisor/src/common/constant.py
@@ -62,6 +62,9 @@ def check_oa_conf() -> None:
     if not OA_CONF.admin_timezone:
         raise ValueError('The admin timezone can not be empty, please check common configuration.')
 
+    if OA_CONF.kmc_semkey < 0x1111 or OA_CONF.kmc_semkey > 0x9999:
+        raise ValueError('The kmc semkey should be between 0x1111 and 0x9999.')
+
 
 class OmniAdvisorConf:
     """
@@ -183,5 +186,7 @@ class OmniAdvisorConf:
         'update', 'merge', 'delete', 'rewrite', 'upsert', 'replace'
     ]
 
+    kmc_semkey = _common_config.getint('kmc', 'kmc.semkey')
+
 
 OA_CONF = OmniAdvisorConf()
diff --git a/omniadvisor/src/common/kmc_toolkit/KmcUtil.py b/omniadvisor/src/common/kmc_toolkit/KmcUtil.py
index 4256b7b8d8..53c22c6a3f 100644
--- a/omniadvisor/src/common/kmc_toolkit/KmcUtil.py
+++ b/omniadvisor/src/common/kmc_toolkit/KmcUtil.py
@@ -7,6 +7,7 @@ KMC类
 import ctypes
 import random
 import common.kmc_toolkit.constants as CONSTANTS
+from common.constant import OA_CONF
 from common.kmc_toolkit.KmcWrapperAPI import KmcWrapper
 from common.kmc_toolkit.msg_type import KmcConfig
 from common.kmc_toolkit.log import kmc_logger
@@ -61,7 +62,7 @@ class Kmc:
         standby_ksf = CONSTANTS.KMC_KSF_STANDBY
 
         # initial sem key
-        sem_key = CONSTANTS.DEFAULT_SEM_KEY + CONSTANTS.MIN_HEX_SEM_KEY
+        sem_key = CONSTANTS.DEFAULT_SEM_KEY + OA_CONF.kmc_semkey
 
         kmc_config = KmcConfig(
             primary_ksf.encode("utf-8"),
-- 
Gitee