| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | combiner.cc | 46 struct grpc_combiner { struct
47 grpc_combiner* next_combiner_on_this_exec_ctx; argument
77 grpc_combiner* grpc_combiner_create(void) { in grpc_combiner_create() argument
78 grpc_combiner* lock = static_cast<grpc_combiner*>(gpr_zalloc(sizeof(*lock))); in grpc_combiner_create()
91 static void really_destroy(grpc_combiner* lock) { in really_destroy()
98 static void start_destroy(grpc_combiner* lock) { in start_destroy()
119 void grpc_combiner_unref(grpc_combiner* lock GRPC_COMBINER_DEBUG_ARGS) { in grpc_combiner_unref()
126 grpc_combiner* grpc_combiner_ref(grpc_combiner* lock GRPC_COMBINER_DEBUG_ARGS) { in grpc_combiner_ref()
132 static void push_last_on_exec_ctx(grpc_combiner* lock) { in push_last_on_exec_ctx()
145 static void push_first_on_exec_ctx(grpc_combiner* lock) { in push_first_on_exec_ctx()
[all …]
|
| D | combiner.h | 38 grpc_combiner* grpc_combiner_create(void);
55 grpc_combiner* grpc_combiner_ref(grpc_combiner* lock GRPC_COMBINER_DEBUG_ARGS);
56 void grpc_combiner_unref(grpc_combiner* lock GRPC_COMBINER_DEBUG_ARGS);
58 grpc_closure_scheduler* grpc_combiner_scheduler(grpc_combiner* lock);
60 grpc_closure_scheduler* grpc_combiner_finally_scheduler(grpc_combiner* lock);
|
| D | exec_ctx.h | 40 typedef struct grpc_combiner grpc_combiner; typedef
128 grpc_combiner* active_combiner;
130 grpc_combiner* last_combiner;
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | combiner_test.cc | 42 grpc_combiner* lock = grpc_combiner_create(); in test_execute_one()
57 grpc_combiner* lock;
99 grpc_combiner* lock = grpc_combiner_create(); in test_execute_many()
127 static_cast<grpc_combiner*>(arg))), in add_finally()
134 grpc_combiner* lock = grpc_combiner_create(); in test_execute_finally()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_closure.cc | 70 grpc_combiner* combiner = grpc_combiner_create(); in BM_ClosureInitAgainstCombiner()
245 grpc_combiner* combiner = grpc_combiner_create(); in BM_ClosureSchedOnCombiner()
261 grpc_combiner* combiner = grpc_combiner_create(); in BM_ClosureSched2OnCombiner()
280 grpc_combiner* combiner = grpc_combiner_create(); in BM_ClosureSched3OnCombiner()
302 grpc_combiner* combiner1 = grpc_combiner_create(); in BM_ClosureSched2OnTwoCombiners()
303 grpc_combiner* combiner2 = grpc_combiner_create(); in BM_ClosureSched2OnTwoCombiners()
325 grpc_combiner* combiner1 = grpc_combiner_create(); in BM_ClosureSched4OnTwoCombiners()
326 grpc_combiner* combiner2 = grpc_combiner_create(); in BM_ClosureSched4OnTwoCombiners()
396 grpc_combiner* combiner = grpc_combiner_create(); in BM_ClosureReschedOnCombiner()
409 grpc_combiner* combiner = grpc_combiner_create(); in BM_ClosureReschedOnCombinerFinally()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | resolver.h | 111 explicit Resolver(grpc_combiner* combiner);
119 grpc_combiner* combiner() const { return combiner_; } in combiner()
128 grpc_combiner* combiner_;
|
| D | lb_policy.h | 54 grpc_combiner* combiner = nullptr;
182 grpc_combiner* combiner() const { return combiner_; } in combiner()
204 grpc_combiner* combiner_;
|
| D | resolver.cc | 29 Resolver::Resolver(grpc_combiner* combiner) in Resolver()
|
| D | resolver_registry.h | 68 grpc_combiner* combiner);
|
| D | resolver_factory.h | 43 grpc_combiner* combiner = nullptr;
|
| D | resolver_registry.cc | 137 grpc_pollset_set* pollset_set, grpc_combiner* combiner) { in CreateResolver()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver.h | 46 grpc_combiner* combiner,
94 grpc_combiner* combiner) GRPC_ABSTRACT;
101 UniquePtr<GrpcPolledFdFactory> NewGrpcPolledFdFactory(grpc_combiner* combiner);
|
| D | grpc_ares_ev_driver_windows.cc | 71 GrpcPolledFdWindows(ares_socket_t as, grpc_combiner* combiner) in GrpcPolledFdWindows()
366 grpc_combiner* combiner_;
396 SockToPolledFdMap(grpc_combiner* combiner) { in SockToPolledFdMap()
495 grpc_combiner* combiner_;
508 GrpcPolledFdFactoryWindows(grpc_combiner* combiner) in GrpcPolledFdFactoryWindows()
513 grpc_combiner* combiner) override { in NewGrpcPolledFdLocked()
530 UniquePtr<GrpcPolledFdFactory> NewGrpcPolledFdFactory(grpc_combiner* combiner) { in NewGrpcPolledFdFactory()
|
| D | grpc_ares_wrapper_fallback.cc | 33 grpc_combiner* combiner) { in grpc_dns_lookup_ares_locked_impl()
41 grpc_combiner* combiner) = grpc_dns_lookup_ares_locked_impl;
|
| D | grpc_ares_ev_driver_posix.cc | 93 grpc_combiner* combiner) override { in NewGrpcPolledFdLocked()
100 UniquePtr<GrpcPolledFdFactory> NewGrpcPolledFdFactory(grpc_combiner* combiner) { in NewGrpcPolledFdFactory()
|
| D | grpc_ares_wrapper.h | 62 char** service_config_json, grpc_combiner* combiner);
|
| D | grpc_ares_wrapper.cc | 364 grpc_combiner* combiner) { in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked()
538 grpc_combiner* combiner) { in grpc_dns_lookup_ares_locked_impl()
560 grpc_combiner* combiner) = grpc_dns_lookup_ares_locked_impl;
599 grpc_combiner* combiner;
|
| D | grpc_ares_ev_driver.cc | 68 grpc_combiner* combiner;
121 grpc_combiner* combiner, in grpc_ares_ev_driver_create_locked()
|
| /external/grpc-grpc/test/core/client_channel/resolvers/ |
| D | dns_resolver_connectivity_test.cc | 36 static grpc_combiner* g_combiner;
67 grpc_combiner* combiner) { in my_dns_lookup_ares_locked()
133 grpc_combiner* combiner) { in call_resolver_next_after_locking()
|
| D | dns_resolver_cooldown_test.cc | 38 static grpc_combiner* g_combiner;
44 grpc_combiner* combiner);
94 grpc_combiner* combiner) { in test_dns_lookup_ares_locked()
|
| D | fake_resolver_test.cc | 37 grpc_combiner* combiner, in build_fake_resolver()
118 grpc_combiner* combiner = grpc_combiner_create(); in test_fake_resolver()
|
| D | dns_resolver_test.cc | 28 static grpc_combiner* g_combiner;
|
| D | sockaddr_resolver_test.cc | 31 static grpc_combiner* g_combiner;
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | subchannel_list.h | 146 grpc_combiner* combiner);
236 const grpc_lb_addresses* addresses, grpc_combiner* combiner,
257 grpc_combiner* combiner_;
281 grpc_combiner* combiner) in SubchannelData()
487 const grpc_lb_addresses* addresses, grpc_combiner* combiner, in SubchannelList()
|
| /external/grpc-grpc/test/core/end2end/ |
| D | goaway_server_test.cc | 51 char** service_config_json, grpc_combiner* combiner);
105 grpc_combiner* combiner) { in my_dns_lookup_ares_locked()
|