Home
last modified time | relevance | path

Searched refs:CallCombiner (Results 1 – 23 of 23) sorted by relevance

/third_party/grpc/src/core/lib/iomgr/
Dcall_combiner.cc49 CallCombiner::CallCombiner() { in CallCombiner() function in grpc_core::CallCombiner
58 CallCombiner::~CallCombiner() { in ~CallCombiner()
63 void CallCombiner::TsanClosure(void* arg, grpc_error* error) { in TsanClosure()
64 CallCombiner* self = static_cast<CallCombiner*>(arg); in TsanClosure()
94 void CallCombiner::ScheduleClosure(grpc_closure* closure, grpc_error* error) { in ScheduleClosure()
113 void CallCombiner::Start(grpc_closure* closure, grpc_error* error, in Start()
148 void CallCombiner::Stop(DEBUG_ARGS const char* reason) { in Stop()
189 void CallCombiner::SetNotifyOnCancel(grpc_closure* closure) { in SetNotifyOnCancel()
232 void CallCombiner::Cancel(grpc_error* error) { in Cancel()
Dcall_combiner.h50 class CallCombiner {
52 CallCombiner();
53 ~CallCombiner();
164 void RunClosures(CallCombiner* call_combiner) { in RunClosures()
188 void RunClosuresWithoutYielding(CallCombiner* call_combiner) { in RunClosuresWithoutYielding()
/third_party/grpc/src/core/ext/filters/deadline/
Ddeadline_filter.h38 grpc_core::CallCombiner* call_combiner;
/third_party/grpc/src/core/lib/channel/
Dconnected_channel.cc44 grpc_core::CallCombiner* call_combiner;
48 grpc_core::CallCombiner* call_combiner;
Dchannel_stack.h84 grpc_core::CallCombiner* call_combiner;
/third_party/grpc/src/core/ext/filters/client_channel/
Ddynamic_filters.h46 CallCombiner* call_combiner;
Dsubchannel.h112 CallCombiner* call_combiner;
Dclient_channel.cc504 CallCombiner* call_combiner_;
838 CallCombiner* call_combiner_;
1009 CallCombiner* call_combiner_;
1217 CallCombiner* call_combiner_;
/third_party/grpc/src/core/ext/filters/client_channel/health/
Dhealth_check_client.h96 grpc_core::CallCombiner call_combiner_;
/third_party/grpc/src/core/ext/filters/http/
Dclient_authority_filter.cc43 grpc_core::CallCombiner* call_combiner;
/third_party/grpc/src/core/lib/surface/
Dlame_client.cc52 CallCombiner* call_combiner;
Dserver.h316 CallCombiner* call_combiner_;
Dcall.cc159 grpc_core::CallCombiner call_combiner;
/third_party/grpc/src/core/lib/transport/
Dtransport.h415 grpc_core::CallCombiner* call_combiner);
Dtransport.cc181 grpc_core::CallCombiner* call_combiner) {
/third_party/grpc/src/core/ext/filters/message_size/
Dmessage_size_filter.cc174 grpc_core::CallCombiner* call_combiner;
/third_party/grpc/src/core/ext/filters/http/message_compress/
Dmessage_decompress_filter.cc107 CallCombiner* call_combiner_;
Dmessage_compress_filter.cc149 grpc_core::CallCombiner* call_combiner_;
/third_party/grpc/src/core/lib/security/transport/
Dserver_auth_filter.cc77 grpc_core::CallCombiner* call_combiner;
Dclient_auth_filter.cc99 grpc_core::CallCombiner* call_combiner;
/third_party/grpc/src/core/ext/filters/http/server/
Dhttp_server_filter.cc64 grpc_core::CallCombiner* call_combiner;
/third_party/grpc/src/core/ext/filters/http/client/
Dhttp_client_filter.cc74 grpc_core::CallCombiner* call_combiner;
/third_party/grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc608 grpc_core::CallCombiner* call_combiner;