aboutsummaryrefslogtreecommitdiffhomepage
path: root/src/core/surface/server.c
diff options
context:
space:
mode:
authorGravatar Yang Gao <yangg@google.com>2015-07-08 21:46:52 -0700
committerGravatar Yang Gao <yangg@google.com>2015-07-08 21:46:52 -0700
commitd130bdd176810c49f4e1d584f648cdbc46801d7b (patch)
treec5f9c35bd8d5be6cb012ea37ccd71f5fa0440cf5 /src/core/surface/server.c
parent7dbb4fc05ded49169c46bf25ba2aee5024a0f2fd (diff)
parentc1f7e315021778bbc997af5e7ac785d6b8619240 (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.c16
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);
}
}