diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-03-04 08:34:47 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-03-04 08:34:47 +0000 |
commit | bf25e9eb063aeab4cbf4204ad9b84f0ca7ec340e (patch) | |
tree | 7c92eb53a9125b1a4b2d6095f00cf72e969cc402 /config | |
parent | 2747507ce27e3d41df5478b2cb42c1796424cf65 (diff) |
Revert back to using poll for nextUpdate
Diffstat (limited to 'config')
-rw-r--r-- | config/src/vespa/config/subscription/configsubscription.cpp | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/config/src/vespa/config/subscription/configsubscription.cpp b/config/src/vespa/config/subscription/configsubscription.cpp index 5eea0895eed..04904d07b17 100644 --- a/config/src/vespa/config/subscription/configsubscription.cpp +++ b/config/src/vespa/config/subscription/configsubscription.cpp @@ -31,11 +31,11 @@ ConfigSubscription::~ConfigSubscription() bool ConfigSubscription::nextUpdate(int64_t generation, vespalib::steady_time deadline) { - if (_closed || !_holder->wait_until(deadline)) { return false; } - if (_closed) { return false; } // The above wait_until can be interrupted + if (_closed || !_holder->poll()) { + return false; + } auto old = std::move(_next); _next = _holder->provide(); - if ( ! _next) { return false; } if (old) { _next->merge(*old); } |