From 6df7366753d0ab3bd074fdd913f7f56cc1b16956 Mon Sep 17 00:00:00 2001 From: Grant Limberg Date: Thu, 2 Oct 2025 16:00:08 -0700 Subject: [PATCH] no need for these timeouts --- nonfree/controller/PubSubListener.cpp | 3 --- 1 file changed, 3 deletions(-) diff --git a/nonfree/controller/PubSubListener.cpp b/nonfree/controller/PubSubListener.cpp index bba666efd..ee3f1939f 100644 --- a/nonfree/controller/PubSubListener.cpp +++ b/nonfree/controller/PubSubListener.cpp @@ -98,19 +98,16 @@ void PubSubListener::subscribe() auto result = session.wait_for(std::chrono::seconds(10)); if (result == std::future_status::timeout) { session.cancel(); - std::this_thread::sleep_for(std::chrono::seconds(5)); continue; } if (! session.valid()) { fprintf(stderr, "Subscription session no longer valid\n"); - std::this_thread::sleep_for(std::chrono::seconds(5)); continue; } } catch (google::cloud::Status const& status) { fprintf(stderr, "Subscription terminated with status: %s\n", status.message().c_str()); - std::this_thread::sleep_for(std::chrono::seconds(5)); } } }