TySS-Dev/nearby
1
0
Fork 0
mirror of https://github.com/kidfromjupiter/nearby.git synced 2026-09-15 07:06:11 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add more logging to scheduled tasks.

Browse Source 
PiperOrigin-RevId: 738969815
This commit is contained in:
Francis Tsui
2025-03-20 15:59:50 -07:00
committed by Copybara-Service
parent cc4a13ac26
commit 12675ff9fa
2 changed files with 19 additions and 11 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/platform/monitored_runnable.cc
+17 -9
View File
@@ -14,11 +14,15 @@
#include "internal/platform/monitored_runnable.h"
#include <string>
#include <utility>
// TODO: Support thread status
#include "absl/strings/str_cat.h"
#include "absl/time/time.h"
#include "internal/platform/implementation/system_clock.h"
#include "internal/platform/logging.h"
#include "internal/platform/pending_job_registry.h"
#include "internal/platform/runnable.h"
#define SET_THREAD_STATUS(NAME)
@@ -29,29 +33,33 @@ absl::Duration kMinReportedTaskDuration = absl::Seconds(10);
} // namespace
MonitoredRunnable::MonitoredRunnable(Runnable&& runnable)
: runnable_{std::move(runnable)} {}
: MonitoredRunnable(absl::StrCat("Task_", absl::Hex(this)),
std::move(runnable)) {}
MonitoredRunnable::MonitoredRunnable(const std::string& name,
Runnable&& runnable)
: name_{name}, runnable_{std::move(runnable)} {
VLOG(1) << "Task: \"" << name_ << "\" scheduled";
PendingJobRegistry::GetInstance().AddPendingJob(name_, post_time_);
}
void MonitoredRunnable::operator()() {
SET_THREAD_STATUS(name_.c_str());
auto start_time = SystemClock::ElapsedRealtime();
auto start_delay = start_time - post_time_;
absl::Time start_time = SystemClock::ElapsedRealtime();
absl::Duration start_delay = start_time - post_time_;
if (start_delay >= kMinReportedStartDelay) {
NEARBY_LOGS(INFO) << "Task: \"" << name_ << "\" started after "
<< absl::ToInt64Seconds(start_delay) << " seconds";
LOG(INFO) << "Task: \"" << name_ << "\" started after " << start_delay;
} else {
VLOG(1) << "Task: \"" << name_ << "\" started after " << start_delay;
}
PendingJobRegistry::GetInstance().RemovePendingJob(name_, post_time_);
PendingJobRegistry::GetInstance().AddRunningJob(name_, post_time_);
runnable_();
auto task_duration = SystemClock::ElapsedRealtime() - start_time;
absl::Duration task_duration = SystemClock::ElapsedRealtime() - start_time;
if (task_duration >= kMinReportedTaskDuration) {
NEARBY_LOGS(INFO) << "Task: \"" << name_ << "\" finished after "
<< absl::ToInt64Seconds(task_duration) << " seconds";
LOG(INFO) << "Task: \"" << name_ << "\" finished after " << task_duration;
} else {
VLOG(1) << "Task: \"" << name_ << "\" finished after " << task_duration;
}
PendingJobRegistry::GetInstance().RemoveRunningJob(name_, post_time_);
PendingJobRegistry::GetInstance().ListJobs();
internal/platform/monitored_runnable.h
+2 -2
View File
@@ -18,8 +18,8 @@
#include <string>
#include "absl/time/time.h"
#include "internal/platform/implementation/system_clock.h"
#include "internal/platform/runnable.h"
#include "internal/platform/system_clock.h"
namespace nearby {
@@ -37,7 +37,7 @@ class MonitoredRunnable {
private:
const std::string name_;
Runnable runnable_;
absl::Time post_time_ = SystemClock::ElapsedRealtime();
const absl::Time post_time_ = SystemClock::ElapsedRealtime();
};
} // namespace nearby