| /third_party/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()
|
| /third_party/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
|
| D | transport.cc | 199 if (batch->recv_trailing_metadata) {
201 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready,
|
| D | transport_op_string.cc | 105 if (op->recv_trailing_metadata) { in grpc_transport_stream_op_batch_string()
|
| /third_party/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()
|
| /third_party/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()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_call_create.cc | 624 if (op->recv_trailing_metadata) { in StartTransportStreamOp()
626 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in StartTransportStreamOp()
747 grpc_metadata_array recv_trailing_metadata; in BM_IsolatedCall_Unary() local
748 grpc_metadata_array_init(&recv_trailing_metadata); in BM_IsolatedCall_Unary()
763 ops[5].data.recv_status_on_client.trailing_metadata = &recv_trailing_metadata; in BM_IsolatedCall_Unary()
776 grpc_metadata_array_destroy(&recv_trailing_metadata); in BM_IsolatedCall_Unary()
790 grpc_metadata_array recv_trailing_metadata; in BM_IsolatedCall_StreamingSend() local
791 grpc_metadata_array_init(&recv_trailing_metadata); in BM_IsolatedCall_StreamingSend()
816 grpc_metadata_array_destroy(&recv_trailing_metadata); in BM_IsolatedCall_StreamingSend()
|
| /third_party/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()
|
| /third_party/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 …]
|
| /third_party/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()
|
| /third_party/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()
|
| /third_party/grpc/src/php/ext/grpc/ |
| D | call.c | 293 grpc_metadata_array recv_trailing_metadata; in PHP_METHOD() local
306 grpc_metadata_array_init(&recv_trailing_metadata); in PHP_METHOD()
433 &recv_trailing_metadata; in PHP_METHOD()
496 recv_md = grpc_parse_metadata_array(&recv_trailing_metadata); in PHP_METHOD()
523 grpc_metadata_array_destroy(&recv_trailing_metadata); in PHP_METHOD()
|
| /third_party/grpc/test/core/util/ |
| D | test_lb_policies.cc | 289 MetadataInterface* recv_trailing_metadata, in RecordRecvTrailingMetadata() argument
293 GPR_ASSERT(recv_trailing_metadata != nullptr); in RecordRecvTrailingMetadata()
294 args_seen.metadata = CopyMetadataToVector(recv_trailing_metadata); in RecordRecvTrailingMetadata()
|
| /third_party/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()
3449 if (batch->recv_trailing_metadata) return 5; in GetBatchIndex()
3538 (!batch->recv_trailing_metadata || in MaybeClearPendingBatch()
3539 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready == in MaybeClearPendingBatch()
3853 if (batch.recv_trailing_metadata) { in Destroy()
3854 grpc_metadata_batch_destroy(&retry_state->recv_trailing_metadata); in Destroy()
4069 return batch->recv_trailing_metadata && in AddClosureForRecvTrailingMetadataReady()
4070 batch->payload->recv_trailing_metadata in AddClosureForRecvTrailingMetadataReady()
4084 &retry_state->recv_trailing_metadata, in AddClosureForRecvTrailingMetadataReady()
[all …]
|
| D | subchannel.cc | 232 if (!batch->recv_trailing_metadata) { in MaybeInterceptRecvTrailingMetadata()
244 batch->payload->recv_trailing_metadata.recv_trailing_metadata; in MaybeInterceptRecvTrailingMetadata()
246 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in MaybeInterceptRecvTrailingMetadata()
247 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in MaybeInterceptRecvTrailingMetadata()
|
| /third_party/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()
|
| /third_party/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()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | call.cc | 1203 if (bctl->op.recv_trailing_metadata) { in post_batch_completion()
1877 stream_op->recv_trailing_metadata = true; in call_start_batch()
1878 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata = in call_start_batch()
1880 stream_op_payload->recv_trailing_metadata.collect_stats = in call_start_batch()
1885 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata_ready = in call_start_batch()
1907 stream_op->recv_trailing_metadata = true; in call_start_batch()
1908 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata = in call_start_batch()
1910 stream_op_payload->recv_trailing_metadata.collect_stats = in call_start_batch()
1915 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata_ready = in call_start_batch()
1961 if (stream_op->recv_trailing_metadata) { in call_start_batch()
|
| D | server.cc | 1372 if (batch->recv_trailing_metadata) { in StartTransportStreamOpBatchImpl()
1374 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in StartTransportStreamOpBatchImpl()
1375 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in StartTransportStreamOpBatchImpl()
|
| /third_party/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()
|
| /third_party/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 341 if (op->recv_trailing_metadata) { in add_to_storage()
994 } else if (curr_op->recv_trailing_metadata) { in op_can_be_run()
1316 } else if (stream_op->recv_trailing_metadata && in execute_stream_op()
1330 stream_op->payload->recv_trailing_metadata.recv_trailing_metadata); in execute_stream_op()
1335 stream_op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in execute_stream_op()
1455 if (op->recv_trailing_metadata) { in perform_stream_op()
1458 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in perform_stream_op()
|
| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_call.c | 620 grpc_metadata_array recv_trailing_metadata; member
637 grpc_metadata_array_init(&st->recv_trailing_metadata); in grpc_run_batch_stack_init()
662 grpc_metadata_array_destroy(&st->recv_trailing_metadata); in grpc_run_batch_stack_cleanup()
729 &st->recv_trailing_metadata; in grpc_run_batch_stack_fill_ops()
787 grpc_rb_md_ary_to_h(&st->recv_trailing_metadata), in grpc_run_batch_stack_build_result()
|
| /third_party/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 458 if (op->recv_trailing_metadata) { in hs_mutate_op()
460 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in hs_mutate_op()
461 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in hs_mutate_op()
|
| /third_party/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 1564 if (op->recv_trailing_metadata) { in perform_stream_op_locked()
1567 s->collecting_stats = op_payload->recv_trailing_metadata.collect_stats; in perform_stream_op_locked()
1570 op_payload->recv_trailing_metadata.recv_trailing_metadata_ready; in perform_stream_op_locked()
1571 s->recv_trailing_metadata = in perform_stream_op_locked()
1572 op_payload->recv_trailing_metadata.recv_trailing_metadata; in perform_stream_op_locked()
1977 s->recv_trailing_metadata); in grpc_chttp2_maybe_complete_recv_trailing_metadata()
|
| D | internal.h | 559 grpc_metadata_batch* recv_trailing_metadata; member
|