Home
last modified time | relevance | path

Searched refs:work_serializer (Results 1 – 25 of 40) sorted by relevance

12

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/fake/
Dfake_resolver.cc92 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in FakeResolver()
124 work_serializer()->Run([this]() { ReturnReresolutionResult(); }, in RequestReresolutionLocked()
239 resolver->work_serializer()->Run([arg]() { arg->SetResponseLocked(); }, in SetResponse()
253 resolver->work_serializer()->Run( in SetReresolutionResponse()
266 resolver->work_serializer()->Run( in UnsetReresolutionResponse()
279 resolver->work_serializer()->Run([arg]() { arg->SetFailureLocked(); }, in SetFailure()
293 resolver->work_serializer()->Run([arg]() { arg->SetFailureLocked(); }, in SetFailureOnReresolution()
305 resolver_->work_serializer()->Run([arg]() { arg->SetResponseLocked(); }, in SetFakeResolver()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_ev_driver_libuv.cc47 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
Dgrpc_ares_wrapper.cc114 std::shared_ptr<grpc_core::WorkSerializer> work_serializer; member
288 driver->work_serializer->Run( in on_timeout()
300 driver->work_serializer->Run( in on_ares_backup_poll_alarm()
378 fdn->ev_driver->work_serializer->Run( in on_readable()
408 fdn->ev_driver->work_serializer->Run( in on_writable()
429 socks[i], ev_driver->pollset_set, ev_driver->work_serializer); in grpc_ares_notify_on_event_locked()
533 std::shared_ptr<grpc_core::WorkSerializer> work_serializer, in grpc_ares_ev_driver_create_locked() argument
550 (*ev_driver)->work_serializer = std::move(work_serializer); in grpc_ares_ev_driver_create_locked()
558 grpc_core::NewGrpcPolledFdFactory((*ev_driver)->work_serializer); in grpc_ares_ev_driver_create_locked()
839 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) { in grpc_dns_lookup_ares_continue_after_check_localhost_and_ip_literals_locked() argument
[all …]
Dgrpc_ares_ev_driver.h62 std::shared_ptr<grpc_core::WorkSerializer> work_serializer) = 0;
68 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
Dgrpc_ares_ev_driver_windows.cc103 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()
Dgrpc_ares_ev_driver_posix.cc102 std::shared_ptr<WorkSerializer> work_serializer) { in NewGrpcPolledFdFactory() argument
103 (void)work_serializer; in NewGrpcPolledFdFactory()
Ddns_resolver_ares.cc129 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in AresDnsResolver()
208 r->work_serializer()->Run([r, error]() { r->OnNextResolutionLocked(error); }, in OnNextResolution()
320 r->work_serializer()->Run([r, error]() { r->OnResolvedLocked(error); }, in OnResolved()
439 query_timeout_ms_, work_serializer()); in StartResolvingLocked()
Dgrpc_ares_wrapper.h72 std::shared_ptr<grpc_core::WorkSerializer> work_serializer);
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dconnectivity_state.cc62 const std::shared_ptr<WorkSerializer>& work_serializer) in Notifier() argument
64 if (work_serializer != nullptr) { in Notifier()
65 work_serializer->Run( in Notifier()
Dconnectivity_state.h81 std::shared_ptr<WorkSerializer> work_serializer = nullptr)
82 : work_serializer_(std::move(work_serializer)) {} in work_serializer_() argument
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dresolver.h128 Resolver(std::shared_ptr<WorkSerializer> work_serializer,
134 std::shared_ptr<WorkSerializer> work_serializer() const { in work_serializer() function
Dresolver_registry.cc158 std::shared_ptr<WorkSerializer> work_serializer, in CreateResolver() argument
167 resolver_args.work_serializer = std::move(work_serializer); in CreateResolver()
Dresolver.cc32 Resolver::Resolver(std::shared_ptr<WorkSerializer> work_serializer, in Resolver() argument
37 work_serializer_(std::move(work_serializer)), in Resolver()
Dlb_policy.cc40 work_serializer_(std::move(args.work_serializer)), in LoadBalancingPolicy()
115 parent->work_serializer()->Run( in Pick()
Dresolver_factory.h44 std::shared_ptr<WorkSerializer> work_serializer; member
Dresolver_registry.h72 std::shared_ptr<WorkSerializer> work_serializer,
Dlb_policy.h329 std::shared_ptr<WorkSerializer> work_serializer; member
400 std::shared_ptr<WorkSerializer> work_serializer() const { in work_serializer() function
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/native/
Ddns_resolver.cc102 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in NativeDnsResolver()
152 r->work_serializer()->Run([r, error]() { r->OnNextResolutionLocked(error); }, in OnNextResolution()
168 r->work_serializer()->Run([r, error]() { r->OnResolvedLocked(error); }, in OnResolved()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb.cc370 : 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()
1544 grpclb_policy->work_serializer()->Run( in OnBalancerCallRetryTimer()
1588 grpclb_policy->work_serializer()->Run( in OnFallbackTimer()
1632 lb_policy_args.work_serializer = work_serializer(); in CreateChildPolicyLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/
Dchild_policy_handler.cc263 lb_policy_args.work_serializer = work_serializer(); in CreateChildPolicy()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/priority/
Dpriority.cc574 lb_policy_args.work_serializer = priority_policy_->work_serializer(); in CreateChildPolicyLocked()
659 self->priority_policy_->work_serializer()->Run( in OnFailoverTimer()
716 self->priority_policy_->work_serializer()->Run( in OnDeactivationTimer()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/
Dxds_cluster_manager.cc438 lb_policy_args.work_serializer = in CreateChildPolicyLocked()
439 xds_cluster_manager_policy_->work_serializer(); in CreateChildPolicyLocked()
519 self->xds_cluster_manager_policy_->work_serializer()->Run( in OnDelayedRemovalTimer()
Dcds.cc181 self->parent_->work_serializer()->Run( in RunInExecCtx()
385 args.work_serializer = work_serializer(); in OnClusterChanged()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/weighted_target/
Dweighted_target.cc453 lb_policy_args.work_serializer = weighted_target_policy_->work_serializer(); in CreateChildPolicyLocked()
571 self->weighted_target_policy_->work_serializer()->Run( in OnDelayedRemovalTimer()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/sockaddr/
Dsockaddr_resolver.cc62 : Resolver(std::move(args.work_serializer), std::move(args.result_handler)), in SockaddrResolver()

12