Skip to content

Commit 9f913f8

Browse files
Tensorstore Teamcopybara-github
authored andcommitted
No public description
PiperOrigin-RevId: 816154153 Change-Id: I8b7c95875418a79ff531027aa4920b300bb8e154
1 parent a1663a3 commit 9f913f8

File tree

1 file changed

+3
-3
lines changed

1 file changed

+3
-3
lines changed

tensorstore/kvstore/kvstack/kvstack_key_value_store.cc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -476,12 +476,12 @@ struct KvStackListState final
476476
~KvStackListState() { execution::set_stopping(receiver_); }
477477

478478
void SetCancel(AnyCancelReceiver cancel) {
479-
absl::MutexLock lock(&mutex_);
479+
absl::MutexLock lock(mutex_);
480480
cancel_ = std::move(cancel);
481481
}
482482

483483
void DoCancel() {
484-
absl::MutexLock lock(&mutex_);
484+
absl::MutexLock lock(mutex_);
485485
if (cancel_) (*cancel_)();
486486
cancel_ = std::nullopt;
487487
pos_ = ranges_.size();
@@ -524,7 +524,7 @@ struct KvStackListState final
524524
static void StartNextRange(internal::IntrusivePtr<KvStackListState> state) {
525525
size_t idx;
526526
{
527-
absl::MutexLock lock(&state->mutex_);
527+
absl::MutexLock lock(state->mutex_);
528528
state->cancel_ = std::nullopt;
529529
idx = state->pos_.fetch_add(1);
530530
}

0 commit comments

Comments
 (0)