Home
last modified time | relevance | path

Searched refs:call_combiner (Results 1 – 25 of 35) sorted by relevance

12

/third_party/grpc/src/core/lib/iomgr/
Dcall_combiner.h56 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ argument
57 (call_combiner)->Start((closure), (error), __FILE__, __LINE__, (reason))
58 #define GRPC_CALL_COMBINER_STOP(call_combiner, reason) \ argument
59 (call_combiner)->Stop(__FILE__, __LINE__, (reason))
66 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ argument
67 (call_combiner)->Start((closure), (error), (reason))
68 #define GRPC_CALL_COMBINER_STOP(call_combiner, reason) \ argument
69 (call_combiner)->Stop((reason))
164 void RunClosures(CallCombiner* call_combiner) { in RunClosures() argument
166 GRPC_CALL_COMBINER_STOP(call_combiner, "no closures to schedule"); in RunClosures()
[all …]
/third_party/grpc/src/core/lib/channel/
Dconnected_channel.cc44 grpc_core::CallCombiner* call_combiner; member
48 grpc_core::CallCombiner* call_combiner; member
58 GRPC_CALL_COMBINER_START(state->call_combiner, state->original_closure, in run_in_call_combiner()
71 state->call_combiner = calld->call_combiner; in intercept_callback()
139 GRPC_CALL_COMBINER_STOP(calld->call_combiner, "passed batch to transport"); in connected_channel_start_transport_stream_op_batch()
153 calld->call_combiner = args->call_combiner; in connected_channel_init_call_elem()
Dchannel_stack.h84 grpc_core::CallCombiner* call_combiner; member
/third_party/grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc68 : owning_call(args.call_stack), call_combiner(args.call_combiner) { in call_data()
99 grpc_core::CallCombiner* call_combiner; member
183 calld->call_combiner); in on_credentials_metadata()
265 calld->call_combiner); in send_security_metadata()
286 calld->call_combiner); in send_security_metadata()
302 calld->call_combiner); in send_security_metadata()
323 calld->call_combiner->SetNotifyOnCancel(GRPC_CLOSURE_INIT( in send_security_metadata()
346 calld->call_combiner); in on_host_checked()
393 calld->call_combiner->SetNotifyOnCancel(GRPC_CLOSURE_INIT( in client_auth_start_transport_stream_op_batch()
Dserver_auth_filter.cc52 : call_combiner(args.call_combiner), owning_call(args.call_stack) { in call_data()
77 grpc_core::CallCombiner* call_combiner; member
158 GRPC_CALL_COMBINER_START(calld->call_combiner, in on_md_processing_done_inner()
223 calld->call_combiner->SetNotifyOnCancel(&calld->cancel_closure); in recv_initial_metadata_ready()
237 GRPC_CALL_COMBINER_START(calld->call_combiner, in recv_initial_metadata_ready()
251 GRPC_CALL_COMBINER_STOP(calld->call_combiner, in recv_trailing_metadata_ready()
/third_party/grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc43 grpc_core::CallCombiner* call_combiner; member
66 calld->call_combiner); in client_authority_start_transport_stream_op_batch()
78 calld->call_combiner = args->call_combiner; in client_authority_init_call_elem()
/third_party/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc58 GRPC_CALL_COMBINER_STOP(deadline_state->call_combiner, in YieldCallCombiner()
83 deadline_state->call_combiner->Cancel(GRPC_ERROR_REF(error)); in TimerCallback()
86 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()
186 GRPC_CALL_COMBINER_STOP(deadline_state->call_combiner, in start_timer_after_init()
194 call_combiner(args.call_combiner), in grpc_deadline_state()
Ddeadline_filter.h38 grpc_core::CallCombiner* call_combiner; member
/third_party/grpc/src/core/lib/surface/
Dlame_client.cc52 CallCombiner* call_combiner; member
60 op, GRPC_ERROR_REF(chand->error), calld->call_combiner); in lame_start_transport_stream_op_batch()
96 calld->call_combiner = args->call_combiner; in lame_init_call_elem()
Dcall.cc159 grpc_core::CallCombiner call_combiner; member
436 &call->call_combiner}; in grpc_call_create()
616 c->call_combiner.SetNotifyOnCancel(nullptr); in grpc_call_unref()
651 GRPC_CALL_COMBINER_START(&call->call_combiner, start_batch_closure, in execute_batch()
696 GRPC_CALL_COMBINER_STOP(&state->call->call_combiner, in done_termination()
712 c->call_combiner.Cancel(GRPC_ERROR_REF(error)); in cancel_with_error()
1377 GRPC_CALL_COMBINER_STOP(&call->call_combiner, "recv_message_ready"); in receiving_stream_ready_in_call_combiner()
1471 GRPC_CALL_COMBINER_STOP(&call->call_combiner, "recv_initial_metadata_ready"); in receiving_initial_metadata_ready()
1529 GRPC_CALL_COMBINER_STOP(&call->call_combiner, "recv_trailing_metadata_ready"); in receiving_trailing_metadata_ready()
1539 GRPC_CALL_COMBINER_STOP(&call->call_combiner, "on_complete"); in finish_batch()
Dserver.cc1190 call_combiner_(args.call_combiner) { in CallData()
/third_party/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc46 : call_combiner(args.call_combiner) { in call_data()
64 grpc_core::CallCombiner* call_combiner; member
352 calld->call_combiner, calld->original_recv_message_ready, in hs_recv_initial_metadata_ready()
360 GRPC_CALL_COMBINER_START(calld->call_combiner, in hs_recv_initial_metadata_ready()
390 calld->call_combiner, in hs_recv_message_ready()
401 GRPC_CALL_COMBINER_STOP(calld->call_combiner, in hs_recv_trailing_metadata_ready()
481 calld->call_combiner); in hs_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc146 : call_combiner(args.call_combiner), limits(chand.limits) { in call_data()
174 grpc_core::CallCombiner* call_combiner; member
226 GRPC_CALL_COMBINER_START(calld->call_combiner, in recv_message_ready()
242 GRPC_CALL_COMBINER_STOP(calld->call_combiner, in recv_trailing_metadata_ready()
272 calld->call_combiner); in message_size_start_transport_stream_op_batch()
/third_party/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc59 : call_combiner(args.call_combiner) { in call_data()
74 grpc_core::CallCombiner* call_combiner; member
198 calld->call_combiner, &calld->recv_trailing_metadata_ready, in recv_initial_metadata_ready()
210 GRPC_CALL_COMBINER_STOP(calld->call_combiner, in recv_trailing_metadata_ready()
271 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
277 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
471 calld->send_message_batch, error, calld->call_combiner); in http_client_start_transport_stream_op_batch()
/third_party/grpc/src/core/lib/transport/
Dtransport.cc181 grpc_core::CallCombiner* call_combiner) { argument
209 closures.RunClosures(call_combiner);
Dtransport.h415 grpc_core::CallCombiner* call_combiner);
/third_party/grpc/src/core/ext/filters/client_channel/
Ddynamic_filters.h46 CallCombiner* call_combiner; member
Ddynamic_filters.cc50 args.call_combiner /* call_combiner */ in Call()
Dsubchannel.h112 CallCombiner* call_combiner; member
Dsubchannel.cc154 args.call_combiner /* call_combiner */ in SubchannelCall()
Dclient_channel.cc1207 call_combiner_(args.call_combiner), in DynamicTerminationFilterCallData()
2649 call_combiner_(args.call_combiner), in CallData()
3251 call_combiner_(args.call_combiner), in RetryingCall()
4922 call_combiner_(args.call_combiner), in LoadBalancedCall()
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc608 grpc_core::CallCombiner* call_combiner; member
633 closures.RunClosures(calld->call_combiner); in StartTransportStreamOp()
647 calld->call_combiner = args->call_combiner; in InitCallElem()
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc61 : call_combiner_(args.call_combiner), in CallData()
Dmessage_compress_filter.cc106 : call_combiner_(args.call_combiner) { in CallData()
/third_party/grpc/doc/
Denvironment_variables.md100 - call_combiner - traces call combiner state

12