From 2400949a780b3d1b3aaf636a13900e95a3495439 Mon Sep 17 00:00:00 2001
From: bowenliu <liubowen18@huawei.com>
Date: Wed, 31 Jul 2024 14:14:31 +0800
Subject: [PATCH] push dms commit

---
 src/gausskernel/ddes/ddes_commit_id |  4 ++--
 src/include/ddes/dms/dms_api.h      | 27 ++++++++++++++++++++++++++-
 2 files changed, 28 insertions(+), 3 deletions(-)

diff --git a/src/gausskernel/ddes/ddes_commit_id b/src/gausskernel/ddes/ddes_commit_id
index aa61cf540..31cce690c 100644
--- a/src/gausskernel/ddes/ddes_commit_id
+++ b/src/gausskernel/ddes/ddes_commit_id
@@ -1,3 +1,3 @@
-dms_commit_id=4e5c455f771c9be5e78260371eed2f28474cf253
+dms_commit_id=1e366d6a3ab36a7947d02d2664496d09e2a079ef
 dss_commit_id=083e52af8c7f965856f319554d6332b14f6b2c99
-cbb_commit_id=ac8ed05be35754e77032b4c9ec9b1eba53f1d5a6
+cbb_commit_id=49b0b0c664346a690c9fe9b537f264306dbdc46d
diff --git a/src/include/ddes/dms/dms_api.h b/src/include/ddes/dms/dms_api.h
index c0f29a600..1c2421034 100644
--- a/src/include/ddes/dms/dms_api.h
+++ b/src/include/ddes/dms/dms_api.h
@@ -34,7 +34,7 @@ extern "C" {
 #define DMS_LOCAL_MINOR_VER_WEIGHT  1000
 #define DMS_LOCAL_MAJOR_VERSION     0
 #define DMS_LOCAL_MINOR_VERSION     0
-#define DMS_LOCAL_VERSION           162
+#define DMS_LOCAL_VERSION           163
 
 #define DMS_SUCCESS 0
 #define DMS_ERROR (-1)
@@ -60,6 +60,7 @@ extern "C" {
 #define DMS_VERSION_MAX_LEN     256
 #define DMS_OCK_LOG_PATH_LEN    256
 #define DMS_LOG_PATH_LEN        (256)
+#define DMS_CMD_DESC_LEN        64
 
 // The values of the following two macros must be same with (GS_MAX_XA_BASE16_GTRID_LEN GS_MAX_XA_BASE16_BQUAL_LEN)
 #define DMS_MAX_XA_BASE16_GTRID_LEN    (128)
@@ -1371,6 +1372,30 @@ typedef struct st_driver_ping_info {
     unsigned long long minor_version;
 } driver_ping_info_t;
 
+typedef struct st_mes_msg_info {
+    unsigned int cmd;
+    unsigned short sid;
+} mes_msg_info_t;
+
+typedef struct st_mes_worker_msg_stats_info {
+    unsigned char is_active;
+    unsigned int tid;
+    int priority;
+    unsigned long long get_msgitem_time;
+    unsigned long long msg_ruid;
+    unsigned int msg_src_inst;
+    mes_msg_info_t msg_info;
+    char msg_cmd_desc[DMS_CMD_DESC_LEN];
+} mes_worker_msg_stats_info_t;
+
+typedef struct st_mes_task_priority_stats_info {
+    int priority;
+    unsigned int worker_num;
+    unsigned long long inqueue_msgitem_num;
+    unsigned long long finished_msgitem_num;
+    unsigned long long msgitem_free_num;
+} mes_task_priority_stats_info_t;
+
 #ifdef __cplusplus
 }
 #endif