| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 47 grpc_closure recv_initial_metadata_ready; member
62 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { in recv_initial_metadata_ready() function
117 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in start_transport_stream_op_batch()
118 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in start_transport_stream_op_batch()
119 recv_initial_metadata_ready, calld, in start_transport_stream_op_batch()
121 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in start_transport_stream_op_batch()
122 &calld->recv_initial_metadata_ready; in start_transport_stream_op_batch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | client_load_reporting_filter.cc | 50 grpc_closure recv_initial_metadata_ready; member
66 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { in recv_initial_metadata_ready() function
135 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in clr_start_transport_stream_op_batch()
136 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in clr_start_transport_stream_op_batch()
137 recv_initial_metadata_ready, calld, in clr_start_transport_stream_op_batch()
139 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in clr_start_transport_stream_op_batch()
140 &calld->recv_initial_metadata_ready; in clr_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 35 grpc_closure recv_initial_metadata_ready; member
57 static void recv_initial_metadata_ready(void* user_data, grpc_error* error) { in recv_initial_metadata_ready() function
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()
87 &calld->recv_initial_metadata_ready; in start_transport_stream_op_batch()
112 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in init_call_elem()
113 recv_initial_metadata_ready, elem, in init_call_elem()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/workarounds/ |
| D | workaround_cronet_compression_filter.cc | 35 grpc_closure recv_initial_metadata_ready; member
57 static void recv_initial_metadata_ready(void* user_data, grpc_error* error) { in recv_initial_metadata_ready() function
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()
88 &calld->recv_initial_metadata_ready; in cronet_compression_start_transport_stream_op_batch()
113 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in cronet_compression_init_call_elem()
114 recv_initial_metadata_ready, elem, in cronet_compression_init_call_elem()
|
| /external/grpc-grpc/src/core/ext/filters/deadline/ |
| D | deadline_filter.cc | 261 grpc_closure recv_initial_metadata_ready; member
293 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { in recv_initial_metadata_ready() function
314 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in server_start_transport_stream_op_batch()
317 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in server_start_transport_stream_op_batch()
318 recv_initial_metadata_ready, elem, in server_start_transport_stream_op_batch()
320 op->payload->recv_initial_metadata.recv_initial_metadata_ready = in server_start_transport_stream_op_batch()
321 &calld->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 | 262 grpc_closure recv_initial_metadata_ready; member
295 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { in recv_initial_metadata_ready() function
317 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in deadline_server_start_transport_stream_op_batch()
320 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in deadline_server_start_transport_stream_op_batch()
321 recv_initial_metadata_ready, elem, 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()
324 &calld->recv_initial_metadata_ready; in deadline_server_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 43 grpc_closure recv_initial_metadata_ready; member
165 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { in recv_initial_metadata_ready() function
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()
207 &calld->recv_initial_metadata_ready; in auth_start_transport_stream_op_batch()
225 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in init_call_elem()
226 recv_initial_metadata_ready, elem, in init_call_elem()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 31 static void recv_initial_metadata_ready(void* arg, grpc_error* error);
53 GRPC_CLOSURE_INIT(&recv_initial_metadata_ready, in call_data()
54 ::recv_initial_metadata_ready, elem, in call_data()
81 grpc_closure recv_initial_metadata_ready; member
211 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { in recv_initial_metadata_ready() function
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()
271 &calld->recv_initial_metadata_ready; in server_auth_start_transport_stream_op_batch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/ |
| D | http_client_filter.cc | 51 static void recv_initial_metadata_ready(void* user_data, grpc_error* error);
60 GRPC_CLOSURE_INIT(&recv_initial_metadata_ready, in call_data()
61 ::recv_initial_metadata_ready, elem, in call_data()
86 grpc_closure recv_initial_metadata_ready; member
185 static void recv_initial_metadata_ready(void* user_data, grpc_error* error) { in recv_initial_metadata_ready() function
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()
366 &calld->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 | 56 grpc_closure recv_initial_metadata_ready; member
151 static void recv_initial_metadata_ready(void* user_data, grpc_error* error) { in recv_initial_metadata_ready() function
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()
316 &calld->recv_initial_metadata_ready; in hc_start_transport_stream_op_batch()
430 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in init_call_elem()
431 recv_initial_metadata_ready, elem, in init_call_elem()
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 52 callback_state recv_initial_metadata_ready; member
105 callback_state* state = &calld->recv_initial_metadata_ready; 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/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 53 grpc_closure recv_initial_metadata_ready; member
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()
374 &calld->recv_initial_metadata_ready; in hs_mutate_op()
418 GRPC_CLOSURE_INIT(&calld->recv_initial_metadata_ready, in hs_init_call_elem()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/ |
| D | connected_channel.cc | 51 callback_state recv_initial_metadata_ready; member
107 callback_state* state = &calld->recv_initial_metadata_ready; in connected_channel_start_transport_stream_op_batch()
110 &batch->payload->recv_initial_metadata.recv_initial_metadata_ready); in connected_channel_start_transport_stream_op_batch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/ |
| D | http_server_filter.cc | 47 GRPC_CLOSURE_INIT(&recv_initial_metadata_ready, in call_data()
76 grpc_closure recv_initial_metadata_ready; member
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()
448 &calld->recv_initial_metadata_ready; in hs_mutate_op()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | channel_filter.h | 176 grpc_closure* recv_initial_metadata_ready() const { in recv_initial_metadata_ready() function
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()
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/common/ |
| D | channel_filter.h | 176 grpc_closure* recv_initial_metadata_ready() const { in recv_initial_metadata_ready() function
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()
|
| /external/grpc-grpc/test/core/end2end/tests/ |
| D | filter_causes_close.cc | 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()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_decompress_filter.cc | 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/ext/filters/client_channel/ |
| D | client_channel.cc | 863 grpc_closure recv_initial_metadata_ready; member
1325 batch->payload->recv_initial_metadata.recv_initial_metadata_ready == in maybe_clear_pending_batch()
1613 .recv_initial_metadata_ready != nullptr; in invoke_recv_initial_metadata_callback()
1627 grpc_closure* recv_initial_metadata_ready = in invoke_recv_initial_metadata_callback() local
1629 .recv_initial_metadata_ready; in invoke_recv_initial_metadata_callback()
1630 pending->batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in invoke_recv_initial_metadata_callback()
1635 GRPC_CLOSURE_RUN(recv_initial_metadata_ready, GRPC_ERROR_REF(error)); in invoke_recv_initial_metadata_callback()
1640 static void recv_initial_metadata_ready(void* arg, grpc_error* error) { in recv_initial_metadata_ready() function
1856 GRPC_CLOSURE_INIT(&retry_state->recv_initial_metadata_ready, in add_closures_for_deferred_recv_callbacks()
1860 closures->Add(&retry_state->recv_initial_metadata_ready, in add_closures_for_deferred_recv_callbacks()
[all …]
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.h | 201 grpc_closure* recv_initial_metadata_ready; member
|
| /external/grpc-grpc/src/cpp/ext/filters/census/ |
| D | server_filter.cc | 133 initial_on_done_recv_initial_metadata_ = op->recv_initial_metadata_ready(); in StartTransportStreamOpBatch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 624 grpc_closure recv_initial_metadata_ready; member
3052 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in InjectRecvInitialMetadataReadyForConfigSelectorCommitCallback()
3056 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in InjectRecvInitialMetadataReadyForConfigSelectorCommitCallback()
3528 batch->payload->recv_initial_metadata.recv_initial_metadata_ready == in MaybeClearPendingBatch()
3868 .recv_initial_metadata_ready != nullptr; in InvokeRecvInitialMetadataCallback()
3881 grpc_closure* recv_initial_metadata_ready = in InvokeRecvInitialMetadataCallback() local
3883 .recv_initial_metadata_ready; in InvokeRecvInitialMetadataCallback()
3884 pending->batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in InvokeRecvInitialMetadataCallback()
3889 Closure::Run(DEBUG_LOCATION, recv_initial_metadata_ready, in InvokeRecvInitialMetadataCallback()
4097 GRPC_CLOSURE_INIT(&retry_state->recv_initial_metadata_ready, in AddClosuresForDeferredRecvCallbacks()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/cpp/ext/filters/census/ |
| D | server_filter.cc | 135 initial_on_done_recv_initial_metadata_ = op->recv_initial_metadata_ready(); in StartTransportStreamOpBatch()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | transport.h | 280 grpc_closure* recv_initial_metadata_ready = nullptr; member
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/cronet/transport/ |
| D | cronet_transport.cc | 1161 stream_op->payload->recv_initial_metadata.recv_initial_metadata_ready, in execute_stream_op()
1166 stream_op->payload->recv_initial_metadata.recv_initial_metadata_ready, in execute_stream_op()
1171 stream_op->payload->recv_initial_metadata.recv_initial_metadata_ready, in execute_stream_op()
1179 stream_op->payload->recv_initial_metadata.recv_initial_metadata_ready, in execute_stream_op()
1446 op->payload->recv_initial_metadata.recv_initial_metadata_ready, in perform_stream_op()
|