diff --git a/core/src/data_substrate.cpp b/core/src/data_substrate.cpp index 80d5d004..cb66253e 100644 --- a/core/src/data_substrate.cpp +++ b/core/src/data_substrate.cpp @@ -21,7 +21,6 @@ */ #include -#include #include #include @@ -667,15 +666,6 @@ bool DataSubstrate::LoadCoreAndNetworkConfig(const INIReader &config_reader) !CheckCommandLineFlagIsDefault("maxclients") ? FLAGS_maxclients : config_reader.GetInteger("local", "maxclients", FLAGS_maxclients); - struct rlimit ulimit - { - }; - ulimit.rlim_cur = core_config_.maxclients; - ulimit.rlim_max = core_config_.maxclients; - if (setrlimit(RLIMIT_NOFILE, &ulimit) == -1) - { - LOG(WARNING) << "Failed to set maxclients."; - } core_config_.bootstrap = !CheckCommandLineFlagIsDefault("bootstrap") ? FLAGS_bootstrap diff --git a/docs/01-architecture-overview.md b/docs/01-architecture-overview.md index 556e3856..5b320fd5 100644 --- a/docs/01-architecture-overview.md +++ b/docs/01-architecture-overview.md @@ -75,6 +75,7 @@ All knobs follow *gflag overrides ini section* (`[local]`, `[cluster]`, `[store] | `auto_redirect` | false | Redirect object commands to remote owner NG internally | | `enable_key_cache` | false | Key cache (non-MVCC only) | | `enable_io_uring` / `raft_log_async_fsync` | false | IO engine options | +| `maxclients` | 500000 | API-server connection admission limit; does not modify process file-descriptor limits | | `max_standby_lag` | 400000 | Max primary→standby message lag | Build-time options are described in the repo `CLAUDE.md` (`WITH_DATA_STORE`, `WITH_LOG_STATE`, `WITH_LOG_SERVICE`, `EXT_TX_PROC_ENABLED`, `ELOQ_MODULE_ENABLED`). diff --git a/store_handler/eloq_data_store_service/eloqstore b/store_handler/eloq_data_store_service/eloqstore index f44d59af..09a42270 160000 --- a/store_handler/eloq_data_store_service/eloqstore +++ b/store_handler/eloq_data_store_service/eloqstore @@ -1 +1 @@ -Subproject commit f44d59affa345e2705948cc09716471961983ec1 +Subproject commit 09a4227028cc0de58bd5e4af4e10577438ca5563 diff --git a/store_handler/eloq_data_store_service/main.cpp b/store_handler/eloq_data_store_service/main.cpp index 53848f18..74cc3482 100644 --- a/store_handler/eloq_data_store_service/main.cpp +++ b/store_handler/eloq_data_store_service/main.cpp @@ -23,7 +23,6 @@ #include #include #include -#include #include #include @@ -88,8 +87,6 @@ DEFINE_bool(bootstrap, "Init data store config file and exit. (Only support bootstrap one " "node now.)"); -DEFINE_uint32(maxclients, 300000, "maxclients"); - static bool CheckCommandLineFlagIsDefault(const char *name) { gflags::CommandLineFlagInfo flag_info; @@ -205,22 +202,6 @@ int main(int argc, char *argv[]) std::filesystem::create_directories(data_path); } - // Set maxclients - uint32_t maxclients = - !CheckCommandLineFlagIsDefault("maxclients") - ? FLAGS_maxclients - : config_reader.GetInteger("local", "maxclients", FLAGS_maxclients); - - struct rlimit ulimit - { - }; - ulimit.rlim_cur = maxclients; - ulimit.rlim_max = maxclients; - if (setrlimit(RLIMIT_NOFILE, &ulimit) == -1) - { - LOG(WARNING) << "Failed to set maxclients."; - } - std::string ds_config_file_path = data_path + "/dss_config.ini"; EloqDS::DataStoreServiceClusterManager ds_config; diff --git a/third_party/src/brpc b/third_party/src/brpc index c12822d4..bf7c9cb8 160000 --- a/third_party/src/brpc +++ b/third_party/src/brpc @@ -1 +1 @@ -Subproject commit c12822d4931a59a9c2cc42df061975e114e93590 +Subproject commit bf7c9cb8a233a370c16e3ebb7664c7db57d97ac8 diff --git a/tx_service/include/tx_service.h b/tx_service/include/tx_service.h index 0bdea682..da9b1a6f 100644 --- a/tx_service/include/tx_service.h +++ b/tx_service/include/tx_service.h @@ -1068,6 +1068,11 @@ class TxServiceModule : public eloq::EloqModule public: TxServiceModule() = default; + eloq::ModuleType Type() const override + { + return eloq::ModuleType::kTxService; + } + void Init(std::vector> *tx_processors) { tx_processors_ = tx_processors;