No public description

PiperOrigin-RevId: 816103011
Change-Id: Ic88188ff52d6a2a3fd430eb1333617ee2b18ab00

Author: Tensorstore Team

tensorstore/kvstore/ocdbt/io/coalesce_kvstore.cc

@@ -212,7 +212,7 @@ Future<kvstore::ReadResult> CoalesceKvStoreDriver::Read(Key key,
                                                         ReadOptions options) {
   internal::IntrusivePtr<PendingRead> state_ptr;
   {
-    absl::MutexLock l(&mu_);
+    absl::MutexLock l(mu_);
     auto it = pending_.find(std::string_view(key));
     if (it != pending_.end()) {
       /// This key is already "reserved" by a PendingRead object, so enqueue
@@ -313,7 +313,7 @@ void CoalesceKvStoreDriver::StartNextRead(
     internal::IntrusivePtr<PendingRead> state_ptr) {
   std::vector<PendingRead::Op> pending;
   {
-    absl::MutexLock l(&mu_);
+    absl::MutexLock l(mu_);
     if (state_ptr->pending_ops.empty()) {
       // No buffered reads for this key; remove the "reservation" and exit.
       pending_.erase(state_ptr->key);

tensorstore/kvstore/ocdbt/io/io_handle_impl.cc

@@ -113,7 +113,7 @@ class IoHandleImpl : public IoHandle {
       return absl::OkStatus();
     }
 
-    absl::MutexLock lock(&manifest_mutex_);
+    absl::MutexLock lock(manifest_mutex_);
     // Only validate the new manifest if it is not the same as the existing
     // manifest.
     if (new_manifest_with_time.manifest !=
@@ -146,7 +146,7 @@ class IoHandleImpl : public IoHandle {
       return absl::OkStatus();
     }
 
-    absl::MutexLock lock(&manifest_mutex_);
+    absl::MutexLock lock(manifest_mutex_);
     if (new_manifest_with_time.manifest != cached_numbered_manifest_.manifest) {
       auto* new_manifest = new_manifest_with_time.manifest.get();
       if (new_manifest) {