aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/restricted/abseil-cpp-tstring/y_absl/synchronization/notification.cc
diff options
context:
space:
mode:
authoranastasy888 <anastasy888@yandex-team.ru>2022-02-10 16:45:55 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:55 +0300
commit3a7a498715ef1b66f5054455421b845e45e3a653 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /contrib/restricted/abseil-cpp-tstring/y_absl/synchronization/notification.cc
parent49f765d71da452ea93138a25559dfa68dd76c7f3 (diff)
downloadydb-3a7a498715ef1b66f5054455421b845e45e3a653.tar.gz
Restoring authorship annotation for <anastasy888@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'contrib/restricted/abseil-cpp-tstring/y_absl/synchronization/notification.cc')
-rw-r--r--contrib/restricted/abseil-cpp-tstring/y_absl/synchronization/notification.cc134
1 files changed, 67 insertions, 67 deletions
diff --git a/contrib/restricted/abseil-cpp-tstring/y_absl/synchronization/notification.cc b/contrib/restricted/abseil-cpp-tstring/y_absl/synchronization/notification.cc
index 639343b099..0b5c5a5e48 100644
--- a/contrib/restricted/abseil-cpp-tstring/y_absl/synchronization/notification.cc
+++ b/contrib/restricted/abseil-cpp-tstring/y_absl/synchronization/notification.cc
@@ -1,78 +1,78 @@
-// Copyright 2017 The Abseil Authors.
-//
-// 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
-//
-// https://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.
-
+// Copyright 2017 The Abseil Authors.
+//
+// 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
+//
+// https://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 "y_absl/synchronization/notification.h"
-
-#include <atomic>
-
+
+#include <atomic>
+
#include "y_absl/base/attributes.h"
#include "y_absl/base/internal/raw_logging.h"
#include "y_absl/synchronization/mutex.h"
#include "y_absl/time/time.h"
-
+
namespace y_absl {
ABSL_NAMESPACE_BEGIN
-
-void Notification::Notify() {
- MutexLock l(&this->mutex_);
-
-#ifndef NDEBUG
- if (ABSL_PREDICT_FALSE(notified_yet_.load(std::memory_order_relaxed))) {
- ABSL_RAW_LOG(
- FATAL,
- "Notify() method called more than once for Notification object %p",
- static_cast<void *>(this));
- }
-#endif
-
- notified_yet_.store(true, std::memory_order_release);
-}
-
-Notification::~Notification() {
- // Make sure that the thread running Notify() exits before the object is
- // destructed.
- MutexLock l(&this->mutex_);
-}
-
-void Notification::WaitForNotification() const {
- if (!HasBeenNotifiedInternal(&this->notified_yet_)) {
- this->mutex_.LockWhen(Condition(&HasBeenNotifiedInternal,
- &this->notified_yet_));
- this->mutex_.Unlock();
- }
-}
-
-bool Notification::WaitForNotificationWithTimeout(
+
+void Notification::Notify() {
+ MutexLock l(&this->mutex_);
+
+#ifndef NDEBUG
+ if (ABSL_PREDICT_FALSE(notified_yet_.load(std::memory_order_relaxed))) {
+ ABSL_RAW_LOG(
+ FATAL,
+ "Notify() method called more than once for Notification object %p",
+ static_cast<void *>(this));
+ }
+#endif
+
+ notified_yet_.store(true, std::memory_order_release);
+}
+
+Notification::~Notification() {
+ // Make sure that the thread running Notify() exits before the object is
+ // destructed.
+ MutexLock l(&this->mutex_);
+}
+
+void Notification::WaitForNotification() const {
+ if (!HasBeenNotifiedInternal(&this->notified_yet_)) {
+ this->mutex_.LockWhen(Condition(&HasBeenNotifiedInternal,
+ &this->notified_yet_));
+ this->mutex_.Unlock();
+ }
+}
+
+bool Notification::WaitForNotificationWithTimeout(
y_absl::Duration timeout) const {
- bool notified = HasBeenNotifiedInternal(&this->notified_yet_);
- if (!notified) {
- notified = this->mutex_.LockWhenWithTimeout(
- Condition(&HasBeenNotifiedInternal, &this->notified_yet_), timeout);
- this->mutex_.Unlock();
- }
- return notified;
-}
-
+ bool notified = HasBeenNotifiedInternal(&this->notified_yet_);
+ if (!notified) {
+ notified = this->mutex_.LockWhenWithTimeout(
+ Condition(&HasBeenNotifiedInternal, &this->notified_yet_), timeout);
+ this->mutex_.Unlock();
+ }
+ return notified;
+}
+
bool Notification::WaitForNotificationWithDeadline(y_absl::Time deadline) const {
- bool notified = HasBeenNotifiedInternal(&this->notified_yet_);
- if (!notified) {
- notified = this->mutex_.LockWhenWithDeadline(
- Condition(&HasBeenNotifiedInternal, &this->notified_yet_), deadline);
- this->mutex_.Unlock();
- }
- return notified;
-}
-
+ bool notified = HasBeenNotifiedInternal(&this->notified_yet_);
+ if (!notified) {
+ notified = this->mutex_.LockWhenWithDeadline(
+ Condition(&HasBeenNotifiedInternal, &this->notified_yet_), deadline);
+ this->mutex_.Unlock();
+ }
+ return notified;
+}
+
ABSL_NAMESPACE_END
} // namespace y_absl