diff options
author | arcadia-devtools <arcadia-devtools@yandex-team.ru> | 2022-03-15 21:33:41 +0300 |
---|---|---|
committer | arcadia-devtools <arcadia-devtools@yandex-team.ru> | 2022-03-15 21:33:41 +0300 |
commit | 3dd665b514943f69657b593eb51af90b99b1206b (patch) | |
tree | 0eb633e628bb1fe6c639574b1184d43def7c0a73 /contrib/libs/grpc/src/cpp/server/server_builder.cc | |
parent | a68afc731202027f105bc5723ee11788017c29e2 (diff) | |
download | ydb-3dd665b514943f69657b593eb51af90b99b1206b.tar.gz |
intermediate changes
ref:953ca886ec160075b38c0f3614de029b423f0a9e
Diffstat (limited to 'contrib/libs/grpc/src/cpp/server/server_builder.cc')
-rw-r--r-- | contrib/libs/grpc/src/cpp/server/server_builder.cc | 23 |
1 files changed, 18 insertions, 5 deletions
diff --git a/contrib/libs/grpc/src/cpp/server/server_builder.cc b/contrib/libs/grpc/src/cpp/server/server_builder.cc index 0cc00b365ff..502d4f20ae6 100644 --- a/contrib/libs/grpc/src/cpp/server/server_builder.cc +++ b/contrib/libs/grpc/src/cpp/server/server_builder.cc @@ -83,9 +83,9 @@ ServerBuilder& ServerBuilder::RegisterService(Service* service) { return *this; } -ServerBuilder& ServerBuilder::RegisterService(const TString& addr, +ServerBuilder& ServerBuilder::RegisterService(const TString& host, Service* service) { - services_.emplace_back(new NamedService(addr, service)); + services_.emplace_back(new NamedService(host, service)); return *this; } @@ -95,7 +95,7 @@ ServerBuilder& ServerBuilder::RegisterAsyncGenericService( gpr_log(GPR_ERROR, "Adding multiple generic services is unsupported for now. " "Dropping the service %p", - (void*)service); + service); } else { generic_service_ = service; } @@ -122,7 +122,7 @@ ServerBuilder& ServerBuilder::experimental_type::RegisterCallbackGenericService( gpr_log(GPR_ERROR, "Adding multiple generic services is unsupported for now. " "Dropping the service %p", - (void*)service); + service); } else { builder_->callback_generic_service_ = service; } @@ -130,6 +130,12 @@ ServerBuilder& ServerBuilder::experimental_type::RegisterCallbackGenericService( } #endif +ServerBuilder& ServerBuilder::experimental_type::SetContextAllocator( + std::unique_ptr<grpc::ContextAllocator> context_allocator) { + builder_->context_allocator_ = std::move(context_allocator); + return *builder_; +} + std::unique_ptr<grpc::experimental::ExternalConnectionAcceptor> ServerBuilder::experimental_type::AddExternalConnectionAcceptor( experimental_type::ExternalConnectionType type, @@ -331,7 +337,7 @@ std::unique_ptr<grpc::Server> ServerBuilder::BuildAndStart() { std::unique_ptr<grpc::Server> server(new grpc::Server( &args, sync_server_cqs, sync_server_settings_.min_pollers, sync_server_settings_.max_pollers, sync_server_settings_.cq_timeout_msec, - std::move(acceptors_), resource_quota_, + std::move(acceptors_), server_config_fetcher_, resource_quota_, std::move(interceptor_creators_))); ServerInitializer* initializer = server->initializer(); @@ -369,6 +375,13 @@ std::unique_ptr<grpc::Server> ServerBuilder::BuildAndStart() { return nullptr; } +#ifdef GRPC_CALLBACK_API_NONEXPERIMENTAL + server->RegisterContextAllocator(std::move(context_allocator_)); +#else + server->experimental_registration()->RegisterContextAllocator( + std::move(context_allocator_)); +#endif + for (const auto& value : services_) { if (!server->RegisterService(value->host.get(), value->service)) { return nullptr; |