diff options
| author |  Craig Tiller <ctiller@google.com> | 2017-04-04 07:25:31 -0700 |
|---|---|---|
| committer |  GitHub <noreply@github.com> | 2017-04-04 07:25:31 -0700 |
| commit | 82c7fec59c41c7d0be23550169a46848489ba68c (patch) | |
| tree | b9f1ec081212be1824ed819d4e5d300682a46cc8 /test/core/end2end/tests | |
| parent | 14af85e8d2359bbd28afe06a5690a6004991e65b (diff) | |
| parent | 659030f0a4815638de807c8c3482238f9f413daa (diff) | |
Merge pull request #9949 from ctiller/new_transport_op
Convert stream ops to a control + payload structure
Diffstat (limited to 'test/core/end2end/tests')
| -rw-r--r-- | test/core/end2end/tests/filter_causes_close.c | 15 |
1 files changed, 8 insertions, 7 deletions
diff --git a/test/core/end2end/tests/filter_causes_close.c b/test/core/end2end/tests/filter_causes_close.c index e6b02eaeee..62bf20809c 100644 --- a/test/core/end2end/tests/filter_causes_close.c +++ b/test/core/end2end/tests/filter_causes_close.c @@ -216,13 +216,14 @@ static void recv_im_ready(grpc_exec_ctx *exec_ctx, void *arg, GRPC_STATUS_PERMISSION_DENIED)); } -static void start_transport_stream_op(grpc_exec_ctx *exec_ctx, - grpc_call_element *elem, - grpc_transport_stream_op *op) { +static void start_transport_stream_op_batch( + grpc_exec_ctx *exec_ctx, grpc_call_element *elem, + grpc_transport_stream_op_batch *op) { call_data *calld = elem->call_data; - if (op->recv_initial_metadata != NULL) { - calld->recv_im_ready = op->recv_initial_metadata_ready; - op->recv_initial_metadata_ready = + if (op->recv_initial_metadata) { + calld->recv_im_ready = + op->payload->recv_initial_metadata.recv_initial_metadata_ready; + op->payload->recv_initial_metadata.recv_initial_metadata_ready = grpc_closure_create(recv_im_ready, elem, grpc_schedule_on_exec_ctx); } grpc_call_next_op(exec_ctx, elem, op); @@ -248,7 +249,7 @@ static void destroy_channel_elem(grpc_exec_ctx *exec_ctx, grpc_channel_element *elem) {} static const grpc_channel_filter test_filter = { - start_transport_stream_op, + start_transport_stream_op_batch, grpc_channel_next_op, sizeof(call_data), init_call_elem, |