Home
last modified time | relevance | path

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

12

/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/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()
Dchannel_stack.h73 grpc_call_combiner* call_combiner; member
/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/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/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/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()
Dcall.cc123 grpc_call_combiner call_combiner; member
309 grpc_call_combiner_init(&call->call_combiner); in grpc_call_create()
397 &call->call_combiner}; in grpc_call_create()
491 grpc_call_combiner_destroy(&c->call_combiner); in release_call()
576 grpc_call_combiner_set_notify_on_cancel(&c->call_combiner, nullptr); in grpc_call_unref()
610 GRPC_CALL_COMBINER_START(&call->call_combiner, start_batch_closure, in execute_batch()
654 GRPC_CALL_COMBINER_STOP(&state->call->call_combiner, in done_termination()
670 grpc_call_combiner_cancel(&c->call_combiner, GRPC_ERROR_REF(error)); in cancel_with_error()
1320 GRPC_CALL_COMBINER_STOP(&call->call_combiner, "recv_message_ready"); in receiving_stream_ready_in_call_combiner()
1391 GRPC_CALL_COMBINER_STOP(&call->call_combiner, "recv_initial_metadata_ready"); in receiving_initial_metadata_ready()
[all …]
/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 …]
Dsubchannel.h84 grpc_call_combiner* call_combiner; member
Dsubchannel.cc871 args.call_combiner /* call_combiner */ in CreateCall()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.cc211 grpc_call_combiner* call_combiner) { argument
239 closures.RunClosures(call_combiner);
Dtransport.h332 grpc_call_combiner* call_combiner);
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc621 grpc_call_combiner* call_combiner; member
646 closures.RunClosures(calld->call_combiner); in StartTransportStreamOp()
660 calld->call_combiner = args->call_combiner; in InitCallElem()
/external/grpc-grpc/doc/
Denvironment_variables.md42 - call_combiner - traces call combiner state
/external/grpc-grpc/
DgRPC-C++.podspec390 'src/core/lib/iomgr/call_combiner.h',
580 'src/core/lib/iomgr/call_combiner.h',
DgRPC-Core.podspec399 'src/core/lib/iomgr/call_combiner.h',
545 'src/core/lib/iomgr/call_combiner.cc',
1004 'src/core/lib/iomgr/call_combiner.h',
Dgrpc.gyp304 'src/core/lib/iomgr/call_combiner.cc',
667 'src/core/lib/iomgr/call_combiner.cc',
903 'src/core/lib/iomgr/call_combiner.cc',
1117 'src/core/lib/iomgr/call_combiner.cc',

12