Home
last modified time | relevance | path

Searched refs:send_trailing_metadata (Results 1 – 25 of 30) sorted by relevance

12

/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc345 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()
Dchttp2_transport.cc1353 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 …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport.h166 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
Dtransport_op_string.cc90 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()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc343 if (is_last_data_frame && s_->send_trailing_metadata != nullptr && in FlushCompressedBytes()
360 s_->send_trailing_metadata != nullptr && in FlushCompressedBytes()
361 grpc_metadata_batch_is_empty(s_->send_trailing_metadata); in FlushCompressedBytes()
429 s_->send_trailing_metadata != nullptr && in FlushInitialMetadata()
516 if (s_->send_trailing_metadata == nullptr) return; in FlushTrailingMetadata()
522 if (grpc_metadata_batch_is_empty(s_->send_trailing_metadata)) { in FlushTrailingMetadata()
537 s_->send_trailing_metadata, &hopt, &t_->outbuf); in FlushTrailingMetadata()
570 s_->send_trailing_metadata = nullptr; in SentLastFrame()
Dchttp2_transport.cc1382 if (op->send_trailing_metadata) { in perform_stream_op_locked()
1383 log_metadata(op_payload->send_trailing_metadata.send_trailing_metadata, in perform_stream_op_locked()
1543 if (op->send_trailing_metadata) { in perform_stream_op_locked()
1548 s->send_trailing_metadata = in perform_stream_op_locked()
1549 op_payload->send_trailing_metadata.send_trailing_metadata; in perform_stream_op_locked()
1552 grpc_metadata_batch_size(s->send_trailing_metadata); in perform_stream_op_locked()
1570 if (contains_non_ok_status(s->send_trailing_metadata)) { in perform_stream_op_locked()
1574 s->send_trailing_metadata = nullptr; in perform_stream_op_locked()
1578 op->payload->send_trailing_metadata.send_trailing_metadata) in perform_stream_op_locked()
1666 if (op->send_trailing_metadata) { in perform_stream_op()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.h140 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()
/external/grpc-grpc/src/cpp/common/
Dchannel_filter.h140 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()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.h143 bool send_trailing_metadata : 1; member
183 grpc_metadata_batch* send_trailing_metadata; member
184 } send_trailing_metadata; member
Dtransport_op_string.cc91 if (op->send_trailing_metadata) { in grpc_transport_stream_op_batch_string()
95 &b, *op->payload->send_trailing_metadata.send_trailing_metadata); in grpc_transport_stream_op_batch_string()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc860 grpc_metadata_batch send_trailing_metadata; member
992 grpc_metadata_batch send_trailing_metadata; member
1042 if (batch->send_trailing_metadata) { in maybe_cache_send_ops_for_batch()
1045 grpc_metadata_batch* send_trailing_metadata = in maybe_cache_send_ops_for_batch() local
1046 batch->payload->send_trailing_metadata.send_trailing_metadata; in maybe_cache_send_ops_for_batch()
1050 sizeof(grpc_linked_mdelem) * send_trailing_metadata->list.count); in maybe_cache_send_ops_for_batch()
1051 grpc_metadata_batch_copy(send_trailing_metadata, in maybe_cache_send_ops_for_batch()
1052 &calld->send_trailing_metadata, in maybe_cache_send_ops_for_batch()
1087 grpc_metadata_batch_destroy(&calld->send_trailing_metadata); in free_cached_send_trailing_metadata()
1121 if (batch_data->batch.send_trailing_metadata) { in free_cached_send_op_data_for_completed_batch()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc650 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 …]
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc643 s->send_trailing_md_op->payload->send_trailing_metadata in op_state_machine()
644 .send_trailing_metadata, in op_state_machine()
917 if (op->send_trailing_metadata) { in perform_stream_op()
918 log_metadata(op->payload->send_trailing_metadata.send_trailing_metadata, in perform_stream_op()
947 op->send_trailing_metadata ? " send_trailing_metadata" : "", in perform_stream_op()
957 (op->send_initial_metadata || op->send_trailing_metadata)) { in perform_stream_op()
994 (op->send_message || op->send_trailing_metadata || in perform_stream_op()
1001 if (op->send_trailing_metadata) { in perform_stream_op()
1024 (op->send_trailing_metadata && !op->send_message) || in perform_stream_op()
/external/grpc-grpc/src/cpp/ext/filters/census/
Dserver_filter.cc147 if (op->send_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
155 op->send_trailing_metadata()->batch(), &census_bin_, in StartTransportStreamOpBatch()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc621 grpc_metadata_batch send_trailing_metadata; member
2791 if (batch->send_trailing_metadata) return 2; in GetBatchIndex()
3364 if (batch->send_trailing_metadata) { in MaybeCacheSendOpsForBatch()
3367 grpc_metadata_batch* send_trailing_metadata = in MaybeCacheSendOpsForBatch() local
3368 batch->payload->send_trailing_metadata.send_trailing_metadata; in MaybeCacheSendOpsForBatch()
3371 sizeof(grpc_linked_mdelem) * send_trailing_metadata->list.count)); in MaybeCacheSendOpsForBatch()
3372 grpc_metadata_batch_copy(send_trailing_metadata, &send_trailing_metadata_, in MaybeCacheSendOpsForBatch()
3426 if (batch_data->batch.send_trailing_metadata) { in FreeCachedSendOpDataForCompletedBatch()
3440 if (batch->send_trailing_metadata) return 2; in GetBatchIndex()
3475 if (batch->send_trailing_metadata) { in PendingBatchesAdd()
[all …]
/external/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/
Dserver_filter.cc149 if (op->send_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
157 op->send_trailing_metadata()->batch(), &census_bin_, in StartTransportStreamOpBatch()
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc391 if (op->send_trailing_metadata) { in hs_mutate_op()
393 elem, op->payload->send_trailing_metadata.send_trailing_metadata); in hs_mutate_op()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc465 if (op->send_trailing_metadata) { in hs_mutate_op()
467 op->payload->send_trailing_metadata.send_trailing_metadata); in hs_mutate_op()
/external/grpc-grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.cc111 } else if (op->send_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
114 grpc_metadata_batch_filter(op->send_trailing_metadata()->batch(), in StartTransportStreamOpBatch()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dcall.cc1199 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()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc339 payload_.send_trailing_metadata.send_trailing_metadata = in StartCall()
341 batch_.send_trailing_metadata = true; in StartCall()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.cc117 } else if (op->send_trailing_metadata() != nullptr) { in StartTransportStreamOpBatch()
120 grpc_metadata_batch_filter(op->send_trailing_metadata()->batch(), in StartTransportStreamOpBatch()
/external/grpc-grpc/src/ruby/ext/grpc/
Drb_call.c614 grpc_metadata_array send_trailing_metadata; member
633 grpc_metadata_array_init(&st->send_trailing_metadata); in grpc_run_batch_stack_init()
658 grpc_rb_metadata_array_destroy_including_entries(&st->send_trailing_metadata); in grpc_run_batch_stack_cleanup()
715 &st->ops[st->op_num], &st->send_trailing_metadata, in grpc_run_batch_stack_fill_ops()
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc1142 if (bctl->op.send_trailing_metadata) { in post_batch_completion()
1636 stream_op->send_trailing_metadata = true; in call_start_batch()
1638 stream_op_payload->send_trailing_metadata.send_trailing_metadata = in call_start_batch()
1662 stream_op->send_trailing_metadata = true; in call_start_batch()
1708 stream_op_payload->send_trailing_metadata.send_trailing_metadata = in call_start_batch()
1859 if (stream_op->send_trailing_metadata) { in call_start_batch()
/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc84 if (batch->send_trailing_metadata) return &calld->on_complete[2]; in get_state_for_batch()

12