Loading src/backends/cluster.cpp +3 −3 Original line number Diff line number Diff line Loading @@ -340,15 +340,15 @@ namespace authdb { }); if (need_initial_data) { // First fetch: wait up to 5s so we have data for the first request static constexpr auto INITIAL_TIMEOUT = std::chrono::seconds(5); // First fetch: wait up to 30s so we have data for the first request static constexpr auto INITIAL_TIMEOUT = std::chrono::seconds(30); if (cache->pending_retrieve.wait_for(INITIAL_TIMEOUT) == std::future_status::ready) { manifest = cache->pending_retrieve.get(); cache->last_fetch = now; cache->recovery_epoch = cur_epoch; } else { std::cerr << "[CLUSTER-BE] domain=" << _Domain << " initial retrieve timed out after 5s" << std::endl; << " initial retrieve timed out after 30s" << std::endl; return; } } Loading Loading
src/backends/cluster.cpp +3 −3 Original line number Diff line number Diff line Loading @@ -340,15 +340,15 @@ namespace authdb { }); if (need_initial_data) { // First fetch: wait up to 5s so we have data for the first request static constexpr auto INITIAL_TIMEOUT = std::chrono::seconds(5); // First fetch: wait up to 30s so we have data for the first request static constexpr auto INITIAL_TIMEOUT = std::chrono::seconds(30); if (cache->pending_retrieve.wait_for(INITIAL_TIMEOUT) == std::future_status::ready) { manifest = cache->pending_retrieve.get(); cache->last_fetch = now; cache->recovery_epoch = cur_epoch; } else { std::cerr << "[CLUSTER-BE] domain=" << _Domain << " initial retrieve timed out after 5s" << std::endl; << " initial retrieve timed out after 30s" << std::endl; return; } } Loading