| /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/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/ |
| D | client_filter.cc | 130 if (op->recv_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
131 recv_trailing_metadata_ = op->recv_trailing_metadata()->batch(); in StartTransportStreamOpBatch()
133 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in StartTransportStreamOpBatch()
134 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in StartTransportStreamOpBatch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | transport.h | 170 recv_trailing_metadata(false), in grpc_transport_stream_op_batch()
205 bool recv_trailing_metadata : 1; member
303 grpc_metadata_batch* recv_trailing_metadata = nullptr; member
307 } recv_trailing_metadata; member
|
| /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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 88 grpc_metadata_batch* recv_trailing_metadata; member
216 error = client_filter_incoming_metadata(calld->recv_trailing_metadata); in recv_trailing_metadata_ready()
369 if (batch->recv_trailing_metadata) { in http_client_start_transport_stream_op_batch()
371 calld->recv_trailing_metadata = in http_client_start_transport_stream_op_batch()
372 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in http_client_start_transport_stream_op_batch()
374 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in http_client_start_transport_stream_op_batch()
375 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in http_client_start_transport_stream_op_batch()
|
| /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/rust/crates/grpcio-sys/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()
|
| /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
|
| /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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 151 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in inject_recv_trailing_metadata_ready()
155 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in inject_recv_trailing_metadata_ready()
233 if (op->recv_trailing_metadata) { in grpc_deadline_state_client_start_transport_stream_op_batch()
331 if (op->recv_trailing_metadata) { in deadline_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/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/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/rust/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 86 if (batch->recv_trailing_metadata) return &calld->on_complete[5]; in get_state_for_batch()
117 if (batch->recv_trailing_metadata) { in connected_channel_start_transport_stream_op_batch()
121 &batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready); in connected_channel_start_transport_stream_op_batch()
|
| /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/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 515 s->recv_trailing_md_op->payload->recv_trailing_metadata in fail_helper_locked()
663 s->recv_trailing_md_op->payload->recv_trailing_metadata in op_state_machine_locked()
792 ->recv_trailing_metadata.recv_trailing_metadata, in op_state_machine_locked()
808 s->recv_trailing_md_op->payload->recv_trailing_metadata in op_state_machine_locked()
837 s->recv_trailing_md_op->payload->recv_trailing_metadata in op_state_machine_locked()
929 s->recv_trailing_md_op->payload->recv_trailing_metadata in cancel_stream_locked()
993 op->recv_trailing_metadata ? " recv_trailing_metadata" : ""); in perform_stream_op()
1037 op->recv_trailing_metadata)) { in perform_stream_op()
1051 if (op->recv_trailing_metadata) { in perform_stream_op()
1109 if (op->recv_trailing_metadata) { in perform_stream_op()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.cc | 368 payload_.recv_trailing_metadata.recv_trailing_metadata = in StartCall()
370 payload_.recv_trailing_metadata.collect_stats = &collect_stats_; in StartCall()
374 payload_.recv_trailing_metadata.recv_trailing_metadata_ready = in StartCall()
378 recv_trailing_metadata_batch_.recv_trailing_metadata = true; in StartCall()
|
| /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/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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 630 grpc_metadata_batch recv_trailing_metadata; member
2794 if (batch->recv_trailing_metadata) return 5; in GetBatchIndex()
3443 if (batch->recv_trailing_metadata) return 5; in GetBatchIndex()
3532 (!batch->recv_trailing_metadata || in MaybeClearPendingBatch()
3533 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready == in MaybeClearPendingBatch()
3847 if (batch.recv_trailing_metadata) { in Destroy()
3848 grpc_metadata_batch_destroy(&retry_state->recv_trailing_metadata); in Destroy()
4063 return batch->recv_trailing_metadata && in AddClosureForRecvTrailingMetadataReady()
4064 batch->payload->recv_trailing_metadata in AddClosureForRecvTrailingMetadataReady()
4078 &retry_state->recv_trailing_metadata, in AddClosureForRecvTrailingMetadataReady()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_decompress_filter.cc | 342 if (batch->recv_trailing_metadata) { in DecompressStartTransportStreamOpBatch()
344 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in DecompressStartTransportStreamOpBatch()
345 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in DecompressStartTransportStreamOpBatch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/message_size/ |
| D | message_size_filter.cc | 283 if (op->recv_trailing_metadata) { in message_size_start_transport_stream_op_batch()
285 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in message_size_start_transport_stream_op_batch()
286 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in message_size_start_transport_stream_op_batch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 273 if (batch->recv_trailing_metadata) { in server_auth_start_transport_stream_op_batch()
275 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in server_auth_start_transport_stream_op_batch()
276 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in server_auth_start_transport_stream_op_batch()
|