diff options
author | Craig Tiller <ctiller@google.com> | 2016-01-07 12:45:32 -0800 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2016-01-07 12:45:32 -0800 |
commit | 15f383c6cc74e94cdc7223552824135acab00e7f (patch) | |
tree | 41628fbe5d4b031a7a5b30aa6eda6152dff32ffb /test/cpp | |
parent | 0850640213266afc64c1f6f7e10728037129f117 (diff) |
Exploratory refactoring for mixed sync/async methods on the same C++ service
Diffstat (limited to 'test/cpp')
-rw-r--r-- | test/cpp/end2end/async_end2end_test.cc | 12 | ||||
-rw-r--r-- | test/cpp/qps/server_async.cc | 2 |
2 files changed, 2 insertions, 12 deletions
diff --git a/test/cpp/end2end/async_end2end_test.cc b/test/cpp/end2end/async_end2end_test.cc index af0b7fdb57..3acbfd55c2 100644 --- a/test/cpp/end2end/async_end2end_test.cc +++ b/test/cpp/end2end/async_end2end_test.cc @@ -180,21 +180,11 @@ class AsyncEnd2endTest : public ::testing::TestWithParam<bool> { int port = grpc_pick_unused_port_or_die(); server_address_ << "localhost:" << port; - // It is currently unsupported to mix sync and async services - // in the same server, so first test that (for coverage) - ServerBuilder build_bad; - build_bad.AddListeningPort(server_address_.str(), - grpc::InsecureServerCredentials()); - build_bad.RegisterAsyncService(&service_); - grpc::cpp::test::util::TestService::Service sync_service; - build_bad.RegisterService(&sync_service); - GPR_ASSERT(build_bad.BuildAndStart() == nullptr); - // Setup server ServerBuilder builder; builder.AddListeningPort(server_address_.str(), grpc::InsecureServerCredentials()); - builder.RegisterAsyncService(&service_); + builder.RegisterService(&service_); cq_ = builder.AddCompletionQueue(); server_ = builder.BuildAndStart(); } diff --git a/test/cpp/qps/server_async.cc b/test/cpp/qps/server_async.cc index c151918ce4..3fa8fc77f4 100644 --- a/test/cpp/qps/server_async.cc +++ b/test/cpp/qps/server_async.cc @@ -67,7 +67,7 @@ class AsyncQpsServerTest : public Server { Server::CreateServerCredentials(config)); gpr_free(server_address); - builder.RegisterAsyncService(&async_service_); + builder.RegisterService(&async_service_); for (int i = 0; i < config.async_server_threads(); i++) { srv_cqs_.emplace_back(builder.AddCompletionQueue()); } |