diff options
author | Craig Tiller <ctiller@google.com> | 2016-04-01 16:36:27 -0700 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2016-04-01 16:36:27 -0700 |
commit | 74071cdab0c9a4016c05d371fdf1ec0d772ed0b7 (patch) | |
tree | 4cd5b95b661ddcdc33729622d5fdb63be4bb4f3a /src/core/ext/resolver/zookeeper | |
parent | 92b74082811902e4ab9482a5229defd3014aad3f (diff) | |
parent | b48dda25913fbf6fcb0a7c86ecc364beb31ff43b (diff) |
Merge branch 'subchannel_factory_create_lb_channel' of github.com:dgquintas/grpc into ccmerge
Diffstat (limited to 'src/core/ext/resolver/zookeeper')
-rw-r--r-- | src/core/ext/resolver/zookeeper/zookeeper_resolver.c | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/src/core/ext/resolver/zookeeper/zookeeper_resolver.c b/src/core/ext/resolver/zookeeper/zookeeper_resolver.c index cd065bef09..898632c3cd 100644 --- a/src/core/ext/resolver/zookeeper/zookeeper_resolver.c +++ b/src/core/ext/resolver/zookeeper/zookeeper_resolver.c @@ -57,7 +57,7 @@ typedef struct { /** name to resolve */ char *name; /** subchannel factory */ - grpc_subchannel_factory *subchannel_factory; + grpc_client_channel_factory *client_channel_factory; /** load balancing policy name */ char *lb_policy_name; @@ -187,9 +187,8 @@ static void zookeeper_on_resolved(grpc_exec_ctx *exec_ctx, void *arg, if (addresses != NULL) { grpc_lb_policy_args lb_policy_args; config = grpc_client_config_create(); - lb_policy_args.addresses = addresses; - lb_policy_args.subchannel_factory = r->subchannel_factory; + lb_policy_args.client_channel_factory = r->client_channel_factory; lb_policy = grpc_lb_policy_create(exec_ctx, r->lb_policy_name, &lb_policy_args); @@ -424,7 +423,7 @@ static void zookeeper_destroy(grpc_exec_ctx *exec_ctx, grpc_resolver *gr) { if (r->resolved_config != NULL) { grpc_client_config_unref(exec_ctx, r->resolved_config); } - grpc_subchannel_factory_unref(exec_ctx, r->subchannel_factory); + grpc_client_channel_factory_unref(exec_ctx, r->client_channel_factory); gpr_free(r->name); gpr_free(r->lb_policy_name); gpr_free(r); @@ -454,8 +453,8 @@ static grpc_resolver *zookeeper_create(grpc_resolver_args *args, grpc_resolver_init(&r->base, &zookeeper_resolver_vtable); r->name = gpr_strdup(path); - r->subchannel_factory = args->subchannel_factory; - grpc_subchannel_factory_ref(r->subchannel_factory); + r->client_channel_factory = args->client_channel_factory; + grpc_client_channel_factory_ref(r->client_channel_factory); r->lb_policy_name = gpr_strdup(lb_policy_name); |