| /external/grpc-grpc/src/cpp/ext/filters/census/ |
| D | client_filter.cc | 120 if (op->recv_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
121 recv_trailing_metadata_ = op->recv_trailing_metadata()->batch(); in StartTransportStreamOpBatch()
123 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in StartTransportStreamOpBatch()
124 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in StartTransportStreamOpBatch()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 869 grpc_metadata_batch recv_trailing_metadata; member
939 grpc_metadata_batch* recv_trailing_metadata; member
1139 if (batch->recv_trailing_metadata) return 5; in get_batch_index()
1329 (!batch->recv_trailing_metadata || in maybe_clear_pending_batch()
1330 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready == in maybe_clear_pending_batch()
1590 if (batch_data->batch.recv_trailing_metadata) { in batch_data_unref()
1591 grpc_metadata_batch_destroy(&retry_state->recv_trailing_metadata); in batch_data_unref()
1818 return batch->recv_trailing_metadata && in add_closure_for_recv_trailing_metadata_ready()
1819 batch->payload->recv_trailing_metadata in add_closure_for_recv_trailing_metadata_ready()
1835 &retry_state->recv_trailing_metadata, in add_closure_for_recv_trailing_metadata_ready()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 58 grpc_metadata_batch* recv_trailing_metadata; member
168 client_filter_incoming_metadata(elem, calld->recv_trailing_metadata); in recv_trailing_metadata_ready()
319 if (batch->recv_trailing_metadata) { in hc_start_transport_stream_op_batch()
321 calld->recv_trailing_metadata = in hc_start_transport_stream_op_batch()
322 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in hc_start_transport_stream_op_batch()
324 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in hc_start_transport_stream_op_batch()
325 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in hc_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | channel_filter.h | 148 op->recv_trailing_metadata in TransportStreamOpBatch()
149 ? op->payload->recv_trailing_metadata.recv_trailing_metadata in TransportStreamOpBatch()
166 MetadataBatch* recv_trailing_metadata() { in recv_trailing_metadata() function
167 return op_->recv_trailing_metadata ? &recv_trailing_metadata_ : nullptr; in recv_trailing_metadata()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | lame_client.cc | 85 } else if (op->recv_trailing_metadata) { in lame_start_transport_stream_op_batch()
87 op->payload->recv_trailing_metadata.recv_trailing_metadata); in lame_start_transport_stream_op_batch()
|
| D | call.cc | 1146 if (bctl->op.recv_trailing_metadata) { in post_batch_completion()
1785 stream_op->recv_trailing_metadata = true; in call_start_batch()
1786 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata = in call_start_batch()
1788 stream_op_payload->recv_trailing_metadata.collect_stats = in call_start_batch()
1793 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata_ready = in call_start_batch()
1815 stream_op->recv_trailing_metadata = true; in call_start_batch()
1816 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata = in call_start_batch()
1818 stream_op_payload->recv_trailing_metadata.collect_stats = in call_start_batch()
1823 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata_ready = in call_start_batch()
1869 if (stream_op->recv_trailing_metadata) { in call_start_batch()
|
| D | server.cc | 762 if (op->recv_trailing_metadata) { in server_mutate_op()
764 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in server_mutate_op()
765 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in server_mutate_op()
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.h | 156 bool recv_trailing_metadata : 1; member
224 grpc_metadata_batch* recv_trailing_metadata; member
228 } recv_trailing_metadata; member
|
| D | transport.cc | 229 if (batch->recv_trailing_metadata) {
231 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready,
|
| D | transport_op_string.cc | 109 if (op->recv_trailing_metadata) { in grpc_transport_stream_op_batch_string()
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 144 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in inject_recv_trailing_metadata_ready()
148 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in inject_recv_trailing_metadata_ready()
232 if (op->recv_trailing_metadata) { in grpc_deadline_state_client_start_transport_stream_op_batch()
328 if (op->recv_trailing_metadata) { in server_start_transport_stream_op_batch()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_call_create.cc | 637 if (op->recv_trailing_metadata) { in StartTransportStreamOp()
639 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in StartTransportStreamOp()
754 grpc_metadata_array recv_trailing_metadata; in BM_IsolatedCall_Unary() local
755 grpc_metadata_array_init(&recv_trailing_metadata); in BM_IsolatedCall_Unary()
770 ops[5].data.recv_status_on_client.trailing_metadata = &recv_trailing_metadata; in BM_IsolatedCall_Unary()
783 grpc_metadata_array_destroy(&recv_trailing_metadata); in BM_IsolatedCall_Unary()
797 grpc_metadata_array recv_trailing_metadata; in BM_IsolatedCall_StreamingSend() local
798 grpc_metadata_array_init(&recv_trailing_metadata); in BM_IsolatedCall_StreamingSend()
823 grpc_metadata_array_destroy(&recv_trailing_metadata); in BM_IsolatedCall_StreamingSend()
|
| /external/grpc-grpc/src/php/ext/grpc/ |
| D | call.c | 284 grpc_metadata_array recv_trailing_metadata; in PHP_METHOD() local
297 grpc_metadata_array_init(&recv_trailing_metadata); in PHP_METHOD()
424 &recv_trailing_metadata; in PHP_METHOD()
492 array = grpc_parse_metadata_array(&recv_trailing_metadata TSRMLS_CC); in PHP_METHOD()
495 recv_md = grpc_parse_metadata_array(&recv_trailing_metadata); in PHP_METHOD()
525 grpc_metadata_array_destroy(&recv_trailing_metadata); in PHP_METHOD()
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 504 GRPC_CLOSURE_SCHED(s->recv_trailing_md_op->payload->recv_trailing_metadata in fail_helper_locked()
652 s->recv_trailing_md_op->payload->recv_trailing_metadata in op_state_machine()
731 GRPC_CLOSURE_SCHED(s->recv_trailing_md_op->payload->recv_trailing_metadata in op_state_machine()
775 ->recv_trailing_metadata.recv_trailing_metadata, in op_state_machine()
790 s->recv_trailing_md_op->payload->recv_trailing_metadata in op_state_machine()
886 GRPC_CLOSURE_SCHED(s->recv_trailing_md_op->payload->recv_trailing_metadata in cancel_stream_locked()
950 op->recv_trailing_metadata ? " recv_trailing_metadata" : ""); in perform_stream_op()
996 op->recv_trailing_metadata)) { in perform_stream_op()
1010 if (op->recv_trailing_metadata) { in perform_stream_op()
1064 if (op->recv_trailing_metadata) { in perform_stream_op()
[all …]
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 87 if (batch->recv_trailing_metadata) return &calld->on_complete[5]; in get_state_for_batch()
115 if (batch->recv_trailing_metadata) { in con_start_transport_stream_op_batch()
119 &batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready); in con_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 209 if (batch->recv_trailing_metadata) { in auth_start_transport_stream_op_batch()
211 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in auth_start_transport_stream_op_batch()
212 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in auth_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 193 if (op->recv_trailing_metadata) { in start_transport_stream_op_batch()
195 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in start_transport_stream_op_batch()
196 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 384 if (op->recv_trailing_metadata) { in hs_mutate_op()
386 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in hs_mutate_op()
387 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in hs_mutate_op()
|
| /external/grpc-grpc/src/ruby/ext/grpc/ |
| D | rb_call.c | 619 grpc_metadata_array recv_trailing_metadata; member
635 grpc_metadata_array_init(&st->recv_trailing_metadata); in grpc_run_batch_stack_init()
660 grpc_metadata_array_destroy(&st->recv_trailing_metadata); in grpc_run_batch_stack_cleanup()
727 &st->recv_trailing_metadata; in grpc_run_batch_stack_fill_ops()
783 grpc_rb_md_ary_to_h(&st->recv_trailing_metadata), NULL)); in grpc_run_batch_stack_build_result()
|
| /external/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 330 if (op->recv_trailing_metadata) { in add_to_storage()
960 } else if (curr_op->recv_trailing_metadata) { in op_can_be_run()
1283 } else if (stream_op->recv_trailing_metadata && in execute_stream_op()
1295 stream_op->payload->recv_trailing_metadata.recv_trailing_metadata); in execute_stream_op()
1299 stream_op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in execute_stream_op()
1413 if (op->recv_trailing_metadata) { in perform_stream_op()
1415 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in perform_stream_op()
|
| /external/grpc-grpc/test/core/end2end/fuzzers/ |
| D | api_fuzzer.cc | 521 grpc_metadata_array recv_trailing_metadata; member
576 grpc_metadata_array_destroy(&call->recv_trailing_metadata); in maybe_delete_call_state()
1035 &g_active_call->recv_trailing_metadata; in LLVMFuzzerTestOneInput()
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 1635 if (op->recv_trailing_metadata) { in perform_stream_op_locked()
1638 s->collecting_stats = op_payload->recv_trailing_metadata.collect_stats; in perform_stream_op_locked()
1641 op_payload->recv_trailing_metadata.recv_trailing_metadata_ready; in perform_stream_op_locked()
1642 s->recv_trailing_metadata = in perform_stream_op_locked()
1643 op_payload->recv_trailing_metadata.recv_trailing_metadata; in perform_stream_op_locked()
2003 s->recv_trailing_metadata); in grpc_chttp2_maybe_complete_recv_trailing_metadata()
|
| D | internal.h | 516 grpc_metadata_batch* recv_trailing_metadata; member
|