diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-04-04 08:29:43 -0700 |
|---|---|---|
| committer | Craig Tiller <ctiller@google.com> | 2017-04-04 08:29:43 -0700 |
| commit | 61666f5557b343fb77d2a250dcdbede253a54d88 (patch) | |
| tree | 817040b0fef4c1a9b44259d00a9e5cc6166c4ff2 /src/core/lib/surface/lame_client.c | |
| parent | 6696894e6a3e02170a560e0abcea1b4e948d583f (diff) | |
| parent | 0df90f049ad8ee0da6e47bbe89650fcf9bee25e2 (diff) | |
Merge branch 'lazy-batches' into lazy-parent
Diffstat (limited to 'src/core/lib/surface/lame_client.c')
| -rw-r--r-- | src/core/lib/surface/lame_client.c | 10 |
1 files changed, 5 insertions, 5 deletions
diff --git a/src/core/lib/surface/lame_client.c b/src/core/lib/surface/lame_client.c index 18b4f3691b..82428c42c0 100644 --- a/src/core/lib/surface/lame_client.c +++ b/src/core/lib/surface/lame_client.c @@ -80,9 +80,9 @@ static void fill_metadata(grpc_exec_ctx *exec_ctx, grpc_call_element *elem, mdb->deadline = gpr_inf_future(GPR_CLOCK_REALTIME); } -static void lame_start_transport_stream_op(grpc_exec_ctx *exec_ctx, - grpc_call_element *elem, - grpc_transport_stream_op *op) { +static void lame_start_transport_stream_op_batch( + grpc_exec_ctx *exec_ctx, grpc_call_element *elem, + grpc_transport_stream_op_batch *op) { GRPC_CALL_LOG_OP(GPR_INFO, elem, op); if (op->recv_initial_metadata) { fill_metadata(exec_ctx, elem, @@ -91,7 +91,7 @@ static void lame_start_transport_stream_op(grpc_exec_ctx *exec_ctx, fill_metadata(exec_ctx, elem, op->payload->recv_trailing_metadata.recv_trailing_metadata); } - grpc_transport_stream_op_finish_with_failure( + grpc_transport_stream_op_batch_finish_with_failure( exec_ctx, op, GRPC_ERROR_CREATE_FROM_STATIC_STRING("lame client channel")); } @@ -150,7 +150,7 @@ static void destroy_channel_elem(grpc_exec_ctx *exec_ctx, grpc_channel_element *elem) {} const grpc_channel_filter grpc_lame_filter = { - lame_start_transport_stream_op, + lame_start_transport_stream_op_batch, lame_start_transport_op, sizeof(call_data), init_call_elem, |