| /third_party/grpc/src/core/ext/filters/client_channel/resolver/fake/ |
| D | fake_resolver.cc | 72 std::shared_ptr<WorkSerializer> work_serializer_; member in grpc_core::FakeResolver
94 : work_serializer_(std::move(args.work_serializer)), in FakeResolver()
127 work_serializer_->Run([this]() { ReturnReresolutionResult(); }, in RequestReresolutionLocked()
242 resolver->work_serializer_->Run([arg]() { arg->SetResponseLocked(); }, in SetResponse()
256 resolver->work_serializer_->Run( in SetReresolutionResponse()
269 resolver->work_serializer_->Run( in UnsetReresolutionResponse()
282 resolver->work_serializer_->Run([arg]() { arg->SetFailureLocked(); }, in SetFailure()
296 resolver->work_serializer_->Run([arg]() { arg->SetFailureLocked(); }, in SetFailureOnReresolution()
308 resolver_->work_serializer_->Run([arg]() { arg->SetResponseLocked(); }, in SetFakeResolver()
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/ |
| D | grpc_ares_ev_driver_windows.cc | 105 : work_serializer_(std::move(work_serializer)), in GrpcPolledFdWindows()
152 work_serializer_->Run([this]() { ContinueRegisterForOnReadableLocked(); }, in RegisterForOnReadableLocked()
209 work_serializer_->Run( in RegisterForOnWriteableLocked()
425 grpc_polled_fd->work_serializer_->Run( in OnTcpConnect()
466 work_serializer_->Run([this]() { ContinueRegisterForOnReadableLocked(); }, in OnTcpConnectLocked()
470 work_serializer_->Run( in OnTcpConnectLocked()
580 polled_fd->work_serializer_->Run( in OnIocpReadable()
625 polled_fd->work_serializer_->Run( in OnIocpWriteable()
662 std::shared_ptr<WorkSerializer> work_serializer_; member in grpc_core::GrpcPolledFdWindows
705 : work_serializer_(std::move(work_serializer)) {} in SockToPolledFdMap()
[all …]
|
| D | grpc_ares_ev_driver_libuv.cc | 50 work_serializer_(std::move(work_serializer)) { in GrpcPolledFdLibuv()
111 std::shared_ptr<WorkSerializer> work_serializer_; member in grpc_core::GrpcPolledFdLibuv
157 polled_fd->work_serializer_->Run([arg]() { ares_uv_poll_cb_locked(arg); }, in ares_uv_poll_cb()
|
| D | dns_resolver_ares.cc | 94 std::shared_ptr<WorkSerializer> work_serializer_; member in grpc_core::__anonf0a5fd5f0111::AresDnsResolver
136 work_serializer_(std::move(args.work_serializer)), in AresDnsResolver()
199 r->work_serializer_->Run([r, error]() { r->OnNextResolutionLocked(error); }, in OnNextResolution()
311 r->work_serializer_->Run([r, error]() { r->OnResolvedLocked(error); }, in OnResolved()
430 query_timeout_ms_, work_serializer_); in StartResolvingLocked()
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/google_c2p/ |
| D | google_c2p_resolver.cc | 94 std::shared_ptr<WorkSerializer> work_serializer_; member in grpc_core::__anonb370f3f10111::GoogleCloud2ProdResolver
163 resolver_->work_serializer_->Run( in MaybeCallOnDone()
230 : work_serializer_(std::move(args.work_serializer)), in GoogleCloud2ProdResolver()
245 args.pollset_set, work_serializer_, std::move(args.result_handler)); in GoogleCloud2ProdResolver()
252 args.pollset_set, work_serializer_, std::move(args.result_handler)); in GoogleCloud2ProdResolver()
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/dns/native/ |
| D | dns_resolver.cc | 80 std::shared_ptr<WorkSerializer> work_serializer_; member in grpc_core::__anon0b9434ef0111::NativeDnsResolver
106 work_serializer_(std::move(args.work_serializer)), in NativeDnsResolver()
154 r->work_serializer_->Run([r, error]() { r->OnNextResolutionLocked(error); }, in OnNextResolution()
170 r->work_serializer_->Run([r, error]() { r->OnResolvedLocked(error); }, in OnResolved()
|
| /third_party/grpc/src/core/lib/transport/ |
| D | connectivity_state.h | 82 : work_serializer_(std::move(work_serializer)) {} in work_serializer_() function
89 std::shared_ptr<WorkSerializer> work_serializer_;
|
| D | connectivity_state.cc | 96 work_serializer_); // Deletes itself when done. in Notify()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | lb_policy.h | 401 return work_serializer_; in work_serializer()
415 std::shared_ptr<WorkSerializer> work_serializer_;
|
| D | lb_policy.cc | 40 work_serializer_(std::move(args.work_serializer)), in LoadBalancingPolicy()
|
| D | client_channel.cc | 188 WorkSerializer* work_serializer() const { return work_serializer_.get(); } in work_serializer()
359 std::shared_ptr<WorkSerializer> work_serializer_; member in grpc_core::__anon6b4c07050111::ChannelData
1429 parent->chand_->work_serializer_->Run( in ~WatcherWrapper()
1442 parent_->chand_->work_serializer_->Run( in OnConnectivityStateChange()
1582 chand_->work_serializer_->Run( in ExternalConnectivityWatcher()
1631 chand_->work_serializer_->Run([this]() { RemoveWatcherLocked(); }, in Notify()
1644 chand_->work_serializer_->Run([this]() { RemoveWatcherLocked(); }, in Cancel()
1672 chand_->work_serializer_->Run([this]() { AddWatcherLocked(); }, in ConnectivityWatcherAdder()
1698 chand_->work_serializer_->Run([this]() { RemoveWatcherLocked(); }, in ConnectivityWatcherRemover()
1879 work_serializer_(std::make_shared<WorkSerializer>()), in ChannelData()
[all …]
|
| /third_party/grpc/src/core/ext/filters/client_channel/xds/ |
| D | xds_client.cc | 175 self->ads_calld_->xds_client()->work_serializer_->Run( in OnTimer()
397 parent->xds_client()->work_serializer_), in StateWatcher()
651 calld->chand_->xds_client()->work_serializer_->Run( in OnRetryTimer()
1149 ads_calld->xds_client()->work_serializer_->Run( in OnRequestSent()
1182 ads_calld->xds_client()->work_serializer_->Run( in OnResponseReceived()
1289 ads_calld->xds_client()->work_serializer_->Run( in OnStatusReceived()
1361 self->xds_client()->work_serializer_->Run( in OnNextReportTimer()
1432 self->xds_client()->work_serializer_->Run( in OnReportDone()
1604 lrs_calld->xds_client()->work_serializer_->Run( in OnInitialRequestSent()
1620 lrs_calld->xds_client()->work_serializer_->Run( in OnResponseReceived()
[all …]
|
| D | xds_client.h | 263 std::shared_ptr<WorkSerializer> work_serializer_; variable
|
| /third_party/grpc/src/core/ext/filters/client_channel/resolver/xds/ |
| D | xds_resolver.cc | 49 : work_serializer_(std::move(args.work_serializer)), in XdsResolver()
185 std::shared_ptr<WorkSerializer> work_serializer_; member in grpc_core::__anon0bd98fcd0111::XdsResolver
236 self->resolver_->work_serializer_->Run( in RunInExecCtx()
494 resolver->work_serializer_->Run( in GetCallConfig()
|