diff options
author | 2015-07-08 21:46:52 -0700 | |
---|---|---|
committer | 2015-07-08 21:46:52 -0700 | |
commit | d130bdd176810c49f4e1d584f648cdbc46801d7b (patch) | |
tree | c5f9c35bd8d5be6cb012ea37ccd71f5fa0440cf5 /src/core/surface/server.c | |
parent | 7dbb4fc05ded49169c46bf25ba2aee5024a0f2fd (diff) | |
parent | c1f7e315021778bbc997af5e7ac785d6b8619240 (diff) |
Merge pull request #2308 from ctiller/metadata-wants-to-be-debugged
Add metadata refcount debug helpers
Diffstat (limited to 'src/core/surface/server.c')
-rw-r--r-- | src/core/surface/server.c | 16 |
1 files changed, 8 insertions, 8 deletions
diff --git a/src/core/surface/server.c b/src/core/surface/server.c index 341ca2942c..de8c405237 100644 --- a/src/core/surface/server.c +++ b/src/core/surface/server.c @@ -504,10 +504,10 @@ static grpc_mdelem *server_filter(void *user_data, grpc_mdelem *md) { channel_data *chand = elem->channel_data; call_data *calld = elem->call_data; if (md->key == chand->path_key) { - calld->path = grpc_mdstr_ref(md->value); + calld->path = GRPC_MDSTR_REF(md->value); return NULL; } else if (md->key == chand->authority_key) { - calld->host = grpc_mdstr_ref(md->value); + calld->host = GRPC_MDSTR_REF(md->value); return NULL; } return md; @@ -643,10 +643,10 @@ static void destroy_call_elem(grpc_call_element *elem) { gpr_mu_unlock(&chand->server->mu_call); if (calld->host) { - grpc_mdstr_unref(calld->host); + GRPC_MDSTR_UNREF(calld->host); } if (calld->path) { - grpc_mdstr_unref(calld->path); + GRPC_MDSTR_UNREF(calld->path); } server_unref(chand->server); @@ -676,10 +676,10 @@ static void destroy_channel_elem(grpc_channel_element *elem) { if (chand->registered_methods) { for (i = 0; i < chand->registered_method_slots; i++) { if (chand->registered_methods[i].method) { - grpc_mdstr_unref(chand->registered_methods[i].method); + GRPC_MDSTR_UNREF(chand->registered_methods[i].method); } if (chand->registered_methods[i].host) { - grpc_mdstr_unref(chand->registered_methods[i].host); + GRPC_MDSTR_UNREF(chand->registered_methods[i].host); } } gpr_free(chand->registered_methods); @@ -691,8 +691,8 @@ static void destroy_channel_elem(grpc_channel_element *elem) { chand->next = chand->prev = chand; maybe_finish_shutdown(chand->server); gpr_mu_unlock(&chand->server->mu_global); - grpc_mdstr_unref(chand->path_key); - grpc_mdstr_unref(chand->authority_key); + GRPC_MDSTR_UNREF(chand->path_key); + GRPC_MDSTR_UNREF(chand->authority_key); server_unref(chand->server); } } |