From d9da18414a1e558223a164f1448ffed704f4576c Mon Sep 17 00:00:00 2001 From: hai007 Date: Tue, 27 Apr 2021 11:29:13 -0700 Subject: [PATCH] Internal change PiperOrigin-RevId: 370725774 --- cpp/platform/public/pending_job_registry.cc | 2 +- cpp/platform/public/pending_job_registry.h | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/cpp/platform/public/pending_job_registry.cc b/cpp/platform/public/pending_job_registry.cc index f4edd1a1..e4858e4f 100644 --- a/cpp/platform/public/pending_job_registry.cc +++ b/cpp/platform/public/pending_job_registry.cc @@ -63,9 +63,9 @@ void PendingJobRegistry::RemoveRunningJob(const std::string& name, void PendingJobRegistry::ListJobs() { auto current_time = SystemClock::ElapsedRealtime(); + MutexLock lock(&mutex_); if (current_time - list_jobs_time_ < kMinReportInterval) return; - MutexLock lock(&mutex_); for (auto& job : pending_jobs_) { auto age = current_time - job.second; if (age >= kReportPendingJobsOlderThan) { diff --git a/cpp/platform/public/pending_job_registry.h b/cpp/platform/public/pending_job_registry.h index c90f3d3c..8b251cb7 100644 --- a/cpp/platform/public/pending_job_registry.h +++ b/cpp/platform/public/pending_job_registry.h @@ -46,7 +46,7 @@ class PendingJobRegistry { ABSL_GUARDED_BY(mutex_); absl::flat_hash_map running_jobs_ ABSL_GUARDED_BY(mutex_); - absl::Time list_jobs_time_ = absl::UnixEpoch(); + absl::Time list_jobs_time_ ABSL_GUARDED_BY(mutex_) = absl::UnixEpoch(); }; } // namespace nearby