Use AddChannelArgument method

pull/11118/head
Muxi Yan 8 years ago
parent b1a80c751d
commit f5b3db9c22
  1. 1
      include/grpc++/server_builder.h
  2. 12
      src/cpp/server/server_builder.cc

@ -231,7 +231,6 @@ class ServerBuilder {
std::vector<std::unique_ptr<ServerBuilderOption>> options_;
std::vector<std::unique_ptr<NamedService>> services_;
std::vector<Port> ports_;
std::vector<const char *> enabled_workarounds_;
SyncServerSettings sync_server_settings_;

@ -199,10 +199,6 @@ std::unique_ptr<Server> ServerBuilder::BuildAndStart() {
args.SetInt(GRPC_ARG_MAX_SEND_MESSAGE_LENGTH, max_send_message_size_);
}
for (auto workaround : enabled_workarounds_) {
args.SetInt(workaround, 1);
}
args.SetInt(GRPC_COMPRESSION_CHANNEL_ENABLED_ALGORITHMS_BITSET,
enabled_compression_algorithms_bitset_);
if (maybe_default_compression_level_.is_set) {
@ -366,13 +362,11 @@ void ServerBuilder::InternalAddPluginFactory(
ServerBuilder& ServerBuilder::EnableWorkaround(uint32_t id) {
switch (id) {
case GRPC_WORKAROUND_ID_CRONET_COMPRESSION:
enabled_workarounds_.push_back(GRPC_ARG_WORKAROUND_CRONET_COMPRESSION);
break;
return AddChannelArgument(GRPC_ARG_WORKAROUND_CRONET_COMPRESSION, 1);
default:
gpr_log(GPR_ERROR, "Workaround %u is not exist or obsolete.", id);
gpr_log(GPR_ERROR, "Workaround %u does not exist or obsolete.", id);
return *this;
}
return *this;
}
} // namespace grpc

Loading…
Cancel
Save