Add timeout config for router.

This commit is contained in:
Braydon Fuller
2024-10-03 16:54:07 -07:00
parent 08f06338f3
commit dbca33cc99

View File

@ -218,7 +218,7 @@ struct Router {
}; };
std::string routerConfigFile; std::string routerConfigFile;
uint64_t connectionTimeoutUs = 5'000'000; uint64_t connectionTimeoutUs = 20'000'000;
WriterPipeline writer; WriterPipeline writer;
Decompressor decomp; Decompressor decomp;
@ -293,6 +293,19 @@ struct Router {
void reconcileConfig() { void reconcileConfig() {
LI << "Loading router config file: " << routerConfigFile; LI << "Loading router config file: " << routerConfigFile;
try {
auto routerConfig = loadRawTaoConfig(routerConfigFile);
if (routerConfig.find("timeout")) {
connectionTimeoutUs = stoi(routerConfig.at("timeout").get_string()) * 1'000'000;
LI << "Using configured timeout (seconds): " << (connectionTimeoutUs / 1'000'000);
} else {
LI << "Using default timeout (seconds): " << connectionTimeoutUs / 1'000'000;
}
} catch (std::exception &e) {
LE << "Failed to parse router timeout in config: " << e.what();
}
try { try {
auto routerConfig = loadRawTaoConfig(routerConfigFile); auto routerConfig = loadRawTaoConfig(routerConfigFile);