Skip to content

Commit 2235ad5

Browse files
Tensorstore Teamcopybara-github
authored andcommitted
No public description
PiperOrigin-RevId: 816135540 Change-Id: I77d22640e9956049d1f74294cd0d4828b38b2275
1 parent c089441 commit 2235ad5

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

tensorstore/transaction.cc

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -94,7 +94,7 @@ void TransactionState::NoMoreCommitReferences() {
9494

9595
TransactionState::OpenPtr TransactionState::AcquireImplicitOpenPtr() {
9696
assert(implicit_transaction_);
97-
absl::MutexLock lock(&mutex_);
97+
absl::MutexLock lock(mutex_);
9898
if (commit_state_ >= kCommitStarted) {
9999
return {};
100100
}
@@ -154,7 +154,7 @@ Result<TransactionState::OpenPtr> TransactionState::AcquireOpenPtrOrError() {
154154
}
155155

156156
TransactionState::OpenPtr TransactionState::AcquireOpenPtr() {
157-
absl::MutexLock lock(&mutex_);
157+
absl::MutexLock lock(mutex_);
158158
assert(commit_reference_count_.load() != 0);
159159
if (commit_state_ == kAborted || commit_state_ == kCommitStarted) {
160160
return {};
@@ -164,7 +164,7 @@ TransactionState::OpenPtr TransactionState::AcquireOpenPtr() {
164164

165165
void TransactionState::RequestCommit() {
166166
{
167-
absl::MutexLock lock(&mutex_);
167+
absl::MutexLock lock(mutex_);
168168
if (commit_state_ != kOpen) return;
169169
if (open_reference_count_.load(std::memory_order_relaxed) != 0) {
170170
// A thread is not permitted to increase `open_reference_count_` from 0
@@ -380,7 +380,7 @@ void TransactionState::Barrier() {
380380
if (atomic()) {
381381
return;
382382
}
383-
absl::MutexLock lock(&mutex_);
383+
absl::MutexLock lock(mutex_);
384384
if (commit_state_ == kCommitStarted || commit_state_ == kAborted) {
385385
return;
386386
}
@@ -397,7 +397,7 @@ size_t TransactionState::phase() {
397397
if (atomic()) {
398398
return 0;
399399
}
400-
absl::MutexLock lock(&mutex_);
400+
absl::MutexLock lock(mutex_);
401401
assert(commit_state_ != kCommitStarted && commit_state_ != kAborted);
402402
return phase_;
403403
}
@@ -512,7 +512,7 @@ void TransactionState::NoMoreWeakReferences() { delete this; }
512512
void TransactionState::NoMoreOpenReferences() {
513513
bool abort;
514514
{
515-
absl::MutexLock lock(&mutex_);
515+
absl::MutexLock lock(mutex_);
516516
if (open_reference_count_.load(std::memory_order_relaxed) != 0) {
517517
// Another open handle was created concurrently.
518518
return;

0 commit comments

Comments
 (0)