aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/client_config/resolver.c
diff options
context:
space:
mode:
Diffstat (limited to 'src/core/client_config/resolver.c')
-rw-r--r--src/core/client_config/resolver.c26
1 files changed, 14 insertions, 12 deletions
diff --git a/src/core/client_config/resolver.c b/src/core/client_config/resolver.c
index 6a7d73c54f..eae8ec6ddf 100644
--- a/src/core/client_config/resolver.c
+++ b/src/core/client_config/resolver.c
@@ -40,8 +40,8 @@ void grpc_resolver_init(grpc_resolver *resolver,
}
#ifdef GRPC_RESOLVER_REFCOUNT_DEBUG
-void grpc_resolver_ref(grpc_resolver *resolver, const char *file, int line,
- const char *reason) {
+void grpc_resolver_ref(grpc_resolver *resolver, grpc_call_list *call_list,
+ const char *file, int line, const char *reason) {
gpr_log(file, line, GPR_LOG_SEVERITY_DEBUG, "RESOLVER:%p ref %d -> %d %s",
resolver, (int)resolver->refs.count, (int)resolver->refs.count + 1,
reason);
@@ -52,32 +52,34 @@ void grpc_resolver_ref(grpc_resolver *resolver) {
}
#ifdef GRPC_RESOLVER_REFCOUNT_DEBUG
-void grpc_resolver_unref(grpc_resolver *resolver, const char *file, int line,
- const char *reason) {
+void grpc_resolver_unref(grpc_resolver *resolver, grpc_call_list *call_list,
+ const char *file, int line, const char *reason) {
gpr_log(file, line, GPR_LOG_SEVERITY_DEBUG, "RESOLVER:%p unref %d -> %d %s",
resolver, (int)resolver->refs.count, (int)resolver->refs.count - 1,
reason);
#else
-void grpc_resolver_unref(grpc_resolver *resolver) {
+void grpc_resolver_unref(grpc_resolver *resolver, grpc_call_list *call_list) {
#endif
if (gpr_unref(&resolver->refs)) {
- resolver->vtable->destroy(resolver);
+ resolver->vtable->destroy(resolver, call_list);
}
}
-void grpc_resolver_shutdown(grpc_resolver *resolver) {
- resolver->vtable->shutdown(resolver);
+void grpc_resolver_shutdown(grpc_resolver *resolver,
+ grpc_call_list *call_list) {
+ resolver->vtable->shutdown(resolver, call_list);
}
void grpc_resolver_channel_saw_error(grpc_resolver *resolver,
struct sockaddr *failing_address,
- int failing_address_len) {
+ int failing_address_len,
+ grpc_call_list *call_list) {
resolver->vtable->channel_saw_error(resolver, failing_address,
- failing_address_len);
+ failing_address_len, call_list);
}
void grpc_resolver_next(grpc_resolver *resolver,
grpc_client_config **target_config,
- grpc_closure *on_complete) {
- resolver->vtable->next(resolver, target_config, on_complete);
+ grpc_closure *on_complete, grpc_call_list *call_list) {
+ resolver->vtable->next(resolver, target_config, on_complete, call_list);
}