X-Git-Url: http://review.tizen.org/git/?a=blobdiff_plain;f=src%2Fcore%2Fext%2Ffilters%2Fclient_channel%2Fclient_channel_plugin.cc;h=8bd41f2c7220183eb5452f53959ac0f7d95c1397;hb=2cbdc95f7308919f1c0019c7edced2f114c46703;hp=2031ab449f52f7e80ba91275211c9222fb880b4a;hpb=77d10676a117e46898d0acd327834bb27892f7aa;p=platform%2Fupstream%2Fgrpc.git diff --git a/src/core/ext/filters/client_channel/client_channel_plugin.cc b/src/core/ext/filters/client_channel/client_channel_plugin.cc index 2031ab4..8bd41f2 100644 --- a/src/core/ext/filters/client_channel/client_channel_plugin.cc +++ b/src/core/ext/filters/client_channel/client_channel_plugin.cc @@ -24,6 +24,7 @@ #include +#include "src/core/ext/filters/client_channel/backup_poller.h" #include "src/core/ext/filters/client_channel/client_channel.h" #include "src/core/ext/filters/client_channel/client_channel_channelz.h" #include "src/core/ext/filters/client_channel/global_subchannel_pool.h" @@ -32,40 +33,48 @@ #include "src/core/ext/filters/client_channel/lb_policy_registry.h" #include "src/core/ext/filters/client_channel/proxy_mapper_registry.h" #include "src/core/ext/filters/client_channel/resolver_registry.h" +#include "src/core/ext/filters/client_channel/resolver_result_parsing.h" +#include "src/core/ext/filters/client_channel/retry_service_config.h" #include "src/core/ext/filters/client_channel/retry_throttle.h" +#include "src/core/ext/filters/client_channel/service_config_parser.h" #include "src/core/lib/surface/channel_init.h" static bool append_filter(grpc_channel_stack_builder* builder, void* arg) { - const grpc_channel_args* args = - grpc_channel_stack_builder_get_channel_arguments(builder); - grpc_arg args_to_add[] = { - grpc_core::channelz::ClientChannelNode::CreateChannelArg()}; - grpc_channel_args* new_args = grpc_channel_args_copy_and_add( - args, args_to_add, GPR_ARRAY_SIZE(args_to_add)); - grpc_channel_stack_builder_set_channel_arguments(builder, new_args); - grpc_channel_args_destroy(new_args); return grpc_channel_stack_builder_append_filter( builder, static_cast(arg), nullptr, nullptr); } void grpc_client_channel_init(void) { + grpc_core::ServiceConfigParser::Init(); + grpc_core::internal::ClientChannelServiceConfigParser::Register(); + grpc_core::internal::RetryServiceConfigParser::Register(); grpc_core::LoadBalancingPolicyRegistry::Builder::InitRegistry(); grpc_core::ResolverRegistry::Builder::InitRegistry(); grpc_core::internal::ServerRetryThrottleMap::Init(); - grpc_proxy_mapper_registry_init(); - grpc_register_http_proxy_mapper(); + grpc_core::ProxyMapperRegistry::Init(); + grpc_core::RegisterHttpProxyMapper(); grpc_core::GlobalSubchannelPool::Init(); grpc_channel_init_register_stage( GRPC_CLIENT_CHANNEL, GRPC_CHANNEL_INIT_BUILTIN_PRIORITY, append_filter, - (void*)&grpc_client_channel_filter); - grpc_http_connect_register_handshaker_factory(); + const_cast( + &grpc_core::ClientChannel::kFilterVtable)); + grpc_client_channel_global_init_backup_polling(); } void grpc_client_channel_shutdown(void) { grpc_core::GlobalSubchannelPool::Shutdown(); grpc_channel_init_shutdown(); - grpc_proxy_mapper_registry_shutdown(); + grpc_core::ProxyMapperRegistry::Shutdown(); grpc_core::internal::ServerRetryThrottleMap::Shutdown(); grpc_core::ResolverRegistry::Builder::ShutdownRegistry(); grpc_core::LoadBalancingPolicyRegistry::Builder::ShutdownRegistry(); + grpc_core::ServiceConfigParser::Shutdown(); } + +namespace grpc_core { + +void BuildClientChannelConfiguration(CoreConfiguration::Builder* builder) { + RegisterHttpConnectHandshaker(builder); +} + +} // namespace grpc_core