Searched refs:poller_ (Results 1 - 4 of 4) sorted by relevance
/foundation/resourceschedule/ffrt/src/eu/ |
H A D | loop.cpp | 41 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 D | loop.h | 38 Poller poller_; member in ffrt::Loop
|
/foundation/communication/netstack/utils/http_over_curl/src/ |
H A D | epoll_multi_driver.cpp | 33 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 D | epoll_multi_driver.h | 48 HttpOverCurl::Epoller &poller_; member in OHOS::NetStack::HttpOverCurl::EpollMultiDriver::CurlSocketContext 65 HttpOverCurl::Epoller poller_; member in OHOS::NetStack::HttpOverCurl::EpollMultiDriver
|
Completed in 2 milliseconds