diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-02-07 15:52:09 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2023-02-07 15:52:09 +0000 |
commit | 55c134df2dc5902712f328752dd389fb368b17bd (patch) | |
tree | 92fe6785f658f7daefe9875ee8b083cf63653d7a | |
parent | 7c504278a2873bc1b95779ee12e4ab2f9b4e7268 (diff) |
Let default max timeout be 600s
-rw-r--r-- | storage/src/vespa/storage/storageserver/statemanager.cpp | 6 | ||||
-rw-r--r-- | vdslib/src/vespa/vdslib/state/nodestate.cpp | 3 |
2 files changed, 6 insertions, 3 deletions
diff --git a/storage/src/vespa/storage/storageserver/statemanager.cpp b/storage/src/vespa/storage/storageserver/statemanager.cpp index c838885aadf..a9a2c29a5a6 100644 --- a/storage/src/vespa/storage/storageserver/statemanager.cpp +++ b/storage/src/vespa/storage/storageserver/statemanager.cpp @@ -23,6 +23,10 @@ LOG_SETUP(".state.manager"); namespace storage { +namespace { + constexpr vespalib::duration MAX_TIMEOUT = 600s; +} + struct StateManager::StateManagerMetrics : metrics::MetricSet { metrics::DoubleAverageMetric invoke_state_listeners_latency; @@ -402,7 +406,7 @@ StateManager::onGetNodeState(const api::GetNodeStateCommand::SP& cmd) && is_up_to_date) { vespalib::duration timeout = cmd->getTimeout(); - if (timeout == vespalib::duration::max()) timeout = 24h; //balder: Dirty temporary hack + if (timeout == vespalib::duration::max()) timeout = MAX_TIMEOUT; LOG(debug, "Received get node state request with timeout of %f seconds. Scheduling to be answered in " "%f seconds unless a node state change happens before that time.", diff --git a/vdslib/src/vespa/vdslib/state/nodestate.cpp b/vdslib/src/vespa/vdslib/state/nodestate.cpp index d86a6dee773..3fc33862e6f 100644 --- a/vdslib/src/vespa/vdslib/state/nodestate.cpp +++ b/vdslib/src/vespa/vdslib/state/nodestate.cpp @@ -62,8 +62,7 @@ NodeState::NodeState(vespalib::stringref serialized, const NodeType* type) vespalib::StringTokenizer st(serialized, " \t\f\r\n"); st.removeEmptyTokens(); - for (auto token : st) - { + for (auto token : st) { std::string::size_type index = token.find(':'); if (index == std::string::npos) { throw IllegalArgumentException("Token " + token + " does not contain ':': " + serialized, VESPA_STRLOC); |