diff options
author | Craig Tiller <ctiller@google.com> | 2016-11-23 11:13:46 -0800 |
---|---|---|
committer | Craig Tiller <ctiller@google.com> | 2016-11-23 11:13:46 -0800 |
commit | de7b4676e936ed9b71e99bd0edaaf025593b2c3a (patch) | |
tree | 24d352af7e3eb4f839abcdc58300ae375169ceab /src/core/lib/surface | |
parent | f269eddd57d5b9c9e4be90c08c927077a82c3a43 (diff) |
Fix metadata batch removal ref counting
Diffstat (limited to 'src/core/lib/surface')
-rw-r--r-- | src/core/lib/surface/call.c | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/src/core/lib/surface/call.c b/src/core/lib/surface/call.c index d5e90ccdda..7a7c19ad8b 100644 --- a/src/core/lib/surface/call.c +++ b/src/core/lib/surface/call.c @@ -866,7 +866,7 @@ static void recv_common_filter(grpc_exec_ctx *exec_ctx, grpc_call *call, GPR_TIMER_BEGIN("status", 0); set_status_code(call, STATUS_FROM_WIRE, decode_status(b->idx.named.grpc_status->md)); - grpc_metadata_batch_remove(b, b->idx.named.grpc_status); + grpc_metadata_batch_remove(exec_ctx, b, b->idx.named.grpc_status); GPR_TIMER_END("status", 0); } @@ -875,7 +875,7 @@ static void recv_common_filter(grpc_exec_ctx *exec_ctx, grpc_call *call, set_status_details( exec_ctx, call, STATUS_FROM_WIRE, grpc_slice_ref_internal(GRPC_MDVALUE(b->idx.named.grpc_message->md))); - grpc_metadata_batch_remove(b, b->idx.named.grpc_message); + grpc_metadata_batch_remove(exec_ctx, b, b->idx.named.grpc_message); GPR_TIMER_END("status-details", 0); } } @@ -910,14 +910,14 @@ static void recv_initial_filter(grpc_exec_ctx *exec_ctx, grpc_call *call, set_incoming_compression_algorithm( call, decode_compression(b->idx.named.grpc_encoding->md)); GPR_TIMER_END("incoming_compression_algorithm", 0); - grpc_metadata_batch_remove(b, b->idx.named.grpc_encoding); + grpc_metadata_batch_remove(exec_ctx, b, b->idx.named.grpc_encoding); } if (b->idx.named.grpc_accept_encoding != NULL) { GPR_TIMER_BEGIN("encodings_accepted_by_peer", 0); set_encodings_accepted_by_peer(exec_ctx, call, b->idx.named.grpc_accept_encoding->md); - grpc_metadata_batch_remove(b, b->idx.named.grpc_accept_encoding); + grpc_metadata_batch_remove(exec_ctx, b, b->idx.named.grpc_accept_encoding); GPR_TIMER_END("encodings_accepted_by_peer", 0); } |