@@ -69,7 +69,7 @@ void DeadlineRegistration::SetDeadline(absl::Time deadline) {
6969void DeadlineRegistration::ExecuteBlockingSyscall (
7070 absl::FunctionRef<void ()> blocking_fn) {
7171 {
72- absl::MutexLock lock (& data_->mutex );
72+ absl::MutexLock lock (data_->mutex );
7373 data_->tid = util::Syscall (__NR_gettid);
7474 if (data_->notification_attempt > 0 || data_->deadline <= absl::Now ()) {
7575 return ;
@@ -78,7 +78,7 @@ void DeadlineRegistration::ExecuteBlockingSyscall(
7878 }
7979 blocking_fn ();
8080 {
81- absl::MutexLock lock (& data_->mutex );
81+ absl::MutexLock lock (data_->mutex );
8282 data_->in_blocking_fn = false ;
8383 }
8484}
@@ -90,11 +90,11 @@ DeadlineManager::DeadlineManager(absl::string_view name) {
9090
9191DeadlineManager::~DeadlineManager () {
9292 {
93- absl::MutexLock lock (& registration_mutex_);
93+ absl::MutexLock lock (registration_mutex_);
9494 CHECK_EQ (registered_deadlines_, 0 );
9595 }
9696 {
97- absl::MutexLock lock (& queue_mutex_);
97+ absl::MutexLock lock (queue_mutex_);
9898 cancelled_ = true ;
9999 }
100100 if (thread_.IsJoinable ()) {
@@ -106,9 +106,9 @@ void DeadlineManager::SignalHandler(int signal) {}
106106
107107void DeadlineManager::AdjustDeadline (DeadlineRegistration& registration,
108108 absl::Time deadline) {
109- absl::MutexLock lock (& queue_mutex_);
109+ absl::MutexLock lock (queue_mutex_);
110110 queue_.erase (registration.data_ .get ());
111- absl::MutexLock data_lock (& registration.data_ ->mutex );
111+ absl::MutexLock data_lock (registration.data_ ->mutex );
112112 registration.data_ ->notification_attempt = 0 ;
113113 registration.data_ ->deadline = RoundUpTo (deadline, kResolution );
114114 if (deadline != absl::InfiniteFuture ()) {
@@ -161,7 +161,7 @@ void DeadlineManager::Run() {
161161 return (!queue_.empty () && next_deadline != (*queue_.begin ())->deadline ) ||
162162 cancelled_;
163163 };
164- absl::MutexLock lock (& queue_mutex_);
164+ absl::MutexLock lock (queue_mutex_);
165165 while (!cancelled_) {
166166 next_deadline = absl::InfiniteFuture ();
167167 if (!queue_.empty ()) {
@@ -175,7 +175,7 @@ void DeadlineManager::Run() {
175175 while (!queue_.empty () && (*queue_.begin ())->deadline <= next_deadline) {
176176 DeadlineRegistration::Data* entry = *queue_.begin ();
177177 queue_.erase (queue_.begin ());
178- absl::MutexLock lock (& entry->mutex );
178+ absl::MutexLock lock (entry->mutex );
179179 if (++entry->notification_attempt > kFailedNotificationsThreshold ) {
180180 VerifySignalHandler ();
181181 }
0 commit comments