| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| client_load_reporting_filter.cc | 47 grpc_closure recv_initial_metadata_ready; member in struct:__anon22969::call_data
62 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { function
117 batch->payload->recv_initial_metadata.recv_initial_metadata_ready;
118 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready,
119 recv_initial_metadata_ready, calld,
121 batch->payload->recv_initial_metadata.recv_initial_metadata_ready =
122 &calld->recv_initial_metadata_ready;
|
| /external/grpc-grpc/src/core/ext/filters/workarounds/ |
| workaround_cronet_compression_filter.cc | 33 // recv_initial_metadata_ready up-call on transport_stream_op, and remember to
35 grpc_closure recv_initial_metadata_ready; member in struct:__anon23001::call_data
36 // Used by recv_initial_metadata_ready.
38 // Original recv_initial_metadata_ready callback, invoked after our own.
57 static void recv_initial_metadata_ready(void* user_data, grpc_error* error) { function
85 op->payload->recv_initial_metadata.recv_initial_metadata_ready;
86 op->payload->recv_initial_metadata.recv_initial_metadata_ready =
87 &calld->recv_initial_metadata_ready;
112 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready,
113 recv_initial_metadata_ready, elem
[all...] |
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| deadline_filter.cc | 261 grpc_closure recv_initial_metadata_ready; member in struct:server_call_data
264 // The original recv_initial_metadata_ready closure, which we chain to
293 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { function
310 // from the recv_initial_metadata_ready callback. So we inject our
314 op->payload->recv_initial_metadata.recv_initial_metadata_ready;
317 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready,
318 recv_initial_metadata_ready, elem,
320 op->payload->recv_initial_metadata.recv_initial_metadata_ready =
321 &calld->recv_initial_metadata_ready;
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| server_auth_filter.cc | 43 grpc_closure recv_initial_metadata_ready; member in struct:__anon23216::call_data
165 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { function
205 batch->payload->recv_initial_metadata.recv_initial_metadata_ready;
206 batch->payload->recv_initial_metadata.recv_initial_metadata_ready =
207 &calld->recv_initial_metadata_ready;
225 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready,
226 recv_initial_metadata_ready, elem,
|
| /external/grpc-grpc/src/core/lib/channel/ |
| connected_channel.cc | 52 callback_state recv_initial_metadata_ready; member in struct:connected_channel_call_data
105 callback_state* state = &calld->recv_initial_metadata_ready;
107 calld, state, false, "recv_initial_metadata_ready",
108 &batch->payload->recv_initial_metadata.recv_initial_metadata_ready);
|
| /external/grpc-grpc/src/core/ext/filters/http/server/ |
| http_server_filter.cc | 53 grpc_closure recv_initial_metadata_ready; member in struct:__anon22995::call_data
299 "resuming recv_message_ready from recv_initial_metadata_ready");
327 "pausing recv_message_ready until recv_initial_metadata_ready");
372 op->payload->recv_initial_metadata.recv_initial_metadata_ready;
373 op->payload->recv_initial_metadata.recv_initial_metadata_ready =
374 &calld->recv_initial_metadata_ready;
418 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready,
|
| /external/grpc-grpc/src/core/ext/filters/http/client/ |
| http_client_filter.cc | 56 grpc_closure recv_initial_metadata_ready; member in struct:__anon22991::call_data
151 static void recv_initial_metadata_ready(void* user_data, grpc_error* error) { function
314 batch->payload->recv_initial_metadata.recv_initial_metadata_ready;
315 batch->payload->recv_initial_metadata.recv_initial_metadata_ready =
316 &calld->recv_initial_metadata_ready;
430 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready,
431 recv_initial_metadata_ready, elem,
|
| /external/grpc-grpc/src/cpp/common/ |
| channel_filter.h | 176 grpc_closure* recv_initial_metadata_ready() const { function in class:grpc::TransportStreamOpBatch
178 ? op_->payload->recv_initial_metadata.recv_initial_metadata_ready
182 op_->payload->recv_initial_metadata.recv_initial_metadata_ready = closure;
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| filter_causes_close.cc | 214 op->payload->recv_initial_metadata.recv_initial_metadata_ready;
215 op->payload->recv_initial_metadata.recv_initial_metadata_ready =
|
| /external/grpc-grpc/src/core/lib/transport/ |
| transport.h | 201 grpc_closure* recv_initial_metadata_ready; member in struct:grpc_transport_stream_op_batch_payload::__anon23255
|
| transport.cc | 222 batch->payload->recv_initial_metadata.recv_initial_metadata_ready,
223 GRPC_ERROR_REF(error), "failing recv_initial_metadata_ready");
|
| /external/grpc-grpc/src/cpp/ext/filters/census/ |
| server_filter.cc | 133 initial_on_done_recv_initial_metadata_ = op->recv_initial_metadata_ready();
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| client_channel.cc | 863 grpc_closure recv_initial_metadata_ready; member in struct:__anon22963
1627 grpc_closure* recv_initial_metadata_ready = local
1640 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { function
[all...] |
| /external/grpc-grpc/src/core/ext/filters/load_reporting/ |
| server_load_reporting_filter.cc | 108 original_recv_initial_metadata_ready_ = op->recv_initial_metadata_ready();
|
| /external/grpc-grpc/src/core/ext/transport/cronet/transport/ |
| cronet_transport.cc | [all...] |
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| inproc_transport.cc | 468 .recv_initial_metadata_ready,
704 .recv_initial_metadata_ready,
[all...] |
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| internal.h | 512 grpc_closure* recv_initial_metadata_ready; member in struct:grpc_chttp2_stream
|
| chttp2_transport.cc | 747 GPR_ASSERT(s->recv_initial_metadata_ready == nullptr);
[all...] |
| /external/grpc-grpc/src/core/lib/surface/ |
| server.cc | 756 op->payload->recv_initial_metadata.recv_initial_metadata_ready;
757 op->payload->recv_initial_metadata.recv_initial_metadata_ready =
[all...] |
| call.cc | [all...] |
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| bm_call_create.cc | 630 closures.Add(op->payload->recv_initial_metadata.recv_initial_metadata_ready,
|
| bm_chttp2_transport.cc | 611 op.payload->recv_initial_metadata.recv_initial_metadata_ready =
|
