Home
last modified time | relevance | path

Searched refs:send_initial_metadata (Results 1 – 25 of 152) sorted by relevance

1234567

/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc258 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.py23 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/grpc-grpc/src/csharp/ext/
Dgrpc_csharp_ext.c55 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/cpp/common/
Dchannel_filter.h136 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/core/ext/filters/client_channel/
Dclient_channel.cc854 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/objective-c/GRPCClient/private/
DGRPCWrappedCall.m66 _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/ruby/lib/grpc/generic/
Dactive_call.rb119 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/python/grpcio_tests/tests/testing/
D_client_test.py60 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/
Dstream_compression_compressed_payload.cc159 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()
Dcompressed_payload.cc159 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()
Dfilter_status_code.cc153 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()
Dworkaround_cronet_compression.cc172 op->data.send_initial_metadata.count = 1; in request_with_payload_template()
173 op->data.send_initial_metadata.metadata = client_init_metadata; in request_with_payload_template()
175 op->data.send_initial_metadata.count = 0; in request_with_payload_template()
215 op->data.send_initial_metadata.count = 0; in request_with_payload_template()
217 op->data.send_initial_metadata.maybe_compression_level.is_set = true; in request_with_payload_template()
218 op->data.send_initial_metadata.maybe_compression_level.level = in request_with_payload_template()
Dmax_connection_age.cc125 op->data.send_initial_metadata.count = 0; in test_max_age_forcibly_close()
126 op->data.send_initial_metadata.metadata = nullptr; in test_max_age_forcibly_close()
176 op->data.send_initial_metadata.count = 0; in test_max_age_forcibly_close()
267 op->data.send_initial_metadata.count = 0; in test_max_age_gracefully_close()
268 op->data.send_initial_metadata.metadata = nullptr; in test_max_age_gracefully_close()
309 op->data.send_initial_metadata.count = 0; in test_max_age_gracefully_close()
Dmax_concurrent_streams.cc116 op->data.send_initial_metadata.count = 0; in simple_request_body()
150 op->data.send_initial_metadata.count = 0; in simple_request_body()
263 op->data.send_initial_metadata.count = 0; in test_max_concurrent_streams()
297 op->data.send_initial_metadata.count = 0; in test_max_concurrent_streams()
355 op->data.send_initial_metadata.count = 0; in test_max_concurrent_streams()
394 op->data.send_initial_metadata.count = 0; in test_max_concurrent_streams()
505 op->data.send_initial_metadata.count = 0; in test_max_concurrent_streams_with_timeout_on_first()
543 op->data.send_initial_metadata.count = 0; in test_max_concurrent_streams_with_timeout_on_first()
589 op->data.send_initial_metadata.count = 0; in test_max_concurrent_streams_with_timeout_on_first()
701 op->data.send_initial_metadata.count = 0; in test_max_concurrent_streams_with_timeout_on_second()
[all …]
Dbad_ping.cc124 op->data.send_initial_metadata.count = 0; in test_bad_ping()
125 op->data.send_initial_metadata.metadata = nullptr; in test_bad_ping()
174 op->data.send_initial_metadata.count = 0; in test_bad_ping()
283 op->data.send_initial_metadata.count = 0; in test_pings_without_data()
284 op->data.send_initial_metadata.metadata = nullptr; in test_pings_without_data()
330 op->data.send_initial_metadata.count = 0; in test_pings_without_data()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dwriting.cc411 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/grpc-grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc56 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/core/ext/filters/http/server/
Dhttp_server_filter.cc345 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/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc337 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()
/external/grpc-grpc/src/python/grpcio_testing/grpc_testing/
D__init__.py31 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.py103 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/grpc-grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc106 GPR_ASSERT(batch->send_initial_metadata); in on_credentials_metadata()
108 batch->payload->send_initial_metadata.send_initial_metadata; in on_credentials_metadata()
294 if (batch->send_initial_metadata) { in auth_start_transport_stream_op_batch()
296 batch->payload->send_initial_metadata.send_initial_metadata; in auth_start_transport_stream_op_batch()
/external/grpc-grpc/test/core/end2end/
Dinvalid_call_argument_test.cc97 op->data.send_initial_metadata.count = 0; in prepare_test()
162 op->data.send_initial_metadata.count = 0; in test_non_null_reserved_on_op()
181 op->data.send_initial_metadata.count = 0; in test_send_initial_metadata_more_than_once()
193 op->data.send_initial_metadata.count = 0; in test_send_initial_metadata_more_than_once()
212 op->data.send_initial_metadata.count = static_cast<size_t>(INT_MAX) + 1; in test_too_many_metadata()
231 op->data.send_initial_metadata.count = 0; in test_send_null_message()
258 op->data.send_initial_metadata.count = 0; in test_send_messages_at_the_same_time()
599 op->data.send_initial_metadata.count = 1; in test_invalid_initial_metadata_reserved_key()
600 op->data.send_initial_metadata.metadata = &metadata; in test_invalid_initial_metadata_reserved_key()
/external/grpc-grpc/test/core/fling/
Dserver.cc95 op->data.send_initial_metadata.count = 0; in handle_unary_method()
121 static void send_initial_metadata(void) { in send_initial_metadata() function
126 metadata_send_op.data.send_initial_metadata.count = 0; in send_initial_metadata()
263 send_initial_metadata(); in main()
/external/grpc-grpc/src/cpp/ext/filters/census/
Dclient_filter.cc83 if (op->send_initial_metadata() != nullptr) { in StartTransportStreamOpBatch()
94 op->send_initial_metadata()->batch(), &tracing_bin_, in StartTransportStreamOpBatch()
106 op->send_initial_metadata()->batch(), &stats_bin_, in StartTransportStreamOpBatch()

1234567