| /third_party/grpc/src/core/ext/transport/chttp2/transport/ |
| D | writing.cc | 345 s_->send_trailing_metadata != nullptr && in FlushUncompressedBytes()
346 grpc_metadata_batch_is_empty(s_->send_trailing_metadata); in FlushUncompressedBytes()
363 if (is_last_data_frame && s_->send_trailing_metadata != nullptr && in FlushCompressedBytes()
380 s_->send_trailing_metadata != nullptr && in FlushCompressedBytes()
381 grpc_metadata_batch_is_empty(s_->send_trailing_metadata); in FlushCompressedBytes()
452 s_->send_trailing_metadata != nullptr && in FlushInitialMetadata()
554 if (s_->send_trailing_metadata == nullptr) return; in FlushTrailingMetadata()
560 if (grpc_metadata_batch_is_empty(s_->send_trailing_metadata)) { in FlushTrailingMetadata()
575 s_->send_trailing_metadata, &hopt, &t_->outbuf); in FlushTrailingMetadata()
608 s_->send_trailing_metadata = nullptr; in SentLastFrame()
|
| D | chttp2_transport.cc | 1353 if (op->send_trailing_metadata) { in perform_stream_op_locked()
1354 log_metadata(op_payload->send_trailing_metadata.send_trailing_metadata, in perform_stream_op_locked()
1490 if (op->send_trailing_metadata) { in perform_stream_op_locked()
1495 s->send_trailing_metadata = in perform_stream_op_locked()
1496 op_payload->send_trailing_metadata.send_trailing_metadata; in perform_stream_op_locked()
1497 s->sent_trailing_metadata_op = op_payload->send_trailing_metadata.sent; in perform_stream_op_locked()
1499 if (contains_non_ok_status(s->send_trailing_metadata)) { in perform_stream_op_locked()
1503 s->send_trailing_metadata = nullptr; in perform_stream_op_locked()
1508 op->payload->send_trailing_metadata.send_trailing_metadata) in perform_stream_op_locked()
1597 if (op->send_trailing_metadata) { in perform_stream_op()
[all …]
|
| D | internal.h | 535 grpc_metadata_batch* send_trailing_metadata = nullptr; member
|
| /third_party/grpc/src/core/lib/transport/ |
| D | transport.h | 166 send_trailing_metadata(false), in grpc_transport_stream_op_batch()
192 bool send_trailing_metadata : 1; member
244 grpc_metadata_batch* send_trailing_metadata = nullptr; member
251 } send_trailing_metadata; member
|
| D | transport_op_string.cc | 90 if (op->send_trailing_metadata) { in grpc_transport_stream_op_batch_string()
93 *op->payload->send_trailing_metadata.send_trailing_metadata, &out); in grpc_transport_stream_op_batch_string()
|
| /third_party/grpc/src/cpp/common/ |
| D | channel_filter.h | 140 op->send_trailing_metadata in TransportStreamOpBatch()
141 ? op->payload->send_trailing_metadata.send_trailing_metadata in TransportStreamOpBatch()
160 MetadataBatch* send_trailing_metadata() { in send_trailing_metadata() function
161 return op_->send_trailing_metadata ? &send_trailing_metadata_ : nullptr; in send_trailing_metadata()
|
| /third_party/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 650 s->send_trailing_md_op->payload->send_trailing_metadata in op_state_machine_locked()
651 .send_trailing_metadata, in op_state_machine_locked()
655 if (s->send_trailing_md_op->payload->send_trailing_metadata.sent) { in op_state_machine_locked()
656 *s->send_trailing_md_op->payload->send_trailing_metadata.sent = true; in op_state_machine_locked()
960 if (op->send_trailing_metadata) { in perform_stream_op()
961 log_metadata(op->payload->send_trailing_metadata.send_trailing_metadata, in perform_stream_op()
990 op->send_trailing_metadata ? " send_trailing_metadata" : "", in perform_stream_op()
998 (op->send_initial_metadata || op->send_trailing_metadata)) { in perform_stream_op()
1035 (op->send_message || op->send_trailing_metadata || in perform_stream_op()
1042 if (op->send_trailing_metadata) { in perform_stream_op()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 621 grpc_metadata_batch send_trailing_metadata; member
2791 if (batch->send_trailing_metadata) return 2; in GetBatchIndex()
3370 if (batch->send_trailing_metadata) { in MaybeCacheSendOpsForBatch()
3373 grpc_metadata_batch* send_trailing_metadata = in MaybeCacheSendOpsForBatch() local
3374 batch->payload->send_trailing_metadata.send_trailing_metadata; in MaybeCacheSendOpsForBatch()
3377 sizeof(grpc_linked_mdelem) * send_trailing_metadata->list.count)); in MaybeCacheSendOpsForBatch()
3378 grpc_metadata_batch_copy(send_trailing_metadata, &send_trailing_metadata_, in MaybeCacheSendOpsForBatch()
3432 if (batch_data->batch.send_trailing_metadata) { in FreeCachedSendOpDataForCompletedBatch()
3446 if (batch->send_trailing_metadata) return 2; in GetBatchIndex()
3481 if (batch->send_trailing_metadata) { in PendingBatchesAdd()
[all …]
|
| /third_party/grpc/src/cpp/ext/filters/census/ |
| D | server_filter.cc | 138 if (op->send_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
146 op->send_trailing_metadata()->batch(), &census_bin_, in StartTransportStreamOpBatch()
|
| /third_party/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 465 if (op->send_trailing_metadata) { in hs_mutate_op()
467 op->payload->send_trailing_metadata.send_trailing_metadata); in hs_mutate_op()
|
| /third_party/grpc/src/core/lib/surface/ |
| D | call.cc | 1199 if (bctl->op.send_trailing_metadata) { in post_batch_completion()
1726 stream_op->send_trailing_metadata = true; in call_start_batch()
1728 stream_op_payload->send_trailing_metadata.send_trailing_metadata = in call_start_batch()
1752 stream_op->send_trailing_metadata = true; in call_start_batch()
1798 stream_op_payload->send_trailing_metadata.send_trailing_metadata = in call_start_batch()
1800 stream_op_payload->send_trailing_metadata.sent = in call_start_batch()
1951 if (stream_op->send_trailing_metadata) { in call_start_batch()
|
| /third_party/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.cc | 339 payload_.send_trailing_metadata.send_trailing_metadata = in StartCall()
341 batch_.send_trailing_metadata = true; in StartCall()
|
| /third_party/grpc/src/core/ext/filters/load_reporting/ |
| D | server_load_reporting_filter.cc | 117 } else if (op->send_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
120 grpc_metadata_batch_filter(op->send_trailing_metadata()->batch(), in StartTransportStreamOpBatch()
|
| /third_party/grpc/src/ruby/ext/grpc/ |
| D | rb_call.c | 615 grpc_metadata_array send_trailing_metadata; member
635 grpc_metadata_array_init(&st->send_trailing_metadata); in grpc_run_batch_stack_init()
660 grpc_rb_metadata_array_destroy_including_entries(&st->send_trailing_metadata); in grpc_run_batch_stack_cleanup()
717 &st->ops[st->op_num], &st->send_trailing_metadata, in grpc_run_batch_stack_fill_ops()
|
| /third_party/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 978 } else if (curr_op->send_trailing_metadata && in op_can_be_run()
1014 else if (curr_op->send_trailing_metadata && in op_can_be_run()
1067 if (!stream_op->send_message && !stream_op->send_trailing_metadata) { in execute_stream_op()
1115 if (!stream_op->send_trailing_metadata) { in execute_stream_op()
1134 } else if (stream_op->send_trailing_metadata && in execute_stream_op()
|
| /third_party/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 83 if (batch->send_trailing_metadata) return &calld->on_complete[2]; in get_state_for_batch()
|