Skip to content
This repository was archived by the owner on Dec 8, 2021. It is now read-only.

Commit eb9fa03

Browse files
authored
refactor: Migrate away from grpc_utils namespace (#1266)
* refactor: Migrate away from `grpc_utils` namespace * qualify uses of `MakeStatusFromRpcError`
1 parent ee80c16 commit eb9fa03

13 files changed

+53
-57
lines changed
-221 Bytes
Binary file not shown.

google/cloud/spanner/BUILD

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -43,7 +43,7 @@ cc_library(
4343
],
4444
deps = [
4545
"@com_github_googleapis_google_cloud_cpp_common//google/cloud:google_cloud_cpp_common",
46-
"@com_github_googleapis_google_cloud_cpp_common//google/cloud/grpc_utils:google_cloud_cpp_grpc_utils",
46+
"@com_github_googleapis_google_cloud_cpp_common//google/cloud:google_cloud_cpp_grpc_utils",
4747
"@com_google_googleapis//:spanner_protos",
4848
],
4949
)

google/cloud/spanner/benchmarks/multiple_rows_cpu_benchmark.cc

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
#include "google/cloud/spanner/internal/spanner_stub.h"
1919
#include "google/cloud/spanner/testing/pick_random_instance.h"
2020
#include "google/cloud/spanner/testing/random_database_name.h"
21-
#include "google/cloud/grpc_utils/grpc_error_delegate.h"
21+
#include "google/cloud/grpc_error_delegate.h"
2222
#include "google/cloud/internal/random.h"
2323
#include <google/spanner/v1/result_set.pb.h>
2424
#include <algorithm>
@@ -710,8 +710,7 @@ class ReadExperiment : public Experiment {
710710
timer.Stop();
711711
samples.push_back(RowCpuSample{
712712
client_count, thread_count, true, row_count, timer.elapsed_time(),
713-
timer.cpu_time(),
714-
google::cloud::grpc_utils::MakeStatusFromRpcError(final)});
713+
timer.cpu_time(), google::cloud::MakeStatusFromRpcError(final)});
715714
}
716715
return samples;
717716
}
@@ -934,8 +933,7 @@ class SelectExperiment : public Experiment {
934933
timer.Stop();
935934
samples.push_back(RowCpuSample{
936935
client_count, thread_count, true, row_count, timer.elapsed_time(),
937-
timer.cpu_time(),
938-
google::cloud::grpc_utils::MakeStatusFromRpcError(final)});
936+
timer.cpu_time(), google::cloud::MakeStatusFromRpcError(final)});
939937
}
940938
return samples;
941939
}

google/cloud/spanner/connection_options.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -82,7 +82,7 @@ grpc::ChannelArguments ConnectionOptions::CreateChannelArguments() const {
8282
}
8383

8484
ConnectionOptions& ConnectionOptions::DisableBackgroundThreads(
85-
google::cloud::grpc_utils::CompletionQueue const& cq) {
85+
google::cloud::CompletionQueue const& cq) {
8686
background_threads_factory_ = [cq] {
8787
return google::cloud::internal::make_unique<
8888
google::cloud::internal::CustomerSuppliedBackgroundThreads>(cq);

google/cloud/spanner/connection_options.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -18,7 +18,7 @@
1818
#include "google/cloud/spanner/tracing_options.h"
1919
#include "google/cloud/spanner/version.h"
2020
#include "google/cloud/background_threads.h"
21-
#include "google/cloud/grpc_utils/completion_queue.h"
21+
#include "google/cloud/completion_queue.h"
2222
#include "google/cloud/status_or.h"
2323
#include <google/spanner/admin/database/v1/spanner_database_admin.grpc.pb.h>
2424
#include <google/spanner/v1/spanner.pb.h>
@@ -188,7 +188,7 @@ class ConnectionOptions {
188188
* `CompletionQueue::Run()`.
189189
*/
190190
ConnectionOptions& DisableBackgroundThreads(
191-
google::cloud::grpc_utils::CompletionQueue const& cq);
191+
google::cloud::CompletionQueue const& cq);
192192

193193
using BackgroundThreadsFactory =
194194
std::function<std::unique_ptr<BackgroundThreads>()>;

google/cloud/spanner/connection_options_test.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -170,7 +170,7 @@ TEST(ConnectionOptionsTest, CreateChannelArgumentsWithChannelPool) {
170170
}
171171

172172
TEST(ConnectionOptionsTest, CustomBackgroundThreads) {
173-
grpc_utils::CompletionQueue cq;
173+
CompletionQueue cq;
174174

175175
auto options = ConnectionOptions(grpc::InsecureChannelCredentials())
176176
.DisableBackgroundThreads(cq);

google/cloud/spanner/database_admin_client.cc

Lines changed: 0 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,6 @@
1313
// limitations under the License.
1414

1515
#include "google/cloud/spanner/database_admin_client.h"
16-
#include "google/cloud/grpc_utils/grpc_error_delegate.h"
1716
#include <algorithm>
1817

1918
namespace google {

google/cloud/spanner/internal/connection_impl.cc

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,7 +20,7 @@
2020
#include "google/cloud/spanner/internal/status_utils.h"
2121
#include "google/cloud/spanner/query_partition.h"
2222
#include "google/cloud/spanner/read_partition.h"
23-
#include "google/cloud/grpc_utils/grpc_error_delegate.h"
23+
#include "google/cloud/grpc_error_delegate.h"
2424
#include "google/cloud/internal/make_unique.h"
2525
#include <limits>
2626

@@ -51,7 +51,7 @@ class DefaultPartialResultSetReader : public PartialResultSetReader {
5151
}
5252

5353
Status Finish() override {
54-
return grpc_utils::MakeStatusFromRpcError(reader_->Finish());
54+
return google::cloud::MakeStatusFromRpcError(reader_->Finish());
5555
}
5656

5757
private:
@@ -667,7 +667,7 @@ StatusOr<BatchDmlResult> ConnectionImpl::ExecuteBatchDmlImpl(
667667
}
668668

669669
BatchDmlResult result;
670-
result.status = grpc_utils::MakeStatusFromRpcError(response->status());
670+
result.status = google::cloud::MakeStatusFromRpcError(response->status());
671671
for (auto const& result_set : response->result_sets()) {
672672
result.stats.push_back({result_set.stats().row_count_exact()});
673673
}

google/cloud/spanner/internal/database_admin_stub.cc

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
#include "google/cloud/spanner/internal/database_admin_stub.h"
1616
#include "google/cloud/spanner/internal/database_admin_logging.h"
1717
#include "google/cloud/spanner/internal/database_admin_metadata.h"
18-
#include "google/cloud/grpc_utils/grpc_error_delegate.h"
18+
#include "google/cloud/grpc_error_delegate.h"
1919
#include "google/cloud/log.h"
2020
#include <google/longrunning/operations.grpc.pb.h>
2121

@@ -46,7 +46,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
4646
grpc::Status status =
4747
database_admin_->CreateDatabase(&client_context, request, &response);
4848
if (!status.ok()) {
49-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
49+
return google::cloud::MakeStatusFromRpcError(status);
5050
}
5151
return response;
5252
}
@@ -58,7 +58,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
5858
auto status =
5959
database_admin_->GetDatabase(&client_context, request, &response);
6060
if (!status.ok()) {
61-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
61+
return google::cloud::MakeStatusFromRpcError(status);
6262
}
6363
return response;
6464
}
@@ -70,7 +70,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
7070
auto status =
7171
database_admin_->GetDatabaseDdl(&client_context, request, &response);
7272
if (!status.ok()) {
73-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
73+
return google::cloud::MakeStatusFromRpcError(status);
7474
}
7575
return response;
7676
}
@@ -83,7 +83,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
8383
grpc::Status status =
8484
database_admin_->UpdateDatabaseDdl(&context, request, &response);
8585
if (!status.ok()) {
86-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
86+
return google::cloud::MakeStatusFromRpcError(status);
8787
}
8888
return response;
8989
}
@@ -94,7 +94,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
9494
grpc::Status status =
9595
database_admin_->DropDatabase(&client_context, request, &response);
9696
if (!status.ok()) {
97-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
97+
return google::cloud::MakeStatusFromRpcError(status);
9898
}
9999
return google::cloud::Status();
100100
}
@@ -106,7 +106,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
106106
auto status =
107107
database_admin_->ListDatabases(&client_context, request, &response);
108108
if (!status.ok()) {
109-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
109+
return google::cloud::MakeStatusFromRpcError(status);
110110
}
111111
return response;
112112
}
@@ -118,7 +118,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
118118
auto status =
119119
database_admin_->GetIamPolicy(&client_context, request, &response);
120120
if (!status.ok()) {
121-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
121+
return google::cloud::MakeStatusFromRpcError(status);
122122
}
123123
return response;
124124
}
@@ -130,7 +130,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
130130
auto status =
131131
database_admin_->SetIamPolicy(&client_context, request, &response);
132132
if (!status.ok()) {
133-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
133+
return google::cloud::MakeStatusFromRpcError(status);
134134
}
135135
return response;
136136
}
@@ -142,7 +142,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
142142
auto status = database_admin_->TestIamPermissions(&client_context, request,
143143
&response);
144144
if (!status.ok()) {
145-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
145+
return google::cloud::MakeStatusFromRpcError(status);
146146
}
147147
return response;
148148
}
@@ -154,7 +154,7 @@ class DefaultDatabaseAdminStub : public DatabaseAdminStub {
154154
grpc::Status status =
155155
operations_->GetOperation(&client_context, request, &response);
156156
if (!status.ok()) {
157-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
157+
return google::cloud::MakeStatusFromRpcError(status);
158158
}
159159
return response;
160160
}

google/cloud/spanner/internal/instance_admin_stub.cc

Lines changed: 12 additions & 12 deletions
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
#include "google/cloud/spanner/internal/instance_admin_stub.h"
1616
#include "google/cloud/spanner/internal/instance_admin_logging.h"
1717
#include "google/cloud/spanner/internal/instance_admin_metadata.h"
18-
#include "google/cloud/grpc_utils/grpc_error_delegate.h"
18+
#include "google/cloud/grpc_error_delegate.h"
1919
#include "google/cloud/log.h"
2020
#include <google/longrunning/operations.grpc.pb.h>
2121

@@ -46,7 +46,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
4646
gcsa::Instance response;
4747
auto status = instance_admin_->GetInstance(&context, request, &response);
4848
if (!status.ok()) {
49-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
49+
return google::cloud::MakeStatusFromRpcError(status);
5050
}
5151
return response;
5252
}
@@ -58,7 +58,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
5858
grpc::Status status =
5959
instance_admin_->CreateInstance(&context, request, &response);
6060
if (!status.ok()) {
61-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
61+
return google::cloud::MakeStatusFromRpcError(status);
6262
}
6363
return response;
6464
}
@@ -70,7 +70,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
7070
grpc::Status status =
7171
instance_admin_->UpdateInstance(&context, request, &response);
7272
if (!status.ok()) {
73-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
73+
return google::cloud::MakeStatusFromRpcError(status);
7474
}
7575
return response;
7676
}
@@ -81,7 +81,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
8181
grpc::Status status =
8282
instance_admin_->DeleteInstance(&context, request, &response);
8383
if (!status.ok()) {
84-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
84+
return google::cloud::MakeStatusFromRpcError(status);
8585
}
8686
return google::cloud::Status();
8787
}
@@ -93,7 +93,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
9393
auto status =
9494
instance_admin_->GetInstanceConfig(&context, request, &response);
9595
if (!status.ok()) {
96-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
96+
return google::cloud::MakeStatusFromRpcError(status);
9797
}
9898
return response;
9999
}
@@ -105,7 +105,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
105105
auto status =
106106
instance_admin_->ListInstanceConfigs(&context, request, &response);
107107
if (!status.ok()) {
108-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
108+
return google::cloud::MakeStatusFromRpcError(status);
109109
}
110110
return response;
111111
}
@@ -116,7 +116,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
116116
gcsa::ListInstancesResponse response;
117117
auto status = instance_admin_->ListInstances(&context, request, &response);
118118
if (!status.ok()) {
119-
return grpc_utils::MakeStatusFromRpcError(status);
119+
return google::cloud::MakeStatusFromRpcError(status);
120120
}
121121
return response;
122122
}
@@ -127,7 +127,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
127127
giam::Policy response;
128128
auto status = instance_admin_->GetIamPolicy(&context, request, &response);
129129
if (!status.ok()) {
130-
return grpc_utils::MakeStatusFromRpcError(status);
130+
return google::cloud::MakeStatusFromRpcError(status);
131131
}
132132
return response;
133133
}
@@ -138,7 +138,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
138138
giam::Policy response;
139139
auto status = instance_admin_->SetIamPolicy(&context, request, &response);
140140
if (!status.ok()) {
141-
return grpc_utils::MakeStatusFromRpcError(status);
141+
return google::cloud::MakeStatusFromRpcError(status);
142142
}
143143
return response;
144144
}
@@ -150,7 +150,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
150150
auto status =
151151
instance_admin_->TestIamPermissions(&context, request, &response);
152152
if (!status.ok()) {
153-
return grpc_utils::MakeStatusFromRpcError(status);
153+
return google::cloud::MakeStatusFromRpcError(status);
154154
}
155155
return response;
156156
}
@@ -162,7 +162,7 @@ class DefaultInstanceAdminStub : public InstanceAdminStub {
162162
grpc::Status status =
163163
operations_->GetOperation(&client_context, request, &response);
164164
if (!status.ok()) {
165-
return google::cloud::grpc_utils::MakeStatusFromRpcError(status);
165+
return google::cloud::MakeStatusFromRpcError(status);
166166
}
167167
return response;
168168
}

0 commit comments

Comments
 (0)