diff options
| author |  Craig Tiller <ctiller@google.com> | 2015-09-16 16:15:47 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2015-09-16 16:15:47 -0700 |
| commit | 3cd6a5158d388c6ae2d07bc78951c986dc4f41ea (patch) | |
| tree | 3c8abac6cf7c3e7b8be75ad57d31a617e4f46c7b /src/core/client_config/resolvers | |
| parent | 8f3addcc4d8822b68f3c2367353dac38eb56c38c (diff) | |
Getting stuff working
Diffstat (limited to 'src/core/client_config/resolvers')
| -rw-r--r-- | src/core/client_config/resolvers/dns_resolver.c | 4 | ||||
| -rw-r--r-- | src/core/client_config/resolvers/sockaddr_resolver.c | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/src/core/client_config/resolvers/dns_resolver.c b/src/core/client_config/resolvers/dns_resolver.c index cbc96ca992..66a8c9f99d 100644 --- a/src/core/client_config/resolvers/dns_resolver.c +++ b/src/core/client_config/resolvers/dns_resolver.c @@ -197,7 +197,7 @@ static void dns_destroy(grpc_resolver *gr) { grpc_client_config_unref(r->resolved_config); } grpc_subchannel_factory_unref(r->subchannel_factory); - grpc_workqueue_unref(r->workqueue); + GRPC_WORKQUEUE_UNREF(r->workqueue, "dns"); gpr_free(r->name); gpr_free(r->default_port); gpr_free(r->lb_policy_name); @@ -227,7 +227,7 @@ static grpc_resolver *dns_create(grpc_resolver_args *args, r->subchannel_factory = args->subchannel_factory; grpc_subchannel_factory_ref(r->subchannel_factory); r->workqueue = args->workqueue; - grpc_workqueue_ref(r->workqueue); + GRPC_WORKQUEUE_REF(r->workqueue, "dns"); r->lb_policy_name = gpr_strdup(lb_policy_name); return &r->base; } diff --git a/src/core/client_config/resolvers/sockaddr_resolver.c b/src/core/client_config/resolvers/sockaddr_resolver.c index cb3b6070f2..abfb7b8569 100644 --- a/src/core/client_config/resolvers/sockaddr_resolver.c +++ b/src/core/client_config/resolvers/sockaddr_resolver.c @@ -157,7 +157,7 @@ static void sockaddr_destroy(grpc_resolver *gr) { sockaddr_resolver *r = (sockaddr_resolver *)gr; gpr_mu_destroy(&r->mu); grpc_subchannel_factory_unref(r->subchannel_factory); - grpc_workqueue_unref(r->workqueue); + GRPC_WORKQUEUE_UNREF(r->workqueue, "sockaddr"); gpr_free(r->addrs); gpr_free(r->addrs_len); gpr_free(r->lb_policy_name); @@ -331,7 +331,7 @@ static grpc_resolver *sockaddr_create( r->subchannel_factory = args->subchannel_factory; grpc_subchannel_factory_ref(r->subchannel_factory); r->workqueue = args->workqueue; - grpc_workqueue_ref(r->workqueue); + GRPC_WORKQUEUE_REF(r->workqueue, "sockaddr"); r->lb_policy_name = gpr_strdup(lb_policy_name); return &r->base; |