Home
last modified time | relevance | path

Searched refs:work_serializer_ (Results 1 – 9 of 9) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/resolver/dns/c_ares/
Dgrpc_ares_ev_driver_windows.cc105 : 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 …]
Dgrpc_ares_ev_driver_libuv.cc50 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()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dresolver.h135 return work_serializer_; in work_serializer()
141 std::shared_ptr<WorkSerializer> work_serializer_;
Dlb_policy.h401 return work_serializer_; in work_serializer()
415 std::shared_ptr<WorkSerializer> work_serializer_;
Dresolver.cc37 work_serializer_(std::move(work_serializer)), in Resolver()
Dlb_policy.cc40 work_serializer_(std::move(args.work_serializer)), in LoadBalancingPolicy()
Dclient_channel.cc188 WorkSerializer* work_serializer() const { return work_serializer_.get(); } in work_serializer()
359 std::shared_ptr<WorkSerializer> work_serializer_; member in grpc_core::__anon5e2240680111::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 …]
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dconnectivity_state.h82 : work_serializer_(std::move(work_serializer)) {} in work_serializer_() function
89 std::shared_ptr<WorkSerializer> work_serializer_;
Dconnectivity_state.cc96 work_serializer_); // Deletes itself when done. in Notify()