Home
last modified time | relevance | path

Searched refs:GRPC_CALL_COMBINER_START (Results 1 – 18 of 18) sorted by relevance

/external/grpc-grpc/src/core/lib/iomgr/
Dcall_combiner.h58 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ macro
71 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ macro
149 GRPC_CALL_COMBINER_START(call_combiner, closure.closure, closure.error, in RunClosures()
169 GRPC_CALL_COMBINER_START(call_combiner, closure.closure, closure.error, in RunClosuresWithoutYielding()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dcall_combiner.h56 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ macro
66 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ macro
171 GRPC_CALL_COMBINER_START(call_combiner, closure.closure, closure.error, in RunClosures()
191 GRPC_CALL_COMBINER_START(call_combiner, closure.closure, closure.error, in RunClosuresWithoutYielding()
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc75 GRPC_CALL_COMBINER_START(deadline_state->call_combiner, in timer_callback()
169 GRPC_CALL_COMBINER_START(deadline_state->call_combiner, &state->closure, in start_timer_after_init()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc86 GRPC_CALL_COMBINER_START(deadline_state->call_combiner, &self->closure_, in TimerCallback()
180 GRPC_CALL_COMBINER_START(deadline_state->call_combiner, &state->closure, in start_timer_after_init()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc171 GRPC_CALL_COMBINER_START(call_combiner_, &on_recv_message_ready_, in MaybeResumeOnRecvMessageReady()
299 GRPC_CALL_COMBINER_START(call_combiner_, &on_recv_trailing_metadata_ready_, in MaybeResumeOnRecvTrailingMetadataReady()
Dmessage_compress_filter.cc443 GRPC_CALL_COMBINER_START( in CompressStartTransportStreamOpBatch()
475 GRPC_CALL_COMBINER_START( in CompressStartTransportStreamOpBatch()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc158 GRPC_CALL_COMBINER_START(calld->call_combiner, in on_md_processing_done_inner()
237 GRPC_CALL_COMBINER_START(calld->call_combiner, in recv_initial_metadata_ready()
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc361 GRPC_CALL_COMBINER_START( in compress_start_transport_stream_op_batch()
397 GRPC_CALL_COMBINER_START( in compress_start_transport_stream_op_batch()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc351 GRPC_CALL_COMBINER_START( in hs_recv_initial_metadata_ready()
360 GRPC_CALL_COMBINER_START(calld->call_combiner, in hs_recv_initial_metadata_ready()
/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc59 GRPC_CALL_COMBINER_START(state->call_combiner, state->original_closure, in run_in_call_combiner()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.cc397 GRPC_CALL_COMBINER_START(&call_combiner_, &batch->handler_private.closure, in StartBatch()
432 GRPC_CALL_COMBINER_START( in Cancel()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/channel/
Dconnected_channel.cc58 GRPC_CALL_COMBINER_START(state->call_combiner, state->original_closure, in run_in_call_combiner()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc226 GRPC_CALL_COMBINER_START(calld->call_combiner, in recv_message_ready()
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc296 GRPC_CALL_COMBINER_START( in hs_recv_initial_metadata_ready()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc197 GRPC_CALL_COMBINER_START( in recv_initial_metadata_ready()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dserver.cc1416 GRPC_CALL_COMBINER_START(calld->call_combiner_, in RecvInitialMetadataReady()
Dcall.cc651 GRPC_CALL_COMBINER_START(&call->call_combiner, start_batch_closure, in execute_batch()
/external/grpc-grpc/src/core/lib/surface/
Dcall.cc610 GRPC_CALL_COMBINER_START(&call->call_combiner, start_batch_closure, in execute_batch()