No public description

PiperOrigin-RevId: 819129327
Change-Id: I9b30bb6c39efed8191a585c533b76ebb12e28834

Author: Tensorstore Team

tensorstore/kvstore/gcs_http/gcs_key_value_store.cc

@@ -359,7 +359,7 @@ class GcsKeyValueStore
 
   // Returns the Auth header for a GCS request.
   Result<std::optional<std::string>> GetAuthHeader() {
-    absl::MutexLock lock(&auth_provider_mutex_);
+    absl::MutexLock lock(auth_provider_mutex_);
     if (!auth_provider_) {
       auto result = GetSharedGoogleAuthProvider(transport_);
       if (!result.ok() && absl::IsNotFound(result.status())) {
@@ -488,7 +488,7 @@ void AddUniqueQueryParameterToDisableCaching(std::string& url) {
   };
   static RandomState random_state;
   uint64_t uuid[2];
-  absl::MutexLock lock(&random_state.mutex);
+  absl::MutexLock lock(random_state.mutex);
   for (auto& x : uuid) {
     x = absl::Uniform<uint64_t>(random_state.gen);
   }

tensorstore/kvstore/gcs_http/gcs_key_value_store_test.cc

@@ -574,7 +574,7 @@ TEST(GcsKeyValueStoreTest, DeleteRangeCancellation) {
 class MyConcurrentMockTransport : public MyMockTransport {
  public:
   size_t reset() {
-    absl::MutexLock lock(&concurrent_request_mutex_);
+    absl::MutexLock lock(concurrent_request_mutex_);
     cur_concurrent_requests_ = 0;
     return std::exchange(max_concurrent_requests_, 0);
   }
@@ -594,7 +594,7 @@ class MyConcurrentMockTransport : public MyMockTransport {
     }
 
     {
-      absl::MutexLock lock(&concurrent_request_mutex_);
+      absl::MutexLock lock(concurrent_request_mutex_);
       ++cur_concurrent_requests_;
       max_concurrent_requests_ =
           std::max(max_concurrent_requests_, cur_concurrent_requests_);
@@ -604,7 +604,7 @@ class MyConcurrentMockTransport : public MyMockTransport {
     auto op = tensorstore::PromiseFuturePair<HttpResponse>::Make();
     ScheduleAt(absl::Now() + absl::Milliseconds(5),
                [this, r = request, o = std::move(options), response_handler] {
-                 absl::MutexLock lock(&concurrent_request_mutex_);
+                 absl::MutexLock lock(concurrent_request_mutex_);
                  --cur_concurrent_requests_;
                  MyMockTransport::IssueRequestWithHandler(r, std::move(o),
                                                           response_handler);
@@ -659,7 +659,7 @@ TEST(GcsKeyValueStoreTest, Concurrency) {
 class MyRateLimitedMockTransport : public MyMockTransport {
  public:
   std::tuple<absl::Time, absl::Time, size_t> reset() {
-    absl::MutexLock l(&request_timing_mutex_);
+    absl::MutexLock l(request_timing_mutex_);
     return {min_time_, max_time_, std::exchange(count_, 0)};
   }
 
@@ -676,7 +676,7 @@ class MyRateLimitedMockTransport : public MyMockTransport {
 
     // Measure the inter-request interval on non-auth requests.
     {
-      absl::MutexLock l(&request_timing_mutex_);
+      absl::MutexLock l(request_timing_mutex_);
       max_time_ = absl::Now();
       if (count_++ == 0) {
         min_time_ = max_time_;

tensorstore/kvstore/gcs_http/gcs_mock.cc

@@ -140,7 +140,7 @@ GCSMockStorageBucket::Match(const HttpRequest& request, absl::Cord payload) {
     return {};
   }
 
-  absl::MutexLock l(&mutex_);
+  absl::MutexLock l(mutex_);
 
   // https://cloud.google.com/storage/docs/request-rate
   // GCS can "randomly" return an HTTP 429.

tensorstore/kvstore/gcs_http/shared_auth_provider.cc

@@ -42,7 +42,7 @@ Result<std::shared_ptr<AuthProvider>> GetSharedGoogleAuthProvider(
     std::shared_ptr<HttpTransport> transport) {
   static auto* g = new SharedAuthProvider();
 
-  absl::MutexLock l(&g->mu_);
+  absl::MutexLock l(g->mu_);
   // Return the cached auth provider if the transport is the same; otherwise
   // update the transport and create a new auth provider.
   if (std::shared_ptr<HttpTransport> cached_transport = g->transport_.lock()) {