Home
last modified time | relevance | path

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

12

/external/grpc-grpc/src/core/lib/transport/
Dtransport_op_string.cc70 if (op->send_trailing_metadata) { in grpc_transport_stream_op_batch_string()
74 op->payload->send_trailing_metadata in grpc_transport_stream_op_batch_string()
75 .send_trailing_metadata->TransportSize()); in grpc_transport_stream_op_batch_string()
77 absl::StrAppend(&out, op->payload->send_trailing_metadata in grpc_transport_stream_op_batch_string()
78 .send_trailing_metadata->DebugString()); in grpc_transport_stream_op_batch_string()
Dbatch_builder.h193 Arena::PoolPtr<grpc_metadata_batch> send_trailing_metadata; member
331 batch->batch.send_trailing_metadata = true; in SendClientTrailingMetadata()
333 payload_->send_trailing_metadata.send_trailing_metadata = metadata.get(); in SendClientTrailingMetadata()
334 payload_->send_trailing_metadata.sent = nullptr; in SendClientTrailingMetadata()
335 pc->send_trailing_metadata = std::move(metadata); in SendClientTrailingMetadata()
362 batch->batch.send_trailing_metadata = true; in SendServerTrailingMetadata()
363 payload_->send_trailing_metadata.send_trailing_metadata = metadata.get(); in SendServerTrailingMetadata()
364 payload_->send_trailing_metadata.sent = &pc->trailing_metadata_sent; in SendServerTrailingMetadata()
373 pc->send_trailing_metadata = std::move(metadata); in SendServerTrailingMetadata()
377 batch.get(), std::move(pc->send_trailing_metadata), in SendServerTrailingMetadata()
Dtransport.h261 send_trailing_metadata(false), in grpc_transport_stream_op_batch()
287 bool send_trailing_metadata : 1; member
309 return send_initial_metadata || send_trailing_metadata || send_message || in HasOp()
330 grpc_metadata_batch* send_trailing_metadata = nullptr; member
337 } send_trailing_metadata; member
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport_op_string.cc73 if (op->send_trailing_metadata) { in grpc_transport_stream_op_batch_string()
77 op->payload->send_trailing_metadata in grpc_transport_stream_op_batch_string()
78 .send_trailing_metadata->TransportSize()); in grpc_transport_stream_op_batch_string()
80 absl::StrAppend(&out, op->payload->send_trailing_metadata in grpc_transport_stream_op_batch_string()
81 .send_trailing_metadata->DebugString()); in grpc_transport_stream_op_batch_string()
Dbatch_builder.h196 Arena::PoolPtr<grpc_metadata_batch> send_trailing_metadata; member
334 batch->batch.send_trailing_metadata = true; in SendClientTrailingMetadata()
337 payload_->send_trailing_metadata.send_trailing_metadata = metadata.get(); in SendClientTrailingMetadata()
338 payload_->send_trailing_metadata.sent = nullptr; in SendClientTrailingMetadata()
339 pc->send_trailing_metadata = std::move(metadata); in SendClientTrailingMetadata()
366 batch->batch.send_trailing_metadata = true; in SendServerTrailingMetadata()
367 payload_->send_trailing_metadata.send_trailing_metadata = metadata.get(); in SendServerTrailingMetadata()
368 payload_->send_trailing_metadata.sent = &pc->trailing_metadata_sent; in SendServerTrailingMetadata()
377 pc->send_trailing_metadata = std::move(metadata); in SendServerTrailingMetadata()
381 batch.get(), std::move(pc->send_trailing_metadata), in SendServerTrailingMetadata()
Dtransport.h352 send_trailing_metadata(false),
378 bool send_trailing_metadata : 1;
400 return send_initial_metadata || send_trailing_metadata || send_message ||
421 grpc_metadata_batch* send_trailing_metadata = nullptr;
428 } send_trailing_metadata;
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/common/
Dchannel_filter.h110 op->send_trailing_metadata in TransportStreamOpBatch()
111 ? op->payload->send_trailing_metadata.send_trailing_metadata in TransportStreamOpBatch()
130 MetadataBatch* send_trailing_metadata() { in send_trailing_metadata() function
131 return op_->send_trailing_metadata ? &send_trailing_metadata_ : nullptr; in send_trailing_metadata()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc411 s_->send_trailing_metadata != nullptr && in FlushBytes()
412 s_->send_trailing_metadata->empty(); in FlushBytes()
462 s_->send_trailing_metadata != nullptr && in FlushInitialMetadata()
548 if (s_->send_trailing_metadata == nullptr) return; in FlushTrailingMetadata()
552 if (s_->send_trailing_metadata->empty()) { in FlushTrailingMetadata()
557 s_->send_trailing_metadata->Set(grpc_core::HttpStatusMetadata(), in FlushTrailingMetadata()
561 s_->send_trailing_metadata->Set(grpc_core::ContentTypeMetadata(), in FlushTrailingMetadata()
574 *s_->send_trailing_metadata, &t_->outbuf); in FlushTrailingMetadata()
601 s_->send_trailing_metadata = nullptr; in SentLastFrame()
/external/grpc-grpc/src/cpp/ext/filters/census/
Dserver_call_tracer.cc121 grpc_metadata_batch* send_trailing_metadata) override;
222 grpc_metadata_batch* send_trailing_metadata) { in RecordSendTrailingMetadata() argument
226 if (OpenCensusStatsEnabled() && send_trailing_metadata != nullptr) { in RecordSendTrailingMetadata()
230 send_trailing_metadata->Set( in RecordSendTrailingMetadata()
/external/grpc-grpc/src/python/grpcio_observability/grpc_observability/
Dserver_call_tracer.cc113 grpc_metadata_batch* send_trailing_metadata) override;
209 grpc_metadata_batch* send_trailing_metadata) { in RecordSendTrailingMetadata() argument
213 if (PythonCensusStatsEnabled() && send_trailing_metadata != nullptr) { in RecordSendTrailingMetadata()
217 send_trailing_metadata->Set( in RecordSendTrailingMetadata()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/
Dserver_call_tracer.cc122 grpc_metadata_batch* send_trailing_metadata) override;
201 grpc_metadata_batch* send_trailing_metadata) { in RecordSendTrailingMetadata() argument
205 if (OpenCensusStatsEnabled() && send_trailing_metadata != nullptr) { in RecordSendTrailingMetadata()
209 send_trailing_metadata->Set( in RecordSendTrailingMetadata()
/external/grpc-grpc/src/core/client_channel/
Dretry_filter_legacy_call_data.cc209 if (pending->batch->send_trailing_metadata && in PendingBatchContainsUnstartedSendOps()
406 if (batch->send_trailing_metadata) { in AddBatchesForPendingBatches()
494 if (batch->send_trailing_metadata) { in AddBatchesForPendingBatches()
790 if (batch_.send_trailing_metadata) { in FreeCachedSendOpDataForCompletedBatch()
1241 batch_.send_trailing_metadata == batch->send_trailing_metadata; in AddClosuresForCompletedPendingBatch()
1272 if (batch->send_message || batch->send_trailing_metadata) { in AddClosuresForReplayOrPendingSendOps()
1339 if (batch_data->batch_.send_trailing_metadata) { in OnComplete()
1439 batch_.send_trailing_metadata = true; in AddRetriableSendTrailingMetadataOp()
1440 batch_.payload->send_trailing_metadata.send_trailing_metadata = in AddRetriableSendTrailingMetadataOp()
1756 if (batch->send_trailing_metadata) { in MaybeCacheSendOpsForBatch()
[all …]
Dsubchannel_stream_client.cc248 payload_.send_trailing_metadata.send_trailing_metadata = in StartCallLocked()
250 batch_.send_trailing_metadata = true; in StartCallLocked()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc413 s_->send_trailing_metadata != nullptr && in FlushBytes()
414 s_->send_trailing_metadata->empty(); in FlushBytes()
464 s_->send_trailing_metadata != nullptr && in FlushInitialMetadata()
557 if (s_->send_trailing_metadata == nullptr) return; in FlushTrailingMetadata()
561 if (s_->send_trailing_metadata->empty()) { in FlushTrailingMetadata()
566 s_->send_trailing_metadata->Set(grpc_core::HttpStatusMetadata(), in FlushTrailingMetadata()
570 s_->send_trailing_metadata->Set(grpc_core::ContentTypeMetadata(), in FlushTrailingMetadata()
577 *s_->send_trailing_metadata, t_->outbuf.c_slice_buffer()); in FlushTrailingMetadata()
604 s_->send_trailing_metadata = nullptr; in SentLastFrame()
/external/grpc-grpc/src/core/lib/channel/
Dcall_tracer.cc90 grpc_metadata_batch* send_trailing_metadata) override { in RecordSendTrailingMetadata() argument
92 tracer->RecordSendTrailingMetadata(send_trailing_metadata); in RecordSendTrailingMetadata()
224 grpc_metadata_batch* send_trailing_metadata) override { in RecordSendTrailingMetadata() argument
226 tracer->RecordSendTrailingMetadata(send_trailing_metadata); in RecordSendTrailingMetadata()
Dpromise_based_filter.cc1404 !batch->send_trailing_metadata && !batch->send_message && in StartBatch()
2050 !batch->send_trailing_metadata && !batch->send_message && in StartBatch()
2068 !batch->send_trailing_metadata && !batch->send_message && in StartBatch()
2131 if (batch.is_captured() && batch->send_trailing_metadata) { in StartBatch()
2136 batch->payload->send_trailing_metadata.send_trailing_metadata in StartBatch()
2140 *batch->payload->send_trailing_metadata.send_trailing_metadata, in StartBatch()
2314 ->send_trailing_metadata.send_trailing_metadata); in PollTrailingMetadata()
2458 ->send_trailing_metadata.send_trailing_metadata, in WakeInsideCombiner()
2478 if (send_trailing_metadata_batch_->payload->send_trailing_metadata in WakeInsideCombiner()
2479 .send_trailing_metadata->get(GrpcStatusMetadata()) in WakeInsideCombiner()
[all …]
/external/grpc-grpc/src/core/ext/transport/inproc/
Dlegacy_inproc_transport.cc664 s->send_trailing_md_op->payload->send_trailing_metadata in op_state_machine_locked()
665 .send_trailing_metadata, in op_state_machine_locked()
669 if (s->send_trailing_md_op->payload->send_trailing_metadata.sent) { in op_state_machine_locked()
670 *s->send_trailing_md_op->payload->send_trailing_metadata.sent = true; in op_state_machine_locked()
958 if (op->send_trailing_metadata) { in PerformStreamOp()
959 log_metadata(op->payload->send_trailing_metadata.send_trailing_metadata, in PerformStreamOp()
988 op->send_trailing_metadata ? " send_trailing_metadata" : "", in PerformStreamOp()
995 if (error.ok() && (op->send_initial_metadata || op->send_trailing_metadata)) { in PerformStreamOp()
1029 if (error.ok() && (op->send_message || op->send_trailing_metadata || in PerformStreamOp()
1036 if (op->send_trailing_metadata) { in PerformStreamOp()
[all …]
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc636 s->send_trailing_md_op->payload->send_trailing_metadata in op_state_machine_locked()
637 .send_trailing_metadata, in op_state_machine_locked()
641 if (s->send_trailing_md_op->payload->send_trailing_metadata.sent) { in op_state_machine_locked()
642 *s->send_trailing_md_op->payload->send_trailing_metadata.sent = true; in op_state_machine_locked()
924 if (op->send_trailing_metadata) { in perform_stream_op()
925 log_metadata(op->payload->send_trailing_metadata.send_trailing_metadata, in perform_stream_op()
954 op->send_trailing_metadata ? " send_trailing_metadata" : "", in perform_stream_op()
961 if (error.ok() && (op->send_initial_metadata || op->send_trailing_metadata)) { in perform_stream_op()
995 if (error.ok() && (op->send_message || op->send_trailing_metadata || in perform_stream_op()
1002 if (op->send_trailing_metadata) { in perform_stream_op()
[all …]
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dretry_filter.cc755 if (pending->batch->send_trailing_metadata && in PendingBatchContainsUnstartedSendOps()
951 if (batch->send_trailing_metadata) { in AddBatchesForPendingBatches()
1039 if (batch->send_trailing_metadata) { in AddBatchesForPendingBatches()
1334 if (batch_.send_trailing_metadata) { in FreeCachedSendOpDataForCompletedBatch()
1785 batch_.send_trailing_metadata == batch->send_trailing_metadata; in AddClosuresForCompletedPendingBatch()
1816 if (batch->send_message || batch->send_trailing_metadata) { in AddClosuresForReplayOrPendingSendOps()
1883 if (batch_data->batch_.send_trailing_metadata) { in OnComplete()
1983 batch_.send_trailing_metadata = true; in AddRetriableSendTrailingMetadataOp()
1984 batch_.payload->send_trailing_metadata.send_trailing_metadata = in AddRetriableSendTrailingMetadataOp()
2309 if (batch->send_trailing_metadata) { in MaybeCacheSendOpsForBatch()
[all …]
Dsubchannel_stream_client.cc253 payload_.send_trailing_metadata.send_trailing_metadata = in StartCallLocked()
255 batch_.send_trailing_metadata = true; in StartCallLocked()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/channel/
Dpromise_based_filter.cc1397 !batch->send_trailing_metadata && !batch->send_message && in StartBatch()
2043 !batch->send_trailing_metadata && !batch->send_message && in StartBatch()
2060 !batch->send_trailing_metadata && !batch->send_message && in StartBatch()
2123 if (batch.is_captured() && batch->send_trailing_metadata) { in StartBatch()
2128 batch->payload->send_trailing_metadata.send_trailing_metadata in StartBatch()
2132 *batch->payload->send_trailing_metadata.send_trailing_metadata, in StartBatch()
2304 ->send_trailing_metadata.send_trailing_metadata); in PollTrailingMetadata()
2447 ->send_trailing_metadata.send_trailing_metadata, in WakeInsideCombiner()
2467 if (send_trailing_metadata_batch_->payload->send_trailing_metadata in WakeInsideCombiner()
2468 .send_trailing_metadata->get(GrpcStatusMetadata()) in WakeInsideCombiner()
[all …]
Dcall_tracer.h72 grpc_metadata_batch* send_trailing_metadata) = 0;
/external/grpc-grpc/test/core/transport/binder/
Dbinder_transport_test.cc263 op->send_trailing_metadata = true; in MakeSendTrailingMetadata()
264 op->payload->send_trailing_metadata.send_trailing_metadata = in MakeSendTrailingMetadata()
470 MakeSendTrailingMetadata send_trailing_metadata(kTrailingMetadata, &op); in TEST_F() local
502 MakeSendTrailingMetadata send_trailing_metadata(kTrailingMetadata, &op); in TEST_F() local
658 MakeSendTrailingMetadata send_trailing_metadata(kSendTrailingMetadata, &op); in TEST_F() local
/external/grpc-grpc/src/core/ext/transport/binder/transport/
Dbinder_transport.cc394 !op->send_trailing_metadata && !op->recv_initial_metadata && in perform_stream_op_locked()
465 if (op->send_trailing_metadata) { in perform_stream_op_locked()
467 auto batch = op->payload->send_trailing_metadata.send_trailing_metadata; in perform_stream_op_locked()
550 op->send_trailing_metadata) { in perform_stream_op_locked()
552 if (!stream->is_client && op->send_trailing_metadata) { in perform_stream_op_locked()
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/ext/transport/binder/transport/
Dbinder_transport.cc398 !op->send_trailing_metadata && !op->recv_initial_metadata && in perform_stream_op_locked()
466 if (op->send_trailing_metadata) { in perform_stream_op_locked()
468 auto batch = op->payload->send_trailing_metadata.send_trailing_metadata; in perform_stream_op_locked()
546 op->send_trailing_metadata) { in perform_stream_op_locked()
548 if (!gbs->is_client && op->send_trailing_metadata) { in perform_stream_op_locked()

12