Home
last modified time | relevance | path

Searched refs:recv_initial_metadata_ready (Results 1 – 22 of 22) sorted by relevance

/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc47 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/grpc-grpc/src/core/ext/filters/workarounds/
Dworkaround_cronet_compression_filter.cc35 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/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc261 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/grpc-grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc43 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/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc56 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/ext/filters/http/server/
Dhttp_server_filter.cc53 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/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc52 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/cpp/common/
Dchannel_filter.h176 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/
Dfilter_causes_close.cc214 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/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc863 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/
Dtransport.h201 grpc_closure* recv_initial_metadata_ready; member
Dtransport.cc222 batch->payload->recv_initial_metadata.recv_initial_metadata_ready,
/external/grpc-grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc1121 stream_op->payload->recv_initial_metadata.recv_initial_metadata_ready, in execute_stream_op()
1125 stream_op->payload->recv_initial_metadata.recv_initial_metadata_ready, in execute_stream_op()
1129 stream_op->payload->recv_initial_metadata.recv_initial_metadata_ready, in execute_stream_op()
1136 stream_op->payload->recv_initial_metadata.recv_initial_metadata_ready, in execute_stream_op()
1406 op->payload->recv_initial_metadata.recv_initial_metadata_ready, in perform_stream_op()
/external/grpc-grpc/src/cpp/ext/filters/census/
Dserver_filter.cc133 initial_on_done_recv_initial_metadata_ = op->recv_initial_metadata_ready(); in StartTransportStreamOpBatch()
/external/grpc-grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.cc108 original_recv_initial_metadata_ready_ = op->recv_initial_metadata_ready(); in StartTransportStreamOpBatch()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc468 .recv_initial_metadata_ready, in fail_helper_locked()
704 .recv_initial_metadata_ready, in op_state_machine()
1053 op->payload->recv_initial_metadata.recv_initial_metadata_ready, in perform_stream_op()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc747 GPR_ASSERT(s->recv_initial_metadata_ready == nullptr); in destroy_stream_locked()
1596 GPR_ASSERT(s->recv_initial_metadata_ready == nullptr); in perform_stream_op_locked()
1597 s->recv_initial_metadata_ready = in perform_stream_op_locked()
1598 op_payload->recv_initial_metadata.recv_initial_metadata_ready; in perform_stream_op_locked()
1856 if (s->recv_initial_metadata_ready != nullptr && in grpc_chttp2_maybe_complete_recv_initial_metadata()
1867 null_then_run_closure(&s->recv_initial_metadata_ready, GRPC_ERROR_NONE); in grpc_chttp2_maybe_complete_recv_initial_metadata()
Dinternal.h512 grpc_closure* recv_initial_metadata_ready; member
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc611 op.payload->recv_initial_metadata.recv_initial_metadata_ready = in BM_TransportStreamRecv()
Dbm_call_create.cc630 closures.Add(op->payload->recv_initial_metadata.recv_initial_metadata_ready, in StartTransportStreamOp()
/external/grpc-grpc/src/core/lib/surface/
Dserver.cc756 op->payload->recv_initial_metadata.recv_initial_metadata_ready; in server_mutate_op()
757 op->payload->recv_initial_metadata.recv_initial_metadata_ready = in server_mutate_op()
Dcall.cc1732 stream_op_payload->recv_initial_metadata.recv_initial_metadata_ready = in call_start_batch()