Skip to content

Commit cd81f2d

Browse files
committed
Address review comments
1 parent 36745c7 commit cd81f2d

1 file changed

Lines changed: 15 additions & 22 deletions

File tree

google/cloud/storage/internal/async/connection_tracing.cc

Lines changed: 15 additions & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -71,9 +71,8 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
7171
std::shared_ptr<storage::ObjectDescriptorConnection>> {
7272
auto result = f.get();
7373
internal::DetachOTelContext(oc);
74-
if (!result) {
74+
if (!result)
7575
return internal::EndSpan(*span, std::move(result).status());
76-
}
7776
return MakeTracingObjectDescriptorConnection(std::move(span),
7877
*std::move(result));
7978
});
@@ -89,9 +88,7 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
8988
-> StatusOr<std::unique_ptr<storage::AsyncReaderConnection>> {
9089
auto reader = f.get();
9190
internal::DetachOTelContext(oc);
92-
if (!reader) {
93-
return internal::EndSpan(*span, std::move(reader).status());
94-
}
91+
if (!reader) return internal::EndSpan(*span, std::move(reader).status());
9592
return MakeTracingReaderConnection(std::move(span), *std::move(reader));
9693
};
9794
return impl_->ReadObject(std::move(p)).then(std::move(wrap));
@@ -119,9 +116,7 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
119116
-> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
120117
auto w = f.get();
121118
internal::DetachOTelContext(oc);
122-
if (!w) {
123-
return internal::EndSpan(*span, std::move(w).status());
124-
}
119+
if (!w) return internal::EndSpan(*span, std::move(w).status());
125120
return MakeTracingWriterConnection(span, *std::move(w));
126121
});
127122
}
@@ -139,9 +134,7 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
139134
-> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
140135
auto w = f.get();
141136
internal::DetachOTelContext(oc);
142-
if (!w) {
143-
return internal::EndSpan(*span, std::move(w).status());
144-
}
137+
if (!w) return internal::EndSpan(*span, std::move(w).status());
145138
return MakeTracingWriterConnection(span, *std::move(w));
146139
});
147140
}
@@ -159,9 +152,7 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
159152
-> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
160153
auto w = f.get();
161154
internal::DetachOTelContext(oc);
162-
if (!w) {
163-
return internal::EndSpan(*span, std::move(w).status());
164-
}
155+
if (!w) return internal::EndSpan(*span, std::move(w).status());
165156
return MakeTracingWriterConnection(span, *std::move(w));
166157
});
167158
}
@@ -179,9 +170,7 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
179170
-> StatusOr<std::unique_ptr<storage::AsyncWriterConnection>> {
180171
auto w = f.get();
181172
internal::DetachOTelContext(oc);
182-
if (!w) {
183-
return internal::EndSpan(*span, std::move(w).status());
184-
}
173+
if (!w) return internal::EndSpan(*span, std::move(w).status());
185174
return MakeTracingWriterConnection(span, *std::move(w));
186175
});
187176
}
@@ -253,7 +242,7 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
253242
span = std::move(span), cache = cache_, bucket_name,
254243
options](future<StatusOr<google::storage::v2::Bucket>> f)
255244
-> StatusOr<google::storage::v2::Bucket> {
256-
auto result = f.get();
245+
StatusOr<google::storage::v2::Bucket> result = f.get();
257246
internal::DetachOTelContext(oc);
258247
if (result.ok()) {
259248
EnrichSpan(*span, options, *result, bucket_name, *cache);
@@ -265,6 +254,9 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
265254
}
266255

267256
private:
257+
static constexpr char kProjectBucketPrefix[] = "projects/_/buckets/";
258+
static constexpr char kGlobalLocation[] = "global";
259+
268260
BucketMetadataCache& cache() const { return *cache_; }
269261

270262
void MaybeTriggerBackgroundFetch(Options const& options,
@@ -277,13 +269,14 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
277269
google::storage::v2::GetBucketRequest request;
278270
auto const normalized_bucket_name =
279271
BucketMetadataCache::NormalizeBucketName(bucket_name);
280-
request.set_name("projects/_/buckets/" + normalized_bucket_name);
272+
request.set_name(std::string(kProjectBucketPrefix) +
273+
normalized_bucket_name);
281274
GetBucketParams params{std::move(request), options};
282275

283276
impl_->GetBucket(std::move(params))
284277
.then([cache = cache_, bucket_name, guard = std::move(guard)](
285278
future<StatusOr<google::storage::v2::Bucket>> f) {
286-
auto metadata = f.get();
279+
StatusOr<google::storage::v2::Bucket> metadata = f.get();
287280
if (metadata.ok()) {
288281
BucketCacheEntry entry = BucketCacheEntry::FromLocation(
289282
metadata->project() + "/buckets/" +
@@ -293,9 +286,9 @@ class AsyncConnectionTracing : public storage::AsyncConnection {
293286
} else if (metadata.status().code() ==
294287
StatusCode::kPermissionDenied) {
295288
BucketCacheEntry entry{
296-
"projects/_/buckets/" +
289+
std::string(kProjectBucketPrefix) +
297290
BucketMetadataCache::NormalizeBucketName(bucket_name),
298-
"global"};
291+
kGlobalLocation};
299292
cache->Put(bucket_name, std::move(entry));
300293
}
301294
});

0 commit comments

Comments
 (0)