Searched refs:pollable (Results 1 – 4 of 4) sorted by relevance
60 void Poller::addPollable(Pollable* pollable) { in addPollable() argument61 mPollables.push_back(pollable); in addPollable()89 for (auto& pollable : mPollables) { in run() local91 pollable->getPollData(&fds); in run()92 Pollable::Timestamp pollableDeadline = pollable->getTimeout(); in run()95 pollables[fds[i].fd] = pollable; in run()120 auto pollable = pollables.find(fd.fd); in run() local121 if (pollable == pollables.end()) { in run()129 if (!pollable->second->onReadAvailable(fd.fd, &status)) { in run()137 if (!pollable->second->onClose(fd.fd, &status)) { in run()[all …]
27 void addPollable(Pollable* pollable);
59 void Poller::addPollable(Pollable* pollable) { in addPollable() argument60 mPollables.push_back(pollable); in addPollable()88 for (auto& pollable : mPollables) { in run() local90 pollable->getPollData(&fds); in run()91 Pollable::Timestamp pollableDeadline = pollable->getTimeout(); in run()94 pollables[fds[i].fd] = pollable; in run()119 auto pollable = pollables.find(fd.fd); in run() local120 if (pollable == pollables.end()) { in run()128 if (!pollable->second->onReadAvailable(fd.fd, &status)) { in run()136 if (!pollable->second->onClose(fd.fd, &status)) { in run()[all …]