Home
last modified time | relevance | path

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

123

/external/grpc-grpc/src/core/lib/iomgr/
Dcall_combiner.h53 void grpc_call_combiner_init(grpc_call_combiner* call_combiner);
55 void grpc_call_combiner_destroy(grpc_call_combiner* call_combiner);
58 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ argument
59 grpc_call_combiner_start((call_combiner), (closure), (error), __FILE__, \
61 #define GRPC_CALL_COMBINER_STOP(call_combiner, reason) \ argument
62 grpc_call_combiner_stop((call_combiner), __FILE__, __LINE__, (reason))
64 void grpc_call_combiner_start(grpc_call_combiner* call_combiner,
68 void grpc_call_combiner_stop(grpc_call_combiner* call_combiner,
71 #define GRPC_CALL_COMBINER_START(call_combiner, closure, error, reason) \ argument
72 grpc_call_combiner_start((call_combiner), (closure), (error), (reason))
[all …]
Dcall_combiner.cc42 void grpc_call_combiner_init(grpc_call_combiner* call_combiner) { in grpc_call_combiner_init() argument
43 gpr_mpscq_init(&call_combiner->queue); in grpc_call_combiner_init()
46 void grpc_call_combiner_destroy(grpc_call_combiner* call_combiner) { in grpc_call_combiner_destroy() argument
47 gpr_mpscq_destroy(&call_combiner->queue); in grpc_call_combiner_destroy()
48 GRPC_ERROR_UNREF(decode_cancel_state_error(call_combiner->cancel_state)); in grpc_call_combiner_destroy()
61 void grpc_call_combiner_start(grpc_call_combiner* call_combiner, in grpc_call_combiner_start() argument
70 call_combiner, closure DEBUG_FMT_ARGS, reason, in grpc_call_combiner_start()
74 gpr_atm_full_fetch_add(&call_combiner->size, (gpr_atm)1)); in grpc_call_combiner_start()
95 gpr_mpscq_push(&call_combiner->queue, in grpc_call_combiner_start()
100 void grpc_call_combiner_stop(grpc_call_combiner* call_combiner DEBUG_ARGS, in grpc_call_combiner_stop()
[all …]
/external/rust/crates/grpcio-sys/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 …]
/external/grpc-grpc/src/core/lib/channel/
Dconnected_channel.cc44 grpc_call_combiner* call_combiner; member
49 grpc_call_combiner* call_combiner; member
59 GRPC_CALL_COMBINER_START(state->call_combiner, state->original_closure, in run_in_call_combiner()
72 state->call_combiner = calld->call_combiner; in intercept_callback()
137 GRPC_CALL_COMBINER_STOP(calld->call_combiner, "passed batch to transport"); in con_start_transport_stream_op_batch()
151 calld->call_combiner = args->call_combiner; in init_call_elem()
/external/rust/crates/grpcio-sys/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()
/external/grpc-grpc/src/core/ext/filters/deadline/
Ddeadline_filter.cc42 GRPC_CALL_COMBINER_STOP(deadline_state->call_combiner, in yield_call_combiner()
70 grpc_call_combiner_cancel(deadline_state->call_combiner, in timer_callback()
75 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()
176 GRPC_CALL_COMBINER_STOP(deadline_state->call_combiner, in start_timer_after_init()
182 grpc_call_combiner* call_combiner, in grpc_deadline_state_init() argument
187 deadline_state->call_combiner = call_combiner; in grpc_deadline_state_init()
272 grpc_deadline_state_init(elem, args->call_stack, args->call_combiner, in init_call_elem()
Ddeadline_filter.h36 grpc_call_combiner* call_combiner; member
56 grpc_call_combiner* call_combiner,
/external/grpc-grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc43 grpc_call_combiner* call_combiner; member
67 calld->call_combiner); in authority_start_transport_stream_op_batch()
79 calld->call_combiner = args->call_combiner; in init_call_elem()
/external/rust/crates/grpcio-sys/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()
/external/rust/crates/grpcio-sys/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()
/external/rust/crates/grpcio-sys/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
/external/grpc-grpc/src/core/ext/filters/http/message_compress/
Dmessage_compress_filter.cc53 grpc_call_combiner* call_combiner; member
272 calld->send_message_batch, GRPC_ERROR_REF(error), calld->call_combiner); in fail_send_message_batch_in_call_combiner()
362 calld->call_combiner, in compress_start_transport_stream_op_batch()
373 batch, GRPC_ERROR_REF(calld->cancel_error), calld->call_combiner); in compress_start_transport_stream_op_batch()
385 calld->call_combiner); in compress_start_transport_stream_op_batch()
398 calld->call_combiner, in compress_start_transport_stream_op_batch()
413 calld->call_combiner, in compress_start_transport_stream_op_batch()
428 calld->call_combiner = args->call_combiner; in init_call_elem()
/external/rust/crates/grpcio-sys/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()
/external/grpc-grpc/src/core/lib/security/transport/
Dclient_auth_filter.cc47 grpc_call_combiner* call_combiner; member
121 calld->call_combiner); in on_credentials_metadata()
199 calld->call_combiner); in send_security_metadata()
225 calld->call_combiner, in send_security_metadata()
251 calld->call_combiner); in on_host_checked()
319 calld->call_combiner, in auth_start_transport_stream_op_batch()
339 calld->call_combiner = args->call_combiner; in init_call_elem()
Dserver_auth_filter.cc39 grpc_call_combiner* call_combiner; member
176 grpc_call_combiner_set_notify_on_cancel(calld->call_combiner, in recv_initial_metadata_ready()
223 calld->call_combiner = args->call_combiner; in init_call_elem()
/external/grpc-grpc/src/core/lib/surface/
Dlame_client.cc43 grpc_call_combiner* call_combiner; member
91 calld->call_combiner); in lame_start_transport_stream_op_batch()
123 calld->call_combiner = args->call_combiner; in init_call_elem()
/external/rust/crates/grpcio-sys/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()
/external/rust/crates/grpcio-sys/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()
/external/rust/crates/grpcio-sys/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()
/external/grpc-grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc41 grpc_call_combiner* call_combiner; member
297 calld->call_combiner, calld->original_recv_message_ready, in hs_recv_initial_metadata_ready()
326 calld->call_combiner, in hs_recv_message_ready()
407 calld->call_combiner); in hs_start_transport_stream_op_batch()
417 calld->call_combiner = args->call_combiner; in hs_init_call_elem()
/external/grpc-grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc96 grpc_call_combiner* call_combiner; member
181 calld->call_combiner); in start_transport_stream_op_batch()
208 calld->call_combiner = args->call_combiner; in init_call_elem()
/external/grpc-grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc44 grpc_call_combiner* call_combiner; member
221 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
227 calld->send_message_batch, error, calld->call_combiner); in on_send_message_next_done()
419 calld->send_message_batch, error, calld->call_combiner); in hc_start_transport_stream_op_batch()
429 calld->call_combiner = args->call_combiner; in init_call_elem()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc922 grpc_call_combiner* call_combiner; member
1226 batch, GRPC_ERROR_REF(error), calld->call_combiner); in fail_pending_batch_in_call_combiner()
1260 closures.RunClosures(calld->call_combiner); in pending_batches_fail()
1262 closures.RunClosuresWithoutYielding(calld->call_combiner); in pending_batches_fail()
1313 closures.RunClosures(calld->call_combiner); in pending_batches_resume()
1659 calld->call_combiner, in recv_initial_metadata_ready()
1684 calld->call_combiner, in recv_initial_metadata_ready()
1749 GRPC_CALL_COMBINER_STOP(calld->call_combiner, in recv_message_ready()
1773 GRPC_CALL_COMBINER_STOP(calld->call_combiner, "recv_message_ready null"); in recv_message_ready()
1952 closures.RunClosures(calld->call_combiner); in run_closures_for_completed_call()
[all …]

123