From 167b4ac5f4cf132c31ca967ccb2f6e88d075aa60 Mon Sep 17 00:00:00 2001 From: lzxddz Date: Wed, 29 Oct 2025 18:51:06 +0800 Subject: [PATCH] convert tx ng configs to dss_config --- src/redis_service.cpp | 15 +++++++++++++-- 1 file changed, 13 insertions(+), 2 deletions(-) diff --git a/src/redis_service.cpp b/src/redis_service.cpp index 435b1c9b..76f4c768 100644 --- a/src/redis_service.cpp +++ b/src/redis_service.cpp @@ -1014,9 +1014,19 @@ bool RedisServiceImpl::Init(brpc::Server &brpc_server) std::filesystem::create_directories(eloq_dss_data_path); } - std::string dss_config_file_path = - eloq_dss_data_path + "/dss_config.ini"; + std::string dss_config_file_path = ""; + EloqDS::DataStoreServiceClusterManager ds_config; + uint32_t dss_leader_id = UINT32_MAX; + if (FLAGS_bootstrap || is_single_node) + { + dss_leader_id = node_id; + } + EloqDS::DataStoreServiceClient::TxConfigsToDssClusterConfig( + node_id, native_ng_id, ng_configs, dss_leader_id, ds_config); + // std::string dss_config_file_path = + // eloq_dss_data_path + "/dss_config.ini"; + /* EloqDS::DataStoreServiceClusterManager ds_config; if (std::filesystem::exists(dss_config_file_path)) { @@ -1068,6 +1078,7 @@ bool RedisServiceImpl::Init(brpc::Server &brpc_server) return false; } } + */ #if defined(DATA_STORE_TYPE_ELOQDSS_ROCKSDB_CLOUD_S3) || \ defined(DATA_STORE_TYPE_ELOQDSS_ROCKSDB_CLOUD_GCS)