| /external/grpc-grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 37 grpc_metadata_batch* recv_initial_metadata; member
63 if (get_user_agent_mdelem(calld->recv_initial_metadata, &md)) { in recv_initial_metadata_ready()
83 if (op->recv_initial_metadata) { in start_transport_stream_op_batch()
85 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in start_transport_stream_op_batch()
86 op->payload->recv_initial_metadata.recv_initial_metadata_ready = in start_transport_stream_op_batch()
88 calld->recv_initial_metadata = in start_transport_stream_op_batch()
89 op->payload->recv_initial_metadata.recv_initial_metadata; in start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | channel_filter.h | 144 op->recv_initial_metadata in TransportStreamOpBatch()
145 ? op->payload->recv_initial_metadata.recv_initial_metadata in TransportStreamOpBatch()
163 MetadataBatch* recv_initial_metadata() { in recv_initial_metadata() function
164 return op_->recv_initial_metadata ? &recv_initial_metadata_ : nullptr; in recv_initial_metadata()
177 return op_->recv_initial_metadata in recv_initial_metadata_ready()
178 ? op_->payload->recv_initial_metadata.recv_initial_metadata_ready in recv_initial_metadata_ready()
182 op_->payload->recv_initial_metadata.recv_initial_metadata_ready = closure; in set_recv_initial_metadata_ready()
214 } else if (op_->recv_initial_metadata && in get_peer_string()
215 op_->payload->recv_initial_metadata.peer_string != nullptr) { in get_peer_string()
216 return op_->payload->recv_initial_metadata.peer_string; in get_peer_string()
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 263 grpc_metadata_batch* recv_initial_metadata; member
296 start_timer_if_needed(elem, calld->recv_initial_metadata->deadline); in recv_initial_metadata_ready()
312 if (op->recv_initial_metadata) { in server_start_transport_stream_op_batch()
314 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in server_start_transport_stream_op_batch()
315 calld->recv_initial_metadata = in server_start_transport_stream_op_batch()
316 op->payload->recv_initial_metadata.recv_initial_metadata; in server_start_transport_stream_op_batch()
320 op->payload->recv_initial_metadata.recv_initial_metadata_ready = in server_start_transport_stream_op_batch()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_call_create.cc | 200 op->data.recv_initial_metadata.recv_initial_metadata = in BM_LameChannelCallCreateCore()
279 op->data.recv_initial_metadata.recv_initial_metadata = in BM_LameChannelCallCreateCoreSeparateBatch()
629 if (op->recv_initial_metadata) { in StartTransportStreamOp()
630 closures.Add(op->payload->recv_initial_metadata.recv_initial_metadata_ready, in StartTransportStreamOp()
752 grpc_metadata_array recv_initial_metadata; in BM_IsolatedCall_Unary() local
753 grpc_metadata_array_init(&recv_initial_metadata); in BM_IsolatedCall_Unary()
763 ops[3].data.recv_initial_metadata.recv_initial_metadata = in BM_IsolatedCall_Unary()
764 &recv_initial_metadata; in BM_IsolatedCall_Unary()
782 grpc_metadata_array_destroy(&recv_initial_metadata); in BM_IsolatedCall_Unary()
795 grpc_metadata_array recv_initial_metadata; in BM_IsolatedCall_StreamingSend() local
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 56 grpc_metadata_batch* recv_initial_metadata; member
283 err = hs_filter_incoming_metadata(elem, calld->recv_initial_metadata); in hs_recv_initial_metadata_ready()
364 if (op->recv_initial_metadata) { in hs_mutate_op()
366 GPR_ASSERT(op->payload->recv_initial_metadata.recv_flags != nullptr); in hs_mutate_op()
367 calld->recv_initial_metadata = in hs_mutate_op()
368 op->payload->recv_initial_metadata.recv_initial_metadata; in hs_mutate_op()
370 op->payload->recv_initial_metadata.recv_flags; in hs_mutate_op()
372 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in hs_mutate_op()
373 op->payload->recv_initial_metadata.recv_initial_metadata_ready = in hs_mutate_op()
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 114 batch->payload->recv_initial_metadata.recv_initial_metadata, in on_md_processing_done_inner()
180 batch->payload->recv_initial_metadata.recv_initial_metadata); in recv_initial_metadata_ready()
201 if (batch->recv_initial_metadata) { in auth_start_transport_stream_op_batch()
205 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in auth_start_transport_stream_op_batch()
206 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in auth_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 447 s->recv_initial_md_op->payload->recv_initial_metadata in fail_helper_locked()
448 .recv_initial_metadata, in fail_helper_locked()
449 s->recv_initial_md_op->payload->recv_initial_metadata.recv_flags, in fail_helper_locked()
456 if (s->recv_initial_md_op->payload->recv_initial_metadata in fail_helper_locked()
461 *s->recv_initial_md_op->payload->recv_initial_metadata in fail_helper_locked()
467 GRPC_CLOSURE_SCHED(s->recv_initial_md_op->payload->recv_initial_metadata in fail_helper_locked()
686 s->recv_initial_md_op->payload->recv_initial_metadata in op_state_machine()
687 .recv_initial_metadata, in op_state_machine()
688 s->recv_initial_md_op->payload->recv_initial_metadata.recv_flags, in op_state_machine()
690 s->recv_initial_md_op->payload->recv_initial_metadata in op_state_machine()
[all …]
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 115 if (batch->recv_initial_metadata) { in start_transport_stream_op_batch()
117 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in start_transport_stream_op_batch()
121 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in start_transport_stream_op_batch()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | filter_causes_close.cc | 142 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in test_request()
212 if (op->recv_initial_metadata) { in start_transport_stream_op_batch()
214 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in start_transport_stream_op_batch()
215 op->payload->recv_initial_metadata.recv_initial_metadata_ready = in start_transport_stream_op_batch()
|
| D | max_concurrent_streams.cc | 125 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in simple_request_body()
285 op->data.recv_initial_metadata.recv_initial_metadata = in test_max_concurrent_streams()
319 op->data.recv_initial_metadata.recv_initial_metadata = in test_max_concurrent_streams()
527 op->data.recv_initial_metadata.recv_initial_metadata = in test_max_concurrent_streams_with_timeout_on_first()
565 op->data.recv_initial_metadata.recv_initial_metadata = in test_max_concurrent_streams_with_timeout_on_first()
723 op->data.recv_initial_metadata.recv_initial_metadata = in test_max_concurrent_streams_with_timeout_on_second()
761 op->data.recv_initial_metadata.recv_initial_metadata = in test_max_concurrent_streams_with_timeout_on_second()
|
| D | filter_call_init_fails.cc | 148 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in test_server_channel_filter()
242 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in test_client_channel_filter()
331 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in test_client_subchannel_filter()
|
| D | max_connection_age.cc | 135 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in test_max_age_forcibly_close()
277 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in test_max_age_gracefully_close()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 141 grpc_metadata_batch* recv_initial_metadata; member
707 GPR_ASSERT(calld->recv_initial_metadata->idx.named.path != nullptr); in server_on_recv_initial_metadata()
708 GPR_ASSERT(calld->recv_initial_metadata->idx.named.authority != nullptr); in server_on_recv_initial_metadata()
710 GRPC_MDVALUE(calld->recv_initial_metadata->idx.named.path->md)); in server_on_recv_initial_metadata()
712 GRPC_MDVALUE(calld->recv_initial_metadata->idx.named.authority->md)); in server_on_recv_initial_metadata()
715 grpc_metadata_batch_remove(calld->recv_initial_metadata, in server_on_recv_initial_metadata()
716 calld->recv_initial_metadata->idx.named.path); in server_on_recv_initial_metadata()
718 calld->recv_initial_metadata, in server_on_recv_initial_metadata()
719 calld->recv_initial_metadata->idx.named.authority); in server_on_recv_initial_metadata()
723 op_deadline = calld->recv_initial_metadata->deadline; in server_on_recv_initial_metadata()
[all …]
|
| D | lame_client.cc | 82 if (op->recv_initial_metadata) { in lame_start_transport_stream_op_batch()
84 op->payload->recv_initial_metadata.recv_initial_metadata); in lame_start_transport_stream_op_batch()
|
| D | call_log_batch.cc | 83 op->data.recv_initial_metadata.recv_initial_metadata); in grpc_op_string()
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 53 grpc_metadata_batch* recv_initial_metadata; member
155 error = client_filter_incoming_metadata(elem, calld->recv_initial_metadata); in recv_initial_metadata_ready()
309 if (batch->recv_initial_metadata) { in hc_start_transport_stream_op_batch()
311 calld->recv_initial_metadata = in hc_start_transport_stream_op_batch()
312 batch->payload->recv_initial_metadata.recv_initial_metadata; in hc_start_transport_stream_op_batch()
314 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in hc_start_transport_stream_op_batch()
315 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in hc_start_transport_stream_op_batch()
|
| /external/grpc-grpc/test/core/fling/ |
| D | client.cc | 65 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in init_ping_pong_request()
105 stream_init_ops[1].data.recv_initial_metadata.recv_initial_metadata = in init_ping_pong_stream()
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.h | 149 bool recv_initial_metadata : 1; member
195 grpc_metadata_batch* recv_initial_metadata; member
212 } recv_initial_metadata; member
|
| /external/grpc-grpc/src/csharp/ext/ |
| D | grpc_csharp_ext.c | 60 grpc_metadata_array recv_initial_metadata; member
207 grpcsharp_metadata_array_destroy_metadata_only(&(ctx->recv_initial_metadata)); in grpcsharp_batch_context_reset()
249 return &(ctx->recv_initial_metadata); in grpcsharp_batch_context_recv_initial_metadata()
589 ops[3].data.recv_initial_metadata.recv_initial_metadata = in grpcsharp_call_start_unary()
590 &(ctx->recv_initial_metadata); in grpcsharp_call_start_unary()
629 ops[1].data.recv_initial_metadata.recv_initial_metadata = in grpcsharp_call_start_client_streaming()
630 &(ctx->recv_initial_metadata); in grpcsharp_call_start_client_streaming()
727 ops[0].data.recv_initial_metadata.recv_initial_metadata = in grpcsharp_call_recv_initial_metadata()
728 &(ctx->recv_initial_metadata); in grpcsharp_call_recv_initial_metadata()
|
| /external/grpc-grpc/test/core/memory_usage/ |
| D | client.cc | 71 op->data.recv_initial_metadata.recv_initial_metadata = in init_ping_pong_request()
129 op->data.recv_initial_metadata.recv_initial_metadata = in send_snapshot_request()
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 85 if (batch->recv_initial_metadata) return &calld->on_complete[3]; in get_state_for_batch()
104 if (batch->recv_initial_metadata) { in con_start_transport_stream_op_batch()
108 &batch->payload->recv_initial_metadata.recv_initial_metadata_ready); in con_start_transport_stream_op_batch()
|
| /external/grpc-grpc/test/core/bad_ssl/ |
| D | bad_ssl_test.cc | 89 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in run_test()
|
| /external/grpc-grpc/test/core/surface/ |
| D | lame_client_test.cc | 111 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv; in main()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 862 grpc_metadata_batch recv_initial_metadata; member
1137 if (batch->recv_initial_metadata) return 3; in get_batch_index()
1324 (!batch->recv_initial_metadata || in maybe_clear_pending_batch()
1325 batch->payload->recv_initial_metadata.recv_initial_metadata_ready == in maybe_clear_pending_batch()
1587 if (batch_data->batch.recv_initial_metadata) { in batch_data_unref()
1588 grpc_metadata_batch_destroy(&retry_state->recv_initial_metadata); in batch_data_unref()
1611 return batch->recv_initial_metadata && in invoke_recv_initial_metadata_callback()
1612 batch->payload->recv_initial_metadata in invoke_recv_initial_metadata_callback()
1622 &retry_state->recv_initial_metadata, in invoke_recv_initial_metadata_callback()
1623 pending->batch->payload->recv_initial_metadata.recv_initial_metadata); in invoke_recv_initial_metadata_callback()
[all …]
|
| /external/grpc-grpc/test/core/end2end/fuzzers/ |
| D | client_fuzzer.cc | 96 op->data.recv_initial_metadata.recv_initial_metadata = in LLVMFuzzerTestOneInput()
|