| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 308 GRPC_MDVALUE(batch->payload->send_initial_metadata.send_initial_metadata in update_path_for_get()
341 batch->payload->send_initial_metadata.send_initial_metadata; in update_path_for_get()
381 if (batch->send_initial_metadata) { in http_client_start_transport_stream_op_batch()
388 (batch->payload->send_initial_metadata.send_initial_metadata_flags & in http_client_start_transport_stream_op_batch()
420 } else if (batch->payload->send_initial_metadata in http_client_start_transport_stream_op_batch()
427 batch->payload->send_initial_metadata.send_initial_metadata, in http_client_start_transport_stream_op_batch()
430 batch->payload->send_initial_metadata.send_initial_metadata, in http_client_start_transport_stream_op_batch()
433 batch->payload->send_initial_metadata.send_initial_metadata, in http_client_start_transport_stream_op_batch()
436 batch->payload->send_initial_metadata.send_initial_metadata, in http_client_start_transport_stream_op_batch()
439 batch->payload->send_initial_metadata.send_initial_metadata, in http_client_start_transport_stream_op_batch()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 258 GRPC_MDVALUE(batch->payload->send_initial_metadata.send_initial_metadata in update_path_for_get()
291 batch->payload->send_initial_metadata.send_initial_metadata; in update_path_for_get()
331 if (batch->send_initial_metadata) { in hc_start_transport_stream_op_batch()
338 (batch->payload->send_initial_metadata.send_initial_metadata_flags & in hc_start_transport_stream_op_batch()
370 } else if (batch->payload->send_initial_metadata in hc_start_transport_stream_op_batch()
377 batch->payload->send_initial_metadata.send_initial_metadata, in hc_start_transport_stream_op_batch()
380 batch->payload->send_initial_metadata.send_initial_metadata, in hc_start_transport_stream_op_batch()
383 batch->payload->send_initial_metadata.send_initial_metadata, in hc_start_transport_stream_op_batch()
386 batch->payload->send_initial_metadata.send_initial_metadata, in hc_start_transport_stream_op_batch()
389 batch->payload->send_initial_metadata.send_initial_metadata, in hc_start_transport_stream_op_batch()
[all …]
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/_channel/ |
| D | _channel_rpc.py | 23 def send_initial_metadata(self, initial_metadata): member in _UnaryUnary
24 self._rpc_state.send_initial_metadata(initial_metadata)
39 def send_initial_metadata(self, initial_metadata): member in _UnaryStream
40 self._rpc_state.send_initial_metadata(initial_metadata)
57 def send_initial_metadata(self, initial_metadata): member in _StreamUnary
58 self._rpc_state.send_initial_metadata(initial_metadata)
79 def send_initial_metadata(self, initial_metadata): member in _StreamStream
80 self._rpc_state.send_initial_metadata(initial_metadata)
|
| /external/rust/crates/grpcio-sys/ |
| D | grpc_wrap.cc | 79 grpc_metadata_array send_initial_metadata; member
247 &(ctx->send_initial_metadata)); in grpcwrap_batch_context_destroy()
478 grpcwrap_metadata_array_move(&(ctx->send_initial_metadata), initial_metadata); in grpcwrap_call_start_unary()
479 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_unary()
480 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_unary()
481 ctx->send_initial_metadata.metadata; in grpcwrap_call_start_unary()
528 grpcwrap_metadata_array_move(&(ctx->send_initial_metadata), initial_metadata); in grpcwrap_call_start_client_streaming()
529 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcwrap_call_start_client_streaming()
530 ops[0].data.send_initial_metadata.metadata = in grpcwrap_call_start_client_streaming()
531 ctx->send_initial_metadata.metadata; in grpcwrap_call_start_client_streaming()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 57 if (batch->send_initial_metadata && in client_authority_start_transport_stream_op_batch()
58 batch->payload->send_initial_metadata.send_initial_metadata->idx.named in client_authority_start_transport_stream_op_batch()
61 batch->payload->send_initial_metadata.send_initial_metadata, in client_authority_start_transport_stream_op_batch()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/common/ |
| D | channel_filter.h | 136 op->send_initial_metadata in TransportStreamOpBatch()
137 ? op->payload->send_initial_metadata.send_initial_metadata in TransportStreamOpBatch()
157 MetadataBatch* send_initial_metadata() { in send_initial_metadata() function
158 return op_->send_initial_metadata ? &send_initial_metadata_ : nullptr; in send_initial_metadata()
171 return op_->send_initial_metadata ? &op_->payload->send_initial_metadata in send_initial_metadata_flags()
211 if (op_->send_initial_metadata && in get_peer_string()
212 op_->payload->send_initial_metadata.peer_string != nullptr) { in get_peer_string()
213 return op_->payload->send_initial_metadata.peer_string; in get_peer_string()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | channel_filter.h | 136 op->send_initial_metadata in TransportStreamOpBatch()
137 ? op->payload->send_initial_metadata.send_initial_metadata in TransportStreamOpBatch()
157 MetadataBatch* send_initial_metadata() { in send_initial_metadata() function
158 return op_->send_initial_metadata ? &send_initial_metadata_ : nullptr; in send_initial_metadata()
171 return op_->send_initial_metadata ? &op_->payload->send_initial_metadata in send_initial_metadata_flags()
211 if (op_->send_initial_metadata && in get_peer_string()
212 op_->payload->send_initial_metadata.peer_string != nullptr) { in get_peer_string()
213 return op_->payload->send_initial_metadata.peer_string; in get_peer_string()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 102 if (batch->send_initial_metadata) { in clr_start_transport_stream_op_batch()
105 batch->payload->send_initial_metadata.send_initial_metadata->list.head; in clr_start_transport_stream_op_batch()
128 batch->payload->send_initial_metadata.send_initial_metadata, in clr_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/csharp/ext/ |
| D | grpc_csharp_ext.c | 55 grpc_metadata_array send_initial_metadata; member
200 &(ctx->send_initial_metadata)); in grpcsharp_batch_context_reset()
570 grpcsharp_metadata_array_move(&(ctx->send_initial_metadata), in grpcsharp_call_start_unary()
572 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_unary()
573 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_unary()
574 ctx->send_initial_metadata.metadata; in grpcsharp_call_start_unary()
620 grpcsharp_metadata_array_move(&(ctx->send_initial_metadata), in grpcsharp_call_start_client_streaming()
622 ops[0].data.send_initial_metadata.count = ctx->send_initial_metadata.count; in grpcsharp_call_start_client_streaming()
623 ops[0].data.send_initial_metadata.metadata = in grpcsharp_call_start_client_streaming()
624 ctx->send_initial_metadata.metadata; in grpcsharp_call_start_client_streaming()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 854 grpc_metadata_batch send_initial_metadata; member
976 grpc_metadata_batch send_initial_metadata; member
1017 if (batch->send_initial_metadata) { in maybe_cache_send_ops_for_batch()
1020 grpc_metadata_batch* send_initial_metadata = in maybe_cache_send_ops_for_batch() local
1021 batch->payload->send_initial_metadata.send_initial_metadata; in maybe_cache_send_ops_for_batch()
1024 sizeof(grpc_linked_mdelem) * send_initial_metadata->list.count); in maybe_cache_send_ops_for_batch()
1025 grpc_metadata_batch_copy(send_initial_metadata, in maybe_cache_send_ops_for_batch()
1026 &calld->send_initial_metadata, in maybe_cache_send_ops_for_batch()
1029 batch->payload->send_initial_metadata.send_initial_metadata_flags; in maybe_cache_send_ops_for_batch()
1030 calld->peer_string = batch->payload->send_initial_metadata.peer_string; in maybe_cache_send_ops_for_batch()
[all …]
|
| /external/grpc-grpc/src/ruby/lib/grpc/generic/ |
| D | active_call.rb | 119 def send_initial_metadata(new_metadata = {}) method in GRPC.ActiveCall
192 send_initial_metadata
208 send_initial_metadata
396 send_initial_metadata(metadata)
498 send_initial_metadata(metadata)
617 merge_metadata_to_send(metadata) && send_initial_metadata
|
| /external/grpc-grpc/src/objective-c/GRPCClient/private/ |
| D | GRPCWrappedCall.m | 66 _op.data.send_initial_metadata.count = metadata.count;
67 _op.data.send_initial_metadata.metadata = metadata.grpc_metadataArray;
68 _op.data.send_initial_metadata.maybe_compression_level.is_set = false;
69 _op.data.send_initial_metadata.maybe_compression_level.level = 0;
77 for (int i = 0; i < _op.data.send_initial_metadata.count; i++) {
78 grpc_slice_unref(_op.data.send_initial_metadata.metadata[i].key);
79 grpc_slice_unref(_op.data.send_initial_metadata.metadata[i].value);
81 gpr_free(_op.data.send_initial_metadata.metadata);
|
| /external/grpc-grpc/src/core/ext/filters/http/ |
| D | client_authority_filter.cc | 56 batch->payload->send_initial_metadata.send_initial_metadata; in authority_start_transport_stream_op_batch()
58 if (batch->send_initial_metadata && in authority_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/testing/ |
| D | _client_test.py | 60 rpc.send_initial_metadata(())
76 rpc.send_initial_metadata(())
90 rpc.send_initial_metadata(())
174 rpc.send_initial_metadata(())
196 rpc.send_initial_metadata(((
246 rpc.send_initial_metadata(())
287 rpc.send_initial_metadata(())
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | filter_status_code.cc | 153 op->data.send_initial_metadata.count = 0; in test_request()
154 op->data.send_initial_metadata.metadata = nullptr; in test_request()
193 op->data.send_initial_metadata.count = 0; in test_request()
264 if (op->send_initial_metadata) { in server_start_transport_stream_op_batch()
265 auto* batch = op->payload->send_initial_metadata.send_initial_metadata; in server_start_transport_stream_op_batch()
|
| D | compressed_payload.cc | 159 op->data.send_initial_metadata.count = 1; in request_for_disabled_algorithm()
160 op->data.send_initial_metadata.metadata = client_metadata; in request_for_disabled_algorithm()
162 op->data.send_initial_metadata.count = 0; in request_for_disabled_algorithm()
198 op->data.send_initial_metadata.count = 0; in request_for_disabled_algorithm()
348 op->data.send_initial_metadata.count = 1; in request_with_payload_template()
349 op->data.send_initial_metadata.metadata = client_init_metadata; in request_with_payload_template()
351 op->data.send_initial_metadata.count = 0; in request_with_payload_template()
391 op->data.send_initial_metadata.count = 0; in request_with_payload_template()
393 op->data.send_initial_metadata.maybe_compression_level.is_set = true; in request_with_payload_template()
394 op->data.send_initial_metadata.maybe_compression_level.level = in request_with_payload_template()
|
| D | stream_compression_compressed_payload.cc | 159 op->data.send_initial_metadata.count = 1; in request_for_disabled_algorithm()
160 op->data.send_initial_metadata.metadata = client_metadata; in request_for_disabled_algorithm()
162 op->data.send_initial_metadata.count = 0; in request_for_disabled_algorithm()
198 op->data.send_initial_metadata.count = 0; in request_for_disabled_algorithm()
355 op->data.send_initial_metadata.count = 1; in request_with_payload_template()
356 op->data.send_initial_metadata.metadata = client_init_metadata; in request_with_payload_template()
358 op->data.send_initial_metadata.count = 0; in request_with_payload_template()
402 op->data.send_initial_metadata.count = 0; in request_with_payload_template()
404 op->data.send_initial_metadata.maybe_compression_level.is_set = true; in request_with_payload_template()
405 op->data.send_initial_metadata.maybe_compression_level.level = in request_with_payload_template()
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | writing.cc | 411 s->sent_initial_metadata, s->send_initial_metadata != nullptr, in StreamWriteContext()
419 if (s_->send_initial_metadata == nullptr) return; in FlushInitialMetadata()
430 is_default_initial_metadata(s_->send_initial_metadata)) { in FlushInitialMetadata()
444 s_->send_initial_metadata, &hopt, &t_->outbuf); in FlushInitialMetadata()
449 s_->send_initial_metadata = nullptr; in FlushInitialMetadata()
557 if (s_->send_initial_metadata->idx.named.status != nullptr) { in ConvertInitialMetadataToTrailingMetadata()
560 &s_->send_initial_metadata->idx.named.status->md; in ConvertInitialMetadataToTrailingMetadata()
562 if (s_->send_initial_metadata->idx.named.content_type != nullptr) { in ConvertInitialMetadataToTrailingMetadata()
565 &s_->send_initial_metadata->idx.named.content_type->md; in ConvertInitialMetadataToTrailingMetadata()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | writing.cc | 434 s->sent_initial_metadata, s->send_initial_metadata != nullptr, in StreamWriteContext()
442 if (s_->send_initial_metadata == nullptr) return; in FlushInitialMetadata()
453 is_default_initial_metadata(s_->send_initial_metadata)) { in FlushInitialMetadata()
467 s_->send_initial_metadata, &hopt, &t_->outbuf); in FlushInitialMetadata()
472 s_->send_initial_metadata = nullptr; in FlushInitialMetadata()
595 if (s_->send_initial_metadata->idx.named.status != nullptr) { in ConvertInitialMetadataToTrailingMetadata()
598 &s_->send_initial_metadata->idx.named.status->md; in ConvertInitialMetadataToTrailingMetadata()
600 if (s_->send_initial_metadata->idx.named.content_type != nullptr) { in ConvertInitialMetadataToTrailingMetadata()
603 &s_->send_initial_metadata->idx.named.content_type->md; in ConvertInitialMetadataToTrailingMetadata()
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 345 if (op->send_initial_metadata) { in hs_mutate_op()
350 op->payload->send_initial_metadata.send_initial_metadata, in hs_mutate_op()
354 op->payload->send_initial_metadata.send_initial_metadata, in hs_mutate_op()
360 elem, op->payload->send_initial_metadata.send_initial_metadata)); in hs_mutate_op()
|
| /external/grpc-grpc/src/python/grpcio_testing/grpc_testing/ |
| D | __init__.py | 31 def send_initial_metadata(self, initial_metadata): member in UnaryUnaryChannelRpc
65 def send_initial_metadata(self, initial_metadata): member in UnaryStreamChannelRpc
107 def send_initial_metadata(self, initial_metadata): member in StreamUnaryChannelRpc
161 def send_initial_metadata(self, initial_metadata): member in StreamStreamChannelRpc
|
| /external/grpc-grpc/src/python/grpcio_tests/tests/unit/ |
| D | _metadata_test.py | 103 servicer_context.send_initial_metadata(_INITIAL_METADATA)
110 servicer_context.send_initial_metadata(_INITIAL_METADATA)
118 servicer_context.send_initial_metadata(_INITIAL_METADATA)
128 servicer_context.send_initial_metadata(_INITIAL_METADATA)
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | transport.h | 165 : send_initial_metadata(false), in grpc_transport_stream_op_batch()
189 bool send_initial_metadata : 1; member
231 grpc_metadata_batch* send_initial_metadata = nullptr; member
241 } send_initial_metadata; member
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 418 if (op->send_initial_metadata) { in hs_mutate_op()
424 op->payload->send_initial_metadata.send_initial_metadata, in hs_mutate_op()
428 op->payload->send_initial_metadata.send_initial_metadata, in hs_mutate_op()
434 op->payload->send_initial_metadata.send_initial_metadata)); in hs_mutate_op()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_chttp2_transport.cc | 337 op.send_initial_metadata = true; in BM_StreamCreateSendInitialMetadataDestroy()
338 op.payload->send_initial_metadata.send_initial_metadata = &b; in BM_StreamCreateSendInitialMetadataDestroy()
444 op.send_initial_metadata = true; in BM_TransportStreamSend()
445 op.payload->send_initial_metadata.send_initial_metadata = &b; in BM_TransportStreamSend()
607 op.send_initial_metadata = true; in BM_TransportStreamRecv()
608 op.payload->send_initial_metadata.send_initial_metadata = &b; in BM_TransportStreamRecv()
|