| /third_party/grpc/test/core/client_channel/resolvers/ |
| D | dns_resolver_test.cc | 47 args.work_serializer = *g_work_serializer; in test_succeeds()
64 args.work_serializer = *g_work_serializer; in test_fails()
76 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
77 g_work_serializer = &work_serializer; in main()
|
| D | sockaddr_resolver_test.cc | 49 args.work_serializer = *g_work_serializer; in test_succeeds()
70 args.work_serializer = *g_work_serializer; in test_fails()
82 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
83 g_work_serializer = &work_serializer; in main()
|
| D | fake_resolver_test.cc | 69 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in build_fake_resolver() argument
80 args.work_serializer = std::move(work_serializer); in build_fake_resolver()
111 std::shared_ptr<grpc_core::WorkSerializer> work_serializer = in test_fake_resolver() local
119 work_serializer, response_generator.get(), in test_fake_resolver()
|
| D | dns_resolver_cooldown_test.cc | 48 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
100 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in test_dns_lookup_ares_locked() argument
104 std::move(work_serializer)); in test_dns_lookup_ares_locked()
289 args.work_serializer = *g_work_serializer; in start_test_under_work_serializer()
325 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
326 g_work_serializer = &work_serializer; in main()
|
| D | dns_resolver_connectivity_test.cc | 102 args.work_serializer = *g_work_serializer; in create_resolver()
164 auto work_serializer = std::make_shared<grpc_core::WorkSerializer>(); in main() local
165 g_work_serializer = &work_serializer; in main()
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver.cc | 71 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
150 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in grpc_ares_ev_driver_create_locked() argument
167 (*ev_driver)->work_serializer = std::move(work_serializer); in grpc_ares_ev_driver_create_locked()
175 grpc_core::NewGrpcPolledFdFactory((*ev_driver)->work_serializer); in grpc_ares_ev_driver_create_locked()
238 driver->work_serializer->Run( in on_timeout()
257 driver->work_serializer->Run( in on_ares_backup_poll_alarm()
335 fdn->ev_driver->work_serializer->Run( in on_readable()
365 fdn->ev_driver->work_serializer->Run( in on_writable()
391 socks[i], ev_driver->pollset_set, ev_driver->work_serializer); in grpc_ares_notify_on_event_locked()
|
| D | grpc_ares_ev_driver_libuv.cc | 47 std::shared_ptr<WorkSerializer> work_serializer) in GrpcPolledFdLibuv() argument
50 work_serializer_(std::move(work_serializer)) { in GrpcPolledFdLibuv()
165 std::shared_ptr<WorkSerializer> work_serializer) override { in NewGrpcPolledFdLocked() argument
166 return new GrpcPolledFdLibuv(as, std::move(work_serializer)); in NewGrpcPolledFdLocked()
173 std::shared_ptr<WorkSerializer> work_serializer) { in NewGrpcPolledFdFactory() argument
|
| D | grpc_ares_wrapper.cc | 114 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
286 driver->work_serializer->Run( in on_timeout()
298 driver->work_serializer->Run( in on_ares_backup_poll_alarm()
376 fdn->ev_driver->work_serializer->Run( in on_readable()
406 fdn->ev_driver->work_serializer->Run( in on_writable()
427 socks[i], ev_driver->pollset_set, ev_driver->work_serializer); in grpc_ares_notify_on_event_locked()
522 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in grpc_ares_ev_driver_create_locked() argument
539 (*ev_driver)->work_serializer = std::move(work_serializer); in grpc_ares_ev_driver_create_locked()
546 grpc_core::NewGrpcPolledFdFactory((*ev_driver)->work_serializer); in grpc_ares_ev_driver_create_locked()
827 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked() argument
[all …]
|
| D | grpc_ares_ev_driver.h | 62 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) = 0;
68 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
|
| D | grpc_ares_wrapper_fallback.cc | 35 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in grpc_dns_lookup_ares_locked_impl() argument
45 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) =
|
| D | grpc_ares_ev_driver_windows.cc | 103 std::shared_ptr<WorkSerializer> work_serializer, in GrpcPolledFdWindows() argument
105 : work_serializer_(std::move(work_serializer)), in GrpcPolledFdWindows()
704 explicit SockToPolledFdMap(std::shared_ptr<WorkSerializer> work_serializer) in SockToPolledFdMap() argument
705 : work_serializer_(std::move(work_serializer)) {} in SockToPolledFdMap()
869 std::shared_ptr<WorkSerializer> work_serializer) in GrpcPolledFdFactoryWindows() argument
870 : sock_to_polled_fd_map_(std::move(work_serializer)) {} in GrpcPolledFdFactoryWindows()
874 std::shared_ptr<WorkSerializer> work_serializer) override { in NewGrpcPolledFdLocked() argument
892 std::shared_ptr<WorkSerializer> work_serializer) { in NewGrpcPolledFdFactory() argument
894 std::move(work_serializer)); in NewGrpcPolledFdFactory()
|
| D | grpc_ares_ev_driver_posix.cc | 102 std::shared_ptr<WorkSerializer> work_serializer) { in NewGrpcPolledFdFactory() argument
103 (void)work_serializer; in NewGrpcPolledFdFactory()
|
| D | grpc_ares_wrapper.h | 72 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
|
| /third_party/grpc/src/core/lib/transport/ |
| D | connectivity_state.cc | 62 const std::shared_ptr<WorkSerializer>& work_serializer) in Notifier() argument
64 if (work_serializer != nullptr) { in Notifier()
65 work_serializer->Run( in Notifier()
|
| D | connectivity_state.h | 81 std::shared_ptr<WorkSerializer> work_serializer = nullptr)
82 : work_serializer_(std::move(work_serializer)) {} in work_serializer_() argument
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | resolver_registry.cc | 158 std::shared_ptr<WorkSerializer> work_serializer, in CreateResolver() argument
167 resolver_args.work_serializer = std::move(work_serializer); in CreateResolver()
|
| D | lb_policy.cc | 40 work_serializer_(std::move(args.work_serializer)), in LoadBalancingPolicy()
115 parent->work_serializer()->Run( in Pick()
|
| D | resolving_lb_policy.cc | 155 target_uri_.get(), args.args, interested_parties(), work_serializer(), in ResolvingLoadBalancingPolicy()
250 lb_policy_args.work_serializer = work_serializer(); in CreateLbPolicyLocked()
|
| D | resolver_factory.h | 44 std::shared_ptr<WorkSerializer> work_serializer; member
|
| D | resolver_registry.h | 72 std::shared_ptr<WorkSerializer> work_serializer,
|
| D | lb_policy.h | 329 std::shared_ptr<WorkSerializer> work_serializer; member
400 std::shared_ptr<WorkSerializer> work_serializer() const { in work_serializer() function
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 370 : AsyncConnectivityStateWatcherInterface(parent->work_serializer()), in StateWatcher()
909 lb_calld->grpclb_policy()->work_serializer()->Run( in MaybeSendClientLoadReport()
988 lb_calld->grpclb_policy()->work_serializer()->Run( in ClientLoadReportDone()
1007 lb_calld->grpclb_policy()->work_serializer()->Run( in OnInitialRequestSent()
1026 lb_calld->grpclb_policy()->work_serializer()->Run( in OnBalancerMessageReceived()
1190 lb_calld->grpclb_policy()->work_serializer()->Run( in OnBalancerStatusReceived()
1542 grpclb_policy->work_serializer()->Run( in OnBalancerCallRetryTimer()
1586 grpclb_policy->work_serializer()->Run( in OnFallbackTimer()
1630 lb_policy_args.work_serializer = work_serializer(); in CreateChildPolicyLocked()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/ |
| D | child_policy_handler.cc | 263 lb_policy_args.work_serializer = work_serializer(); in CreateChildPolicy()
|
| /third_party/grpc/test/core/util/ |
| D | test_lb_policies.cc | 56 delegate_args.work_serializer = work_serializer(); in ForwardingLoadBalancingPolicy()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/priority/ |
| D | priority.cc | 576 lb_policy_args.work_serializer = priority_policy_->work_serializer(); in CreateChildPolicyLocked()
661 self->priority_policy_->work_serializer()->Run( in OnFailoverTimer()
718 self->priority_policy_->work_serializer()->Run( in OnDeactivationTimer()
|