Home
last modified time | relevance | path

Searched refs:poller_ (Results 1 - 4 of 4) sorted by relevance

/foundation/resourceschedule/ffrt/src/eu/
H A Dloop.cpp41 if (!stopFlag_.load() && poller_.DeterminePollerReady()) { in Run()
42 poller_.PollOnce(0); in Run()
47 poller_.PollOnce(-1); in Run()
61 poller_.WakeUp(); in WakeUp()
75 return poller_.AddFdEvent(op, events, fd, data, cb); in EpollCtl()
81 return poller_.DelFdEvent(fd); in EpollCtl()
94 return poller_.RegisterTimer(timeout, data, cb, repeat); in TimerStart()
99 return poller_.UnregisterTimer(handle); in TimerStop()
H A Dloop.h38 Poller poller_; member in ffrt::Loop
/foundation/communication/netstack/utils/http_over_curl/src/
H A Depoll_multi_driver.cpp33 timeoutTimer_.RegisterForPolling(poller_); in Initialize()
34 incomingQueue_->GetSyncEvent().RegisterForPolling(poller_); in Initialize()
67 int eventsToHandle = poller_.Wait(events, MAX_EPOLL_EVENTS, waitEventsTimeoutMs); in Step()
161 auto curlSocket = new (std::nothrow) CurlSocketContext(poller_, socket, action); in MultiSocketCallback()
189 : poller_(poller), socketDescriptor_(sockDescriptor) in CurlSocketContext()
192 poller_.RegisterMe(socketDescriptor_, kind); in CurlSocketContext()
197 poller_.UnregisterMe(socketDescriptor_); in Reassign()
200 poller_.RegisterMe(socketDescriptor_, kind); in Reassign()
205 poller_.UnregisterMe(socketDescriptor_); in ~CurlSocketContext()
/foundation/communication/netstack/utils/http_over_curl/include/
H A Depoll_multi_driver.h48 HttpOverCurl::Epoller &poller_; member in OHOS::NetStack::HttpOverCurl::EpollMultiDriver::CurlSocketContext
65 HttpOverCurl::Epoller poller_; member in OHOS::NetStack::HttpOverCurl::EpollMultiDriver

Completed in 2 milliseconds