| /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/rust/crates/grpcio-sys/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()
84 if (op->recv_initial_metadata) { in cronet_compression_start_transport_stream_op_batch()
86 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in cronet_compression_start_transport_stream_op_batch()
87 op->payload->recv_initial_metadata.recv_initial_metadata_ready = in cronet_compression_start_transport_stream_op_batch()
89 calld->recv_initial_metadata = in cronet_compression_start_transport_stream_op_batch()
90 op->payload->recv_initial_metadata.recv_initial_metadata; in cronet_compression_start_transport_stream_op_batch()
|
| /external/rust/crates/grpcio-sys/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/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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 264 grpc_metadata_batch* recv_initial_metadata; member
298 start_timer_if_needed(elem, calld->recv_initial_metadata->deadline); in recv_initial_metadata_ready()
315 if (op->recv_initial_metadata) { in deadline_server_start_transport_stream_op_batch()
317 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in deadline_server_start_transport_stream_op_batch()
318 calld->recv_initial_metadata = in deadline_server_start_transport_stream_op_batch()
319 op->payload->recv_initial_metadata.recv_initial_metadata; in deadline_server_start_transport_stream_op_batch()
323 op->payload->recv_initial_metadata.recv_initial_metadata_ready = in deadline_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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 79 grpc_metadata_batch* recv_initial_metadata = nullptr; member
338 err = hs_filter_incoming_metadata(elem, calld->recv_initial_metadata); in hs_recv_initial_metadata_ready()
438 if (op->recv_initial_metadata) { in hs_mutate_op()
440 GPR_ASSERT(op->payload->recv_initial_metadata.recv_flags != nullptr); in hs_mutate_op()
441 calld->recv_initial_metadata = in hs_mutate_op()
442 op->payload->recv_initial_metadata.recv_initial_metadata; in hs_mutate_op()
444 op->payload->recv_initial_metadata.recv_flags; in hs_mutate_op()
446 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in hs_mutate_op()
447 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/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 453 s->recv_initial_md_op->payload->recv_initial_metadata in fail_helper_locked()
454 .recv_initial_metadata, in fail_helper_locked()
455 s->recv_initial_md_op->payload->recv_initial_metadata.recv_flags, in fail_helper_locked()
462 if (s->recv_initial_md_op->payload->recv_initial_metadata in fail_helper_locked()
467 *s->recv_initial_md_op->payload->recv_initial_metadata in fail_helper_locked()
475 s->recv_initial_md_op->payload->recv_initial_metadata in fail_helper_locked()
698 s->recv_initial_md_op->payload->recv_initial_metadata in op_state_machine_locked()
699 .recv_initial_metadata, in op_state_machine_locked()
700 s->recv_initial_md_op->payload->recv_initial_metadata.recv_flags, in op_state_machine_locked()
702 s->recv_initial_md_op->payload->recv_initial_metadata in op_state_machine_locked()
[all …]
|
| /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/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 151 batch->payload->recv_initial_metadata.recv_initial_metadata, in on_md_processing_done_inner()
226 batch->payload->recv_initial_metadata.recv_initial_metadata); in recv_initial_metadata_ready()
265 if (batch->recv_initial_metadata) { in server_auth_start_transport_stream_op_batch()
269 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in server_auth_start_transport_stream_op_batch()
270 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in server_auth_start_transport_stream_op_batch()
|
| /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()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 133 if (batch->recv_initial_metadata) { in clr_start_transport_stream_op_batch()
135 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in clr_start_transport_stream_op_batch()
139 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in clr_start_transport_stream_op_batch()
|
| /external/rust/crates/grpcio-sys/ |
| D | grpc_wrap.cc | 84 grpc_metadata_array recv_initial_metadata; member
254 grpcwrap_metadata_array_destroy_metadata_only(&(ctx->recv_initial_metadata)); in grpcwrap_batch_context_destroy()
284 return &(ctx->recv_initial_metadata); in grpcwrap_batch_context_recv_initial_metadata()
496 ops[3].data.recv_initial_metadata.recv_initial_metadata = in grpcwrap_call_start_unary()
497 &(ctx->recv_initial_metadata); in grpcwrap_call_start_unary()
536 ops[1].data.recv_initial_metadata.recv_initial_metadata = in grpcwrap_call_start_client_streaming()
537 &(ctx->recv_initial_metadata); in grpcwrap_call_start_client_streaming()
633 ops[0].data.recv_initial_metadata.recv_initial_metadata = in grpcwrap_call_recv_initial_metadata()
634 &(ctx->recv_initial_metadata); in grpcwrap_call_recv_initial_metadata()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | transport.h | 168 recv_initial_metadata(false), in grpc_transport_stream_op_batch()
198 bool recv_initial_metadata : 1; member
274 grpc_metadata_batch* recv_initial_metadata = nullptr; member
291 } recv_initial_metadata; member
|
| /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 …]
|
| /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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 83 grpc_metadata_batch* recv_initial_metadata; member
189 error = client_filter_incoming_metadata(calld->recv_initial_metadata); in recv_initial_metadata_ready()
359 if (batch->recv_initial_metadata) { in http_client_start_transport_stream_op_batch()
361 calld->recv_initial_metadata = in http_client_start_transport_stream_op_batch()
362 batch->payload->recv_initial_metadata.recv_initial_metadata; in http_client_start_transport_stream_op_batch()
364 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in http_client_start_transport_stream_op_batch()
365 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in http_client_start_transport_stream_op_batch()
|
| /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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_decompress_filter.cc | 326 if (batch->recv_initial_metadata) { in DecompressStartTransportStreamOpBatch()
328 batch->payload->recv_initial_metadata.recv_initial_metadata; in DecompressStartTransportStreamOpBatch()
330 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in DecompressStartTransportStreamOpBatch()
331 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in DecompressStartTransportStreamOpBatch()
|
| /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
|