diff options
author | 2015-09-10 11:06:50 -0700 | |
---|---|---|
committer | 2015-09-10 11:06:50 -0700 | |
commit | 3924fcb1c0d0c2ae9fd2995da4ce79e903766fef (patch) | |
tree | 6847af64027cb16f477d5d5732fcee23cb54a559 /src/core/client_config/resolvers/sockaddr_resolver.c | |
parent | fe7a6368fc154e291dd91b002e22bca4970ef00a (diff) | |
parent | c7705c7c4701fc1cdc512fb0867b0fd699d69b2e (diff) |
Merge remote-tracking branch 'origin/lb_registry' into rr_with_registry
Diffstat (limited to 'src/core/client_config/resolvers/sockaddr_resolver.c')
-rw-r--r-- | src/core/client_config/resolvers/sockaddr_resolver.c | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/src/core/client_config/resolvers/sockaddr_resolver.c b/src/core/client_config/resolvers/sockaddr_resolver.c index 1610893428..88dd5d624b 100644 --- a/src/core/client_config/resolvers/sockaddr_resolver.c +++ b/src/core/client_config/resolvers/sockaddr_resolver.c @@ -121,6 +121,7 @@ static void sockaddr_next(grpc_resolver *resolver, static void sockaddr_maybe_finish_next_locked(sockaddr_resolver *r) { grpc_client_config *cfg; grpc_lb_policy *lb_policy; + grpc_lb_policy_args lb_policy_args; grpc_subchannel **subchannels; grpc_subchannel_args args; @@ -135,8 +136,10 @@ static void sockaddr_maybe_finish_next_locked(sockaddr_resolver *r) { subchannels[i] = grpc_subchannel_factory_create_subchannel( r->subchannel_factory, &args); } + lb_policy_args.subchannels = subchannels; + lb_policy_args.num_subchannels = r->num_addrs; lb_policy = - grpc_lb_policy_create(r->lb_policy_name, subchannels, r->num_addrs); + grpc_lb_policy_create(r->lb_policy_name, &lb_policy_args); gpr_free(subchannels); grpc_client_config_set_lb_policy(cfg, lb_policy); GRPC_LB_POLICY_UNREF(lb_policy, "unix"); |