database/openGauss-server
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

【bugfix】mes wrork线程池化问题修复

Browse Source
This commit is contained in:
dongning12
2024-01-22 14:19:14 +08:00
parent 13130a581a
commit f78687b40f
3 changed files with 7 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/include/ddes/dms/dms_api.h
View File

@ -32,7 +32,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 127
#define DMS_LOCAL_VERSION 128
#define DMS_SUCCESS 0
#define DMS_ERROR (-1)
@ -823,7 +823,7 @@ typedef int(*dms_get_open_status)(void *db_handle);
typedef void (*dms_reform_set_dms_role)(void *db_handle, unsigned int reformer_id);
typedef void (*dms_reset_user)(void *db_handle, unsigned long long list_in);
typedef int (*dms_drc_xa_res_rebuild)(void *db_handle, unsigned char thread_index, unsigned char parall_num);
typedef void (*dms_reform_shrink_xa_rms)(unsigned char undo_seg_id);
typedef void (*dms_reform_shrink_xa_rms)(void *db_handle, unsigned char undo_seg_id);
typedef void (*dms_ckpt_unblock_rcy_local)(void *db_handle, unsigned long long list_in);
// for openGauss

6
src/include/storage/proc.h
View File

@ -478,12 +478,12 @@ const int MAX_COMPACTION_THREAD_NUM = 10;
#define NUM_DMS_PRIO_CNT 4
#define NUM_DMS_RECV_THREAD_CNT (g_instance.attr.attr_storage.dms_attr.channel_count * \
(g_instance.attr.attr_storage.dms_attr.inst_count - 1) * NUM_DMS_PRIO_CNT)
#define NUM_DMS_MAX_WORK_THREAD_PROCS (128)
#define NUM_DMS_MAX_WORK_THREAD_PROCS (g_instance.attr.attr_storage.dms_attr.work_thread_pool_max_cnt)
#define NUM_DMS_WORK_SCHEDULER_PROC (1)
#define NUM_DMS_RDMA_THREAD_PROCS (g_instance.attr.attr_storage.dms_attr.work_thread_count == 0 ? \
#define NUM_DMS_RDMA_THREAD_PROCS (g_instance.attr.attr_storage.dms_attr.work_thread_pool_max_cnt != 0 ? \
NUM_DMS_MAX_WORK_THREAD_PROCS * 2 + NUM_DMS_WORK_SCHEDULER_PROC : \
g_instance.attr.attr_storage.dms_attr.work_thread_count * 2)
#define NUM_DMS_WORK_THREAD_PROCS (g_instance.attr.attr_storage.dms_attr.work_thread_count == 0 ? \
#define NUM_DMS_WORK_THREAD_PROCS (g_instance.attr.attr_storage.dms_attr.work_thread_pool_max_cnt != 0 ? \
NUM_DMS_MAX_WORK_THREAD_PROCS + NUM_DMS_WORK_SCHEDULER_PROC : \
g_instance.attr.attr_storage.dms_attr.work_thread_count)
#define NUM_DMS_CALLBACK_PROCS \