Home
last modified time | relevance | path

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

/third_party/grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc32 static void recv_trailing_metadata_ready(void* user_data, grpc_error* error);
56 GRPC_CLOSURE_INIT(&recv_trailing_metadata_ready, in call_data()
57 ::recv_trailing_metadata_ready, elem, in call_data()
83 grpc_closure recv_trailing_metadata_ready; member
159 &calld->recv_trailing_metadata_ready, in on_md_processing_done_inner()
238 &calld->recv_trailing_metadata_ready, in recv_initial_metadata_ready()
245 static void recv_trailing_metadata_ready(void* user_data, grpc_error* err) { in recv_trailing_metadata_ready() function
275 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in server_auth_start_transport_stream_op_batch()
276 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in server_auth_start_transport_stream_op_batch()
277 &calld->recv_trailing_metadata_ready; in server_auth_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc41 static void recv_trailing_metadata_ready(void* user_data, grpc_error* error);
149 GRPC_CLOSURE_INIT(&recv_trailing_metadata_ready, in call_data()
150 ::recv_trailing_metadata_ready, elem, in call_data()
180 grpc_closure recv_trailing_metadata_ready; member
227 &calld->recv_trailing_metadata_ready, in recv_message_ready()
236 static void recv_trailing_metadata_ready(void* user_data, grpc_error* error) { in recv_trailing_metadata_ready() function
285 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in message_size_start_transport_stream_op_batch()
286 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in message_size_start_transport_stream_op_batch()
287 &calld->recv_trailing_metadata_ready; in message_size_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc138 static void recv_trailing_metadata_ready(void* arg, grpc_error* error) { in recv_trailing_metadata_ready() function
151 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in inject_recv_trailing_metadata_ready()
152 GRPC_CLOSURE_INIT(&deadline_state->recv_trailing_metadata_ready, in inject_recv_trailing_metadata_ready()
153 recv_trailing_metadata_ready, deadline_state, in inject_recv_trailing_metadata_ready()
155 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in inject_recv_trailing_metadata_ready()
156 &deadline_state->recv_trailing_metadata_ready; in inject_recv_trailing_metadata_ready()
Ddeadline_filter.h43 grpc_closure recv_trailing_metadata_ready; member
/third_party/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc52 static void recv_trailing_metadata_ready(void* user_data, grpc_error* error);
63 GRPC_CLOSURE_INIT(&recv_trailing_metadata_ready, in call_data()
64 ::recv_trailing_metadata_ready, elem, in call_data()
90 grpc_closure recv_trailing_metadata_ready; member
198 calld->call_combiner, &calld->recv_trailing_metadata_ready, in recv_initial_metadata_ready()
204 static void recv_trailing_metadata_ready(void* user_data, grpc_error* error) { in recv_trailing_metadata_ready() function
374 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in http_client_start_transport_stream_op_batch()
375 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in http_client_start_transport_stream_op_batch()
376 &calld->recv_trailing_metadata_ready; in http_client_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc52 GRPC_CLOSURE_INIT(&recv_trailing_metadata_ready, in call_data()
90 grpc_closure recv_trailing_metadata_ready; member
361 &calld->recv_trailing_metadata_ready, in hs_recv_initial_metadata_ready()
460 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in hs_mutate_op()
461 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in hs_mutate_op()
462 &calld->recv_trailing_metadata_ready; in hs_mutate_op()
/third_party/grpc/src/core/lib/channel/
Dconnected_channel.cc53 callback_state recv_trailing_metadata_ready; member
118 callback_state* state = &calld->recv_trailing_metadata_ready; in connected_channel_start_transport_stream_op_batch()
121 &batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready); in connected_channel_start_transport_stream_op_batch()
/third_party/grpc/src/cpp/ext/filters/census/
Dclient_filter.cc133 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in StartTransportStreamOpBatch()
134 op->op()->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in StartTransportStreamOpBatch()
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc344 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in DecompressStartTransportStreamOpBatch()
345 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in DecompressStartTransportStreamOpBatch()
/third_party/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc516 .recv_trailing_metadata_ready, in fail_helper_locked()
664 .recv_trailing_metadata_ready, in op_state_machine_locked()
809 .recv_trailing_metadata_ready, in op_state_machine_locked()
838 .recv_trailing_metadata_ready, in op_state_machine_locked()
930 .recv_trailing_metadata_ready, in cancel_stream_locked()
1116 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in perform_stream_op()
/third_party/grpc/src/core/ext/filters/client_channel/
Dlb_policy.h247 recv_trailing_metadata_ready; member
Dclient_channel.cc632 grpc_closure recv_trailing_metadata_ready; member
3539 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready == in MaybeClearPendingBatch()
4071 .recv_trailing_metadata_ready != nullptr; in AddClosureForRecvTrailingMetadataReady()
4088 .recv_trailing_metadata_ready, in AddClosureForRecvTrailingMetadataReady()
4091 pending->batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in AddClosureForRecvTrailingMetadataReady()
4517 GRPC_CLOSURE_INIT(&retry_state->recv_trailing_metadata_ready, in AddRetriableRecvTrailingMetadataOp()
4521 .recv_trailing_metadata_ready = in AddRetriableRecvTrailingMetadataOp()
4522 &retry_state->recv_trailing_metadata_ready; in AddRetriableRecvTrailingMetadataOp()
4665 &retry_state->recv_trailing_metadata_ready, GRPC_ERROR_NONE, in AddSubchannelBatchesForPendingBatches()
5211 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in InjectRecvTrailingMetadataReadyForLoadBalancingPolicy()
[all …]
Dsubchannel.cc246 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in MaybeInterceptRecvTrailingMetadata()
247 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in MaybeInterceptRecvTrailingMetadata()
/third_party/grpc/src/core/lib/transport/
Dtransport.h306 grpc_closure* recv_trailing_metadata_ready = nullptr; member
Dtransport.cc201 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready,
/third_party/grpc/test/core/util/
Dtest_lb_policies.cc280 result->recv_trailing_metadata_ready = [this](grpc_error* error, in TrailingMetadataHandler()
/third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_impl.cc342 result.recv_trailing_metadata_ready; in Pick()
343 result.recv_trailing_metadata_ready = in Pick()
Dlrs.cc178 result.recv_trailing_metadata_ready = in Pick()
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc374 payload_.recv_trailing_metadata.recv_trailing_metadata_ready = in StartCall()
/third_party/grpc/src/core/ext/transport/cronet/transport/
Dcronet_transport.cc1335 stream_op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in execute_stream_op()
1458 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in perform_stream_op()
/third_party/grpc/src/core/lib/surface/
Dserver.cc1374 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready; in StartTransportStreamOpBatchImpl()
1375 batch->payload->recv_trailing_metadata.recv_trailing_metadata_ready = in StartTransportStreamOpBatchImpl()
Dcall.cc1885 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata_ready = in call_start_batch()
1915 stream_op_payload->recv_trailing_metadata.recv_trailing_metadata_ready = in call_start_batch()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc626 op->payload->recv_trailing_metadata.recv_trailing_metadata_ready, in StartTransportStreamOp()
/third_party/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1570 op_payload->recv_trailing_metadata.recv_trailing_metadata_ready; in perform_stream_op_locked()