mirror of
https://github.com/kidfromjupiter/nearby.git
synced 2026-09-14 14:46:12 -04:00
Automated Code Change
PiperOrigin-RevId: 877067723
This commit is contained in:
@@ -22,30 +22,30 @@
|
||||
namespace nearby {
|
||||
|
||||
FakeClock::~FakeClock() {
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
observers_.clear();
|
||||
}
|
||||
|
||||
absl::Time FakeClock::Now() const {
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
return now_;
|
||||
}
|
||||
|
||||
void FakeClock::AddObserver(absl::string_view name,
|
||||
std::function<void()> observer) {
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
observers_.emplace(name, std::move(observer));
|
||||
}
|
||||
|
||||
void FakeClock::RemoveObserver(absl::string_view name) {
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
observers_.erase(name);
|
||||
}
|
||||
|
||||
void FakeClock::FastForward(absl::Duration duration) {
|
||||
std::vector<std::string> timer_callback_ids;
|
||||
{
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
now_ += duration;
|
||||
for (const auto& observer : observers_) {
|
||||
timer_callback_ids.push_back(observer.first);
|
||||
@@ -59,7 +59,7 @@ void FakeClock::FastForward(absl::Duration duration) {
|
||||
std::function<void()> callback;
|
||||
|
||||
{
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
is_alive_timer = observers_.contains(timer_callback_id);
|
||||
if (!is_alive_timer) {
|
||||
continue;
|
||||
@@ -72,12 +72,12 @@ void FakeClock::FastForward(absl::Duration duration) {
|
||||
}
|
||||
|
||||
int FakeClock::GetObserversCount() {
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
return observers_.size();
|
||||
}
|
||||
|
||||
void FakeClock::Reset() {
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
return observers_.clear();
|
||||
}
|
||||
|
||||
|
||||
@@ -30,12 +30,12 @@ namespace nearby {
|
||||
FakeTaskRunner::~FakeTaskRunner() { Shutdown(); }
|
||||
|
||||
void FakeTaskRunner::Shutdown() {
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
task_executor_->Shutdown();
|
||||
}
|
||||
|
||||
bool FakeTaskRunner::PostTask(absl::AnyInvocable<void()> task) {
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
task_executor_->Execute([task = std::move(task)]() mutable {
|
||||
task();
|
||||
});
|
||||
@@ -44,7 +44,7 @@ bool FakeTaskRunner::PostTask(absl::AnyInvocable<void()> task) {
|
||||
|
||||
bool FakeTaskRunner::PostDelayedTask(absl::Duration delay,
|
||||
absl::AnyInvocable<void()> task) {
|
||||
absl::MutexLock lock(&mutex_);
|
||||
absl::MutexLock lock(mutex_);
|
||||
std::unique_ptr<Timer> timer = std::make_unique<FakeTimer>(clock_);
|
||||
Timer* timer_ptr = timer.get();
|
||||
timers_.push_back(std::move(timer));
|
||||
|
||||
Reference in New Issue
Block a user