diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2023-03-01 17:56:51 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2023-03-01 17:56:51 +0100 |
commit | b6d95fabbb3fbd85b6a572da5473a3204678d2d3 (patch) | |
tree | dfc07974f1fc8f3e00862b49908c671c4d5739f4 /storage | |
parent | d17de6e8eae213f9e71c7fddb5b3876ff1d0a58b (diff) |
Revert "Balder/enforce system time for snapshot"
Diffstat (limited to 'storage')
-rw-r--r-- | storage/src/vespa/storage/common/statusmetricconsumer.cpp | 20 | ||||
-rw-r--r-- | storage/src/vespa/storage/storageserver/statereporter.cpp | 5 |
2 files changed, 13 insertions, 12 deletions
diff --git a/storage/src/vespa/storage/common/statusmetricconsumer.cpp b/storage/src/vespa/storage/common/statusmetricconsumer.cpp index 5998a2fe9a9..c6f73540605 100644 --- a/storage/src/vespa/storage/common/statusmetricconsumer.cpp +++ b/storage/src/vespa/storage/common/statusmetricconsumer.cpp @@ -61,7 +61,7 @@ StatusMetricConsumer::reportStatus(std::ostream& out, } else { LOG(debug, "Not calling update hooks as dontcallupdatehooks option has been given"); } - vespalib::system_time currentTime = _component.getClock().getSystemTime(); + int64_t currentTimeS(vespalib::count_s(_component.getClock().getMonotonicTime().time_since_epoch())); bool json = (path.getAttribute("format") == "json"); int verbosity(path.get("verbosity", 0)); @@ -72,7 +72,7 @@ StatusMetricConsumer::reportStatus(std::ostream& out, if (path.hasAttribute("task") && path.getAttribute("task") == "reset") { std::lock_guard guard(_lock); - _manager.reset(currentTime); + _manager.reset(currentTimeS); } if (path.hasAttribute("interval")) { @@ -83,7 +83,7 @@ StatusMetricConsumer::reportStatus(std::ostream& out, const metrics::MetricSnapshot* snapshot; if (interval == -2) { snapshot = &_manager.getActiveMetrics(metricLock); - _manager.getActiveMetrics(metricLock).setToTime(currentTime); + _manager.getActiveMetrics(metricLock).setToTime(currentTimeS); } else if (interval == -1) { // "Prime" the metric structure by first fetching the set of active // metrics (complete with structure) and resetting these. This @@ -94,9 +94,9 @@ StatusMetricConsumer::reportStatus(std::ostream& out, "Total metrics from start until current time", 0, _manager.getActiveMetrics(metricLock).getMetrics(), copyUnset); - generated->reset(); - _manager.getTotalMetricSnapshot(metricLock).addToSnapshot(*generated, currentTime); - _manager.getActiveMetrics(metricLock).addToSnapshot(*generated, currentTime); + generated->reset(0); + _manager.getTotalMetricSnapshot(metricLock).addToSnapshot(*generated, currentTimeS); + _manager.getActiveMetrics(metricLock).addToSnapshot(*generated, currentTimeS); generated->setFromTime(_manager.getTotalMetricSnapshot(metricLock).getFromTime()); snapshot = generated.get(); } else if (interval == 0) { @@ -104,8 +104,8 @@ StatusMetricConsumer::reportStatus(std::ostream& out, generated = std::make_unique<metrics::MetricSnapshot>( _manager.getTotalMetricSnapshot(metricLock).getName(), 0, _manager.getActiveMetrics(metricLock).getMetrics(), true); - generated->reset(); - _manager.getTotalMetricSnapshot(metricLock).addToSnapshot(*generated, currentTime); + generated->reset(0); + _manager.getTotalMetricSnapshot(metricLock).addToSnapshot(*generated, currentTimeS); snapshot = generated.get(); } else { snapshot = &_manager.getTotalMetricSnapshot(metricLock); @@ -115,9 +115,9 @@ StatusMetricConsumer::reportStatus(std::ostream& out, generated = std::make_unique<metrics::MetricSnapshot>( _manager.getMetricSnapshot(metricLock, interval).getName(), 0, _manager.getActiveMetrics(metricLock).getMetrics(), true); - generated->reset(); + generated->reset(0); _manager.getMetricSnapshot(metricLock, interval, temporarySnap) - .addToSnapshot(*generated, currentTime); + .addToSnapshot(*generated, currentTimeS); snapshot = generated.get(); } else { snapshot = &_manager.getMetricSnapshot(metricLock, interval, temporarySnap); diff --git a/storage/src/vespa/storage/storageserver/statereporter.cpp b/storage/src/vespa/storage/storageserver/statereporter.cpp index 79746f2cd63..205a2d710a6 100644 --- a/storage/src/vespa/storage/storageserver/statereporter.cpp +++ b/storage/src/vespa/storage/storageserver/statereporter.cpp @@ -81,8 +81,9 @@ StateReporter::getMetrics(const vespalib::string &consumer) _manager.getMetricSnapshot(guard, interval).getName(), interval, _manager.getActiveMetrics(guard).getMetrics(), true); - snapshot.reset(); - _manager.getMetricSnapshot(guard, interval).addToSnapshot(snapshot, _component.getClock().getSystemTime()); + snapshot.reset(0); + _manager.getMetricSnapshot(guard, interval).addToSnapshot( + snapshot, vespalib::count_s(_component.getClock().getSystemTime().time_since_epoch())); vespalib::asciistream json; vespalib::JsonStream stream(json); |