/*
|
* Copyright (C) 2019 The Android Open Source Project
|
*
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
* you may not use this file except in compliance with the License.
|
* You may obtain a copy of the License at
|
*
|
* http://www.apache.org/licenses/LICENSE-2.0
|
*
|
* Unless required by applicable law or agreed to in writing, software
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
* See the License for the specific language governing permissions and
|
* limitations under the License.
|
*/
|
|
#include "src/trace_processor/clock_tracker.h"
|
|
#include <algorithm>
|
|
#include "perfetto/base/logging.h"
|
#include "src/trace_processor/trace_processor_context.h"
|
#include "src/trace_processor/trace_storage.h"
|
|
namespace perfetto {
|
namespace trace_processor {
|
|
ClockTracker::ClockTracker(TraceProcessorContext* ctx) : context_(ctx) {}
|
ClockTracker::~ClockTracker() = default;
|
|
void ClockTracker::SyncClocks(ClockDomain domain,
|
int64_t clock_time_ns,
|
int64_t trace_time_ns) {
|
ClockSnapshotVector& snapshots = clocks_[domain];
|
if (!snapshots.empty()) {
|
// The trace clock (typically CLOCK_BOOTTIME) must be monotonic.
|
if (trace_time_ns <= snapshots.back().trace_time_ns) {
|
PERFETTO_ELOG("Trace time in clock snapshot is moving backwards");
|
context_->storage->IncrementStats(stats::clock_snapshot_not_monotonic);
|
return;
|
}
|
if (clock_time_ns <= snapshots.back().clock_time_ns) {
|
if (domain == ClockDomain::kMonotonic) {
|
PERFETTO_ELOG("CLOCK_MONOTONIC in clock snapshot is moving backwards");
|
context_->storage->IncrementStats(stats::clock_snapshot_not_monotonic);
|
return;
|
}
|
// This can happen in other clocks, for instance CLOCK_REALTIME if
|
// adjusting the timezone or during daylight saving. In this case the most
|
// reasonable thing we can do is obliterating all the past snapshots.
|
while (!snapshots.empty() &&
|
snapshots.back().clock_time_ns >= clock_time_ns) {
|
snapshots.pop_back();
|
}
|
}
|
}
|
snapshots.emplace_back(ClockSnapshot{clock_time_ns, trace_time_ns});
|
}
|
|
base::Optional<int64_t> ClockTracker::ToTraceTime(ClockDomain domain,
|
int64_t clock_time_ns) {
|
ClockSnapshotVector& snapshots = clocks_[domain];
|
if (snapshots.empty()) {
|
context_->storage->IncrementStats(stats::clock_sync_failure);
|
return base::nullopt;
|
}
|
static auto comparator = [](int64_t lhs, const ClockSnapshot& rhs) {
|
return lhs < rhs.clock_time_ns;
|
};
|
auto it = std::upper_bound(snapshots.begin(), snapshots.end(), clock_time_ns,
|
comparator);
|
if (it != snapshots.begin())
|
it--;
|
return it->trace_time_ns + (clock_time_ns - it->clock_time_ns);
|
}
|
|
} // namespace trace_processor
|
} // namespace perfetto
|
