| /external/grpc-grpc/src/core/ext/filters/workarounds/ |
| workaround_cronet_compression_filter.cc | 37 grpc_metadata_batch* recv_initial_metadata; member in struct:__anon23001::call_data
63 if (get_user_agent_mdelem(calld->recv_initial_metadata, &md)) {
83 if (op->recv_initial_metadata) {
85 op->payload->recv_initial_metadata.recv_initial_metadata_ready;
86 op->payload->recv_initial_metadata.recv_initial_metadata_ready =
88 calld->recv_initial_metadata =
89 op->payload->recv_initial_metadata.recv_initial_metadata;
|
| /external/grpc-grpc/src/cpp/common/ |
| channel_filter.h | 144 op->recv_initial_metadata
145 ? op->payload->recv_initial_metadata.recv_initial_metadata
163 MetadataBatch* recv_initial_metadata() { function in class:grpc::TransportStreamOpBatch
164 return op_->recv_initial_metadata ? &recv_initial_metadata_ : nullptr;
177 return op_->recv_initial_metadata
178 ? op_->payload->recv_initial_metadata.recv_initial_metadata_ready
182 op_->payload->recv_initial_metadata.recv_initial_metadata_ready = closure;
214 } else if (op_->recv_initial_metadata &&
215 op_->payload->recv_initial_metadata.peer_string != nullptr)
[all...] |
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| client_load_reporting_filter.cc | 46 // State for intercepting recv_initial_metadata.
114 // Intercept recv_initial_metadata.
115 if (batch->recv_initial_metadata) {
117 batch->payload->recv_initial_metadata.recv_initial_metadata_ready;
121 batch->payload->recv_initial_metadata.recv_initial_metadata_ready =
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| deadline_filter.cc | 263 grpc_metadata_batch* recv_initial_metadata; member in struct:server_call_data
296 start_timer_if_needed(elem, calld->recv_initial_metadata->deadline);
312 if (op->recv_initial_metadata) {
314 op->payload->recv_initial_metadata.recv_initial_metadata_ready;
315 calld->recv_initial_metadata =
316 op->payload->recv_initial_metadata.recv_initial_metadata;
320 op->payload->recv_initial_metadata.recv_initial_metadata_ready =
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| http_server_filter.cc | 52 // State for intercepting recv_initial_metadata.
56 grpc_metadata_batch* recv_initial_metadata; member in struct:__anon22995::call_data
283 err = hs_filter_incoming_metadata(elem, calld->recv_initial_metadata);
312 // We've already seen the recv_initial_metadata callback, so
321 // We have not yet seen the recv_initial_metadata callback, so we
364 if (op->recv_initial_metadata) {
366 GPR_ASSERT(op->payload->recv_initial_metadata.recv_flags != nullptr);
367 calld->recv_initial_metadata =
368 op->payload->recv_initial_metadata.recv_initial_metadata;
[all...] |
| /external/grpc-grpc/src/core/lib/security/transport/ |
| server_auth_filter.cc | 114 batch->payload->recv_initial_metadata.recv_initial_metadata,
180 batch->payload->recv_initial_metadata.recv_initial_metadata);
201 if (batch->recv_initial_metadata) {
205 batch->payload->recv_initial_metadata.recv_initial_metadata_ready;
206 batch->payload->recv_initial_metadata.recv_initial_metadata_ready =
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| filter_causes_close.cc | 142 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
212 if (op->recv_initial_metadata) {
214 op->payload->recv_initial_metadata.recv_initial_metadata_ready;
215 op->payload->recv_initial_metadata.recv_initial_metadata_ready =
|
| max_concurrent_streams.cc | 125 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
285 op->data.recv_initial_metadata.recv_initial_metadata =
319 op->data.recv_initial_metadata.recv_initial_metadata =
527 op->data.recv_initial_metadata.recv_initial_metadata =
565 op->data.recv_initial_metadata.recv_initial_metadata
[all...] |
| bad_hostname.cc | 125 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
|
| negative_deadline.cc | 122 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
|
| filter_call_init_fails.cc | 148 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
242 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
331 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
|
| /external/grpc-grpc/src/core/lib/surface/ |
| lame_client.cc | 82 if (op->recv_initial_metadata) {
84 op->payload->recv_initial_metadata.recv_initial_metadata);
|
| call_log_batch.cc | 82 gpr_asprintf(&tmp, "RECV_INITIAL_METADATA ptr=%p",
83 op->data.recv_initial_metadata.recv_initial_metadata);
|
| server.cc | 141 grpc_metadata_batch* recv_initial_metadata; member in struct:__anon23235::call_data
707 GPR_ASSERT(calld->recv_initial_metadata->idx.named.path != nullptr);
708 GPR_ASSERT(calld->recv_initial_metadata->idx.named.authority != nullptr);
710 GRPC_MDVALUE(calld->recv_initial_metadata->idx.named.path->md));
712 GRPC_MDVALUE(calld->recv_initial_metadata->idx.named.authority->md));
715 grpc_metadata_batch_remove(calld->recv_initial_metadata,
716 calld->recv_initial_metadata->idx.named.path);
718 calld->recv_initial_metadata,
719 calld->recv_initial_metadata->idx.named.authority);
723 op_deadline = calld->recv_initial_metadata->deadline
[all...] |
| /external/grpc-grpc/src/core/lib/transport/ |
| transport.h | 128 The recv ops (recv_initial_metadata, recv_message, and
149 bool recv_initial_metadata : 1; member in struct:grpc_transport_stream_op_batch
195 grpc_metadata_batch* recv_initial_metadata; member in struct:grpc_transport_stream_op_batch_payload::__anon23255
209 // recv_initial_metadata op is completed. It must remain valid
212 } recv_initial_metadata; member in struct:grpc_transport_stream_op_batch_payload
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| bm_call_create.cc | 200 op->data.recv_initial_metadata.recv_initial_metadata =
279 op->data.recv_initial_metadata.recv_initial_metadata =
629 if (op->recv_initial_metadata) {
630 closures.Add(op->payload->recv_initial_metadata.recv_initial_metadata_ready,
631 GRPC_ERROR_NONE, "recv_initial_metadata");
752 grpc_metadata_array recv_initial_metadata; local
753 grpc_metadata_array_init(&recv_initial_metadata);
763 ops[3].data.recv_initial_metadata.recv_initial_metadata
795 grpc_metadata_array recv_initial_metadata; local
[all...] |
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| inproc_transport.cc | 447 s->recv_initial_md_op->payload->recv_initial_metadata
448 .recv_initial_metadata,
449 s->recv_initial_md_op->payload->recv_initial_metadata.recv_flags,
456 if (s->recv_initial_md_op->payload->recv_initial_metadata
461 *s->recv_initial_md_op->payload->recv_initial_metadata
467 GRPC_CLOSURE_SCHED(s->recv_initial_md_op->payload->recv_initial_metadata
686 s->recv_initial_md_op->payload->recv_initial_metadata
687 .recv_initial_metadata,
688 s->recv_initial_md_op->payload->recv_initial_metadata.recv_flags,
690 s->recv_initial_md_op->payload->recv_initial_metadata
[all...] |
| /external/grpc-grpc/test/core/fling/ |
| client.cc | 65 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
105 stream_init_ops[1].data.recv_initial_metadata.recv_initial_metadata =
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| http_client_filter.cc | 52 // State for handling recv_initial_metadata ops.
53 grpc_metadata_batch* recv_initial_metadata; member in struct:__anon22991::call_data
155 error = client_filter_incoming_metadata(elem, calld->recv_initial_metadata);
309 if (batch->recv_initial_metadata) {
311 calld->recv_initial_metadata =
312 batch->payload->recv_initial_metadata.recv_initial_metadata;
314 batch->payload->recv_initial_metadata.recv_initial_metadata_ready;
315 batch->payload->recv_initial_metadata.recv_initial_metadata_ready =
|
| /external/grpc-grpc/test/core/bad_ssl/ |
| bad_ssl_test.cc | 89 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
|
| /external/grpc-grpc/test/core/end2end/fuzzers/ |
| client_fuzzer.cc | 96 op->data.recv_initial_metadata.recv_initial_metadata =
|
| /external/grpc-grpc/test/core/surface/ |
| lame_client_test.cc | 111 op->data.recv_initial_metadata.recv_initial_metadata = &initial_metadata_recv;
|
| /external/grpc-grpc/test/core/memory_usage/ |
| client.cc | 71 op->data.recv_initial_metadata.recv_initial_metadata =
129 op->data.recv_initial_metadata.recv_initial_metadata =
|
| /external/grpc-grpc/src/core/lib/channel/ |
| connected_channel.cc | 85 if (batch->recv_initial_metadata) return &calld->on_complete[3];
104 if (batch->recv_initial_metadata) {
108 &batch->payload->recv_initial_metadata.recv_initial_metadata_ready);
|
| /external/grpc-grpc/src/core/ext/filters/load_reporting/ |
| server_load_reporting_filter.cc | 103 if (op->recv_initial_metadata() != nullptr) {
107 op->op()->payload->recv_initial_metadata.recv_initial_metadata;
251 "recv_initial_metadata filtering error"));
252 // If the LB token was not found in the recv_initial_metadata, only the
|
