Home
last modified time | relevance | path

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

/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dclient_load_reporting_filter.cc50 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()
/third_party/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
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()
/third_party/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc262 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()
/third_party/grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc31 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()
/third_party/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc51 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()
/third_party/grpc/src/core/lib/channel/
Dconnected_channel.cc51 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()
/third_party/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc47 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()
/third_party/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()
/third_party/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()
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc330 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in DecompressStartTransportStreamOpBatch()
331 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in DecompressStartTransportStreamOpBatch()
/third_party/grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc1161 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()
1447 op->payload->recv_initial_metadata.recv_initial_metadata_ready, in perform_stream_op()
/third_party/grpc/src/cpp/ext/filters/census/
Dserver_filter.cc124 initial_on_done_recv_initial_metadata_ = op->recv_initial_metadata_ready(); in StartTransportStreamOpBatch()
/third_party/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc624 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()
3534 batch->payload->recv_initial_metadata.recv_initial_metadata_ready == in MaybeClearPendingBatch()
3874 .recv_initial_metadata_ready != nullptr; in InvokeRecvInitialMetadataCallback()
3887 grpc_closure* recv_initial_metadata_ready = in InvokeRecvInitialMetadataCallback() local
3889 .recv_initial_metadata_ready; in InvokeRecvInitialMetadataCallback()
3890 pending->batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in InvokeRecvInitialMetadataCallback()
3895 Closure::Run(DEBUG_LOCATION, recv_initial_metadata_ready, in InvokeRecvInitialMetadataCallback()
4103 GRPC_CLOSURE_INIT(&retry_state->recv_initial_metadata_ready, in AddClosuresForDeferredRecvCallbacks()
[all …]
/third_party/grpc/src/core/lib/transport/
Dtransport.h280 grpc_closure* recv_initial_metadata_ready = nullptr; member
Dtransport.cc192 batch->payload->recv_initial_metadata.recv_initial_metadata_ready,
/third_party/grpc/src/core/ext/filters/load_reporting/
Dserver_load_reporting_filter.cc114 original_recv_initial_metadata_ready_ = op->recv_initial_metadata_ready(); in StartTransportStreamOpBatch()
/third_party/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc476 .recv_initial_metadata_ready, in fail_helper_locked()
718 .recv_initial_metadata_ready, in op_state_machine_locked()
1097 op->payload->recv_initial_metadata.recv_initial_metadata_ready, in perform_stream_op()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc674 GPR_ASSERT(recv_initial_metadata_ready == nullptr); in ~grpc_chttp2_stream()
1525 GPR_ASSERT(s->recv_initial_metadata_ready == nullptr); in perform_stream_op_locked()
1526 s->recv_initial_metadata_ready = in perform_stream_op_locked()
1527 op_payload->recv_initial_metadata.recv_initial_metadata_ready; in perform_stream_op_locked()
1817 if (s->recv_initial_metadata_ready != nullptr && in grpc_chttp2_maybe_complete_recv_initial_metadata()
1828 null_then_sched_closure(&s->recv_initial_metadata_ready); in grpc_chttp2_maybe_complete_recv_initial_metadata()
Dinternal.h555 grpc_closure* recv_initial_metadata_ready = nullptr; member
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc351 payload_.recv_initial_metadata.recv_initial_metadata_ready = in StartCall()
/third_party/grpc/src/core/lib/surface/
Dserver.cc1366 batch->payload->recv_initial_metadata.recv_initial_metadata_ready; in StartTransportStreamOpBatchImpl()
1367 batch->payload->recv_initial_metadata.recv_initial_metadata_ready = in StartTransportStreamOpBatchImpl()
Dcall.cc1824 stream_op_payload->recv_initial_metadata.recv_initial_metadata_ready = in call_start_batch()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_chttp2_transport.cc639 op.payload->recv_initial_metadata.recv_initial_metadata_ready = in BM_TransportStreamRecv()
Dbm_call_create.cc617 closures.Add(op->payload->recv_initial_metadata.recv_initial_metadata_ready, in StartTransportStreamOp()