Skip to content
Snippets Groups Projects
Commit 8f3addcc authored by Craig Tiller's avatar Craig Tiller
Browse files

Propagate workqueue from resolver --> lb_policy

parent 36c86e2a
No related branches found
No related tags found
No related merge requests found
...@@ -146,8 +146,10 @@ static void dns_on_resolved(void *arg, grpc_resolved_addresses *addresses) { ...@@ -146,8 +146,10 @@ static void dns_on_resolved(void *arg, grpc_resolved_addresses *addresses) {
subchannels[i] = grpc_subchannel_factory_create_subchannel( subchannels[i] = grpc_subchannel_factory_create_subchannel(
r->subchannel_factory, &args); r->subchannel_factory, &args);
} }
memset(&lb_policy_args, 0, sizeof(lb_policy_args));
lb_policy_args.subchannels = subchannels; lb_policy_args.subchannels = subchannels;
lb_policy_args.num_subchannels = addresses->naddrs; lb_policy_args.num_subchannels = addresses->naddrs;
lb_policy_args.workqueue = r->workqueue;
lb_policy = grpc_lb_policy_create(r->lb_policy_name, &lb_policy_args); lb_policy = grpc_lb_policy_create(r->lb_policy_name, &lb_policy_args);
grpc_client_config_set_lb_policy(config, lb_policy); grpc_client_config_set_lb_policy(config, lb_policy);
GRPC_LB_POLICY_UNREF(lb_policy, "construction"); GRPC_LB_POLICY_UNREF(lb_policy, "construction");
......
...@@ -137,8 +137,10 @@ static void sockaddr_maybe_finish_next_locked(sockaddr_resolver *r) { ...@@ -137,8 +137,10 @@ static void sockaddr_maybe_finish_next_locked(sockaddr_resolver *r) {
subchannels[i] = grpc_subchannel_factory_create_subchannel( subchannels[i] = grpc_subchannel_factory_create_subchannel(
r->subchannel_factory, &args); r->subchannel_factory, &args);
} }
memset(&lb_policy_args, 0, sizeof(lb_policy_args));
lb_policy_args.subchannels = subchannels; lb_policy_args.subchannels = subchannels;
lb_policy_args.num_subchannels = r->num_addrs; lb_policy_args.num_subchannels = r->num_addrs;
lb_policy_args.workqueue = r->workqueue;
lb_policy = lb_policy =
grpc_lb_policy_create(r->lb_policy_name, &lb_policy_args); grpc_lb_policy_create(r->lb_policy_name, &lb_policy_args);
gpr_free(subchannels); gpr_free(subchannels);
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment