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

Automated Code Change

Browse Source 
PiperOrigin-RevId: 876848243
This commit is contained in:
hai007
2026-02-28 20:22:56 -08:00
committed by Copybara-Service
parent 079b5b94e9
commit 622b4eca8b
1 changed files with 6 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
internal/platform/cancellation_flag.cc
+6 -6
View File
@@ -28,7 +28,7 @@ CancellationFlag::CancellationFlag(bool cancelled) {
}
CancellationFlag::~CancellationFlag() {
absl::MutexLock lock(mutex_.get());
absl::MutexLock lock(*mutex_.get());
listeners_.clear();
}
@@ -40,7 +40,7 @@ void CancellationFlag::Cancel() {
absl::flat_hash_set<CancelListener *> listeners;
{
absl::MutexLock lock(mutex_.get());
absl::MutexLock lock(*mutex_.get());
if (cancelled_) {
// Someone already cancelled. Return immediately.
return;
@@ -62,14 +62,14 @@ void CancellationFlag::Uncancel() {
}
{
absl::MutexLock lock(mutex_.get());
absl::MutexLock lock(*mutex_.get());
assert(cancelled_);
cancelled_ = false;
}
}
bool CancellationFlag::Cancelled() const {
absl::MutexLock lock(mutex_.get());
absl::MutexLock lock(*mutex_.get());
// Return false as no-op if feature flag is not enabled.
if (!FeatureFlags::GetInstance().GetFlags().enable_cancellation_flag) {
@@ -80,13 +80,13 @@ bool CancellationFlag::Cancelled() const {
}
void CancellationFlag::RegisterOnCancelListener(CancelListener *listener) {
absl::MutexLock lock(mutex_.get());
absl::MutexLock lock(*mutex_.get());
listeners_.emplace(listener);
}
void CancellationFlag::UnregisterOnCancelListener(CancelListener *listener) {
absl::MutexLock lock(mutex_.get());
absl::MutexLock lock(*mutex_.get());
listeners_.erase(listener);
}