Home
last modified time | relevance | path

Searched defs:poller (Results 1 – 25 of 40) sorted by relevance

12

/external/webrtc/test/pc/e2e/
Dstats_poller_test.cc53 StatsPoller poller(/*observers=*/{&stats_observer}, in TEST() local
73 StatsPoller poller(/*observers=*/{&stats_observer}, in TEST() local
Dstats_poller.cc54 for (auto& poller : pollers_) { in PollStatsAndNotifyObservers() local
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/posix_engine/
Dposix_engine.cc244 PosixEventPoller* poller = poller_manager_->Poller(); in ConnectInternal() local
304 PosixEnginePollerManager::PosixEnginePollerManager(PosixEventPoller* poller) in PosixEnginePollerManager()
344 PosixEventEngine::PosixEventEngine(PosixEventPoller* poller) in PosixEventEngine()
373 PosixEventPoller* poller = poller_manager->Poller(); in PollerWorkInternal() local
581 PosixEventPoller* poller = poller_manager_->Poller(); in CreatePosixEndpointFromFd() local
Dev_epoll1_linux.cc64 Epoll1EventHandle(int fd, Epoll1Poller* poller) in Epoll1EventHandle()
220 void ForkPollerListAddPoller(Epoll1Poller* poller) { in ForkPollerListAddPoller()
228 void ForkPollerListRemovePoller(Epoll1Poller* poller) { in ForkPollerListRemovePoller()
253 Epoll1Poller* poller = fork_poller_list.front(); in ResetEventManagerOnFork() local
Devent_poller_posix_default.cc39 PosixEventPoller* poller = nullptr; in MakeDefaultPoller() local
Dev_poll_posix.cc77 PollEventHandle(int fd, PollPoller* poller) in PollEventHandle()
268 void ForkPollerListAddPoller(PollPoller* poller) { in ForkPollerListAddPoller()
276 void ForkPollerListRemovePoller(PollPoller* poller) { in ForkPollerListRemovePoller()
317 PollPoller* poller = fork_poller_list.front(); in ResetEventManagerOnFork() local
Dposix_engine_listener.cc58 PosixEventPoller* poller, std::shared_ptr<EventEngine> engine) in PosixEngineListenerImpl()
Dposix_engine_listener.h205 PosixEventPoller* poller, std::shared_ptr<EventEngine> engine) in PosixEngineListener()
/external/grpc-grpc/src/core/lib/event_engine/posix_engine/
Dposix_engine.cc274 PosixEventPoller* poller = poller_manager_->Poller(); in ConnectInternal() local
333 std::shared_ptr<PosixEventPoller> poller) in PosixEnginePollerManager()
373 PosixEventEngine::PosixEventEngine(std::shared_ptr<PosixEventPoller> poller) in PosixEventEngine()
410 PosixEventPoller* poller = poller_manager->Poller(); in PollerWorkInternal() local
666 PosixEventPoller* poller = poller_manager_->Poller(); in CreatePosixEndpointFromFd() local
Dev_epoll1_linux.cc63 Epoll1EventHandle(int fd, Epoll1Poller* poller) in Epoll1EventHandle()
219 void ForkPollerListAddPoller(Epoll1Poller* poller) { in ForkPollerListAddPoller()
227 void ForkPollerListRemovePoller(Epoll1Poller* poller) { in ForkPollerListRemovePoller()
252 Epoll1Poller* poller = fork_poller_list.front(); in ResetEventManagerOnFork() local
Devent_poller_posix_default.cc54 std::shared_ptr<PosixEventPoller> poller; in MakeDefaultPoller() local
Dev_poll_posix.cc76 PollEventHandle(int fd, std::shared_ptr<PollPoller> poller) in PollEventHandle()
265 void ForkPollerListAddPoller(PollPoller* poller) { in ForkPollerListAddPoller()
273 void ForkPollerListRemovePoller(PollPoller* poller) { in ForkPollerListRemovePoller()
314 PollPoller* poller = fork_poller_list.front(); in ResetEventManagerOnFork() local
Dposix_engine_listener.cc62 PosixEventPoller* poller, std::shared_ptr<EventEngine> engine) in PosixEngineListenerImpl()
Dposix_engine_listener.h207 PosixEventPoller* poller, std::shared_ptr<EventEngine> engine) in PosixEngineListener()
Dgrpc_polled_fd_posix.h104 explicit GrpcPolledFdFactoryPosix(PosixEventPoller* poller) in GrpcPolledFdFactoryPosix()
/external/rust/crates/v4l2r/lib/src/decoder/stateful/
Dcapture_thread.rs79 pub(super) poller: Poller, field
149 let mut poller = Poller::new(Arc::clone(device))?; in new() localVariable
522 let mut poller = self.poller; in run() localVariable
/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/core/lib/event_engine/windows/
Dwindows_engine.h96 IOCP* poller() { return &iocp_; } in poller() function
/external/grpc-grpc/src/core/lib/event_engine/windows/
Dwindows_engine.h105 IOCP* poller() { return &iocp_; } in poller() function
/external/grpc-grpc/test/core/event_engine/posix/
Dposix_endpoint_test.cc75 PosixEventPoller& poller, bool is_zero_copy_enabled, int num_connections, in CreateConnectedEndpoints()
155 Worker(std::shared_ptr<EventEngine> engine, PosixEventPoller* poller) in Worker()
Devent_poller_posix_test.cc536 PosixEventPoller* poller) in WakeupFdHandle()
643 Worker(Scheduler* scheduler, PosixEventPoller* poller, int num_handles, in Worker()
/external/rust/crates/v4l2r/lib/src/
Ddevice.rs29 pub mod poller; module
Dencoder.rs475 poller: Poller, field
493 let mut poller = Poller::new(Arc::clone(device))?; in new() localVariable
/external/rust/android-crates-io/crates/futures-macro/src/
Dselect.rs305 let poller: &mut &mut dyn FnMut( in select_inner() localVariable
/external/grpc-grpc/test/core/transport/chttp2/
Dremove_stream_from_stalled_lists_test.cc260 std::thread poller([call_cq]() { in HandleOneRpc() local
/external/virtio-media/device/src/
Dlib.rs223 poller: Poller, field

12