Looper.cpp revision 7901eb25c60b1df00050d6c3772505d8dcfcdab9
17901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// 27901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// Copyright 2010 The Android Open Source Project 37901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// 47901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// A looper implementation based on epoll(). 57901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// 67901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#define LOG_TAG "Looper" 77901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 87901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown//#define LOG_NDEBUG 0 97901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 107901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// Debugs poll and wake interactions. 117901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#define DEBUG_POLL_AND_WAKE 0 127901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 137901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// Debugs callback registration and invocation. 147901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#define DEBUG_CALLBACKS 0 157901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 167901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#include <cutils/log.h> 177901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#include <utils/Looper.h> 187901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#include <utils/Timers.h> 197901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 207901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#include <unistd.h> 217901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#include <fcntl.h> 227901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#include <sys/epoll.h> 237901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 247901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 257901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownnamespace android { 267901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 277901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownstatic pthread_mutex_t gTLSMutex = PTHREAD_MUTEX_INITIALIZER; 287901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownstatic bool gHaveTLS = false; 297901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownstatic pthread_key_t gTLS = 0; 307901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 317901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// Hint for number of file descriptors to be associated with the epoll instance. 327901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownstatic const int EPOLL_SIZE_HINT = 8; 337901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 347901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// Maximum number of file descriptors for which to retrieve poll events each iteration. 357901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownstatic const int EPOLL_MAX_EVENTS = 16; 367901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 377901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff BrownLooper::Looper(bool allowNonCallbacks) : 387901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mAllowNonCallbacks(allowNonCallbacks), 397901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mResponseIndex(0) { 407901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mEpollFd = epoll_create(EPOLL_SIZE_HINT); 417901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOG_ALWAYS_FATAL_IF(mEpollFd < 0, "Could not create epoll instance. errno=%d", errno); 427901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 437901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int wakeFds[2]; 447901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int result = pipe(wakeFds); 457901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not create wake pipe. errno=%d", errno); 467901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 477901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mWakeReadPipeFd = wakeFds[0]; 487901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mWakeWritePipeFd = wakeFds[1]; 497901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 507901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = fcntl(mWakeReadPipeFd, F_SETFL, O_NONBLOCK); 517901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake read pipe non-blocking. errno=%d", 527901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown errno); 537901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 547901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = fcntl(mWakeWritePipeFd, F_SETFL, O_NONBLOCK); 557901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake write pipe non-blocking. errno=%d", 567901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown errno); 577901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 587901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown struct epoll_event eventItem; 597901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown eventItem.events = EPOLLIN; 607901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown eventItem.data.fd = mWakeReadPipeFd; 617901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = epoll_ctl(mEpollFd, EPOLL_CTL_ADD, mWakeReadPipeFd, & eventItem); 627901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not add wake read pipe to epoll instance. errno=%d", 637901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown errno); 647901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 657901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 667901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff BrownLooper::~Looper() { 677901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown close(mWakeReadPipeFd); 687901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown close(mWakeWritePipeFd); 697901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown close(mEpollFd); 707901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 717901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 727901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownvoid Looper::threadDestructor(void *st) { 737901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown Looper* const self = static_cast<Looper*>(st); 747901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (self != NULL) { 757901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown self->decStrong((void*)threadDestructor); 767901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 777901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 787901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 797901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownvoid Looper::setForThread(const sp<Looper>& looper) { 807901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown sp<Looper> old = getForThread(); // also has side-effect of initializing TLS 817901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 827901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (looper != NULL) { 837901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown looper->incStrong((void*)threadDestructor); 847901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 857901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 867901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown pthread_setspecific(gTLS, looper.get()); 877901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 887901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (old != NULL) { 897901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown old->decStrong((void*)threadDestructor); 907901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 917901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 927901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 937901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownsp<Looper> Looper::getForThread() { 947901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (!gHaveTLS) { 957901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown pthread_mutex_lock(&gTLSMutex); 967901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (pthread_key_create(&gTLS, threadDestructor) != 0) { 977901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown pthread_mutex_unlock(&gTLSMutex); 987901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return NULL; 997901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1007901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown gHaveTLS = true; 1017901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown pthread_mutex_unlock(&gTLSMutex); 1027901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1037901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1047901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return (Looper*)pthread_getspecific(gTLS); 1057901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1067901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1077901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownsp<Looper> Looper::prepare(int opts) { 1087901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown bool allowNonCallbacks = opts & ALOOPER_PREPARE_ALLOW_NON_CALLBACKS; 1097901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown sp<Looper> looper = Looper::getForThread(); 1107901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (looper == NULL) { 1117901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown looper = new Looper(allowNonCallbacks); 1127901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown Looper::setForThread(looper); 1137901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1147901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (looper->getAllowNonCallbacks() != allowNonCallbacks) { 1157901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGW("Looper already prepared for this thread with a different value for the " 1167901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown "ALOOPER_PREPARE_ALLOW_NON_CALLBACKS option."); 1177901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1187901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return looper; 1197901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1207901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1217901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownbool Looper::getAllowNonCallbacks() const { 1227901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return mAllowNonCallbacks; 1237901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1247901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1257901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::pollOnce(int timeoutMillis, int* outFd, int* outEvents, void** outData) { 1267901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int result = 0; 1277901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown for (;;) { 1287901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown while (mResponseIndex < mResponses.size()) { 1297901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown const Response& response = mResponses.itemAt(mResponseIndex++); 1307901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (! response.request.callback) { 1317901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 1327901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ pollOnce - returning signalled identifier %d: " 1337901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown "fd=%d, events=0x%x, data=%p", this, 1347901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown response.request.ident, response.request.fd, 1357901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown response.events, response.request.data); 1367901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 1377901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (outFd != NULL) *outFd = response.request.fd; 1387901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (outEvents != NULL) *outEvents = response.events; 1397901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (outData != NULL) *outData = response.request.data; 1407901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return response.request.ident; 1417901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1427901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1437901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1447901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (result != 0) { 1457901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 1467901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ pollOnce - returning result %d", this, result); 1477901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 1487901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (outFd != NULL) *outFd = 0; 1497901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (outEvents != NULL) *outEvents = NULL; 1507901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (outData != NULL) *outData = NULL; 1517901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return result; 1527901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1537901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1547901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = pollInner(timeoutMillis); 1557901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1567901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1577901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1587901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::pollInner(int timeoutMillis) { 1597901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 1607901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ pollOnce - waiting: timeoutMillis=%d", this, timeoutMillis); 1617901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 1627901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown struct epoll_event eventItems[EPOLL_MAX_EVENTS]; 1637901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int eventCount = epoll_wait(mEpollFd, eventItems, EPOLL_MAX_EVENTS, timeoutMillis); 1647901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (eventCount < 0) { 1657901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (errno != EINTR) { 1667901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGW("Poll failed with an unexpected error, errno=%d", errno); 1677901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1687901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return ALOOPER_POLL_ERROR; 1697901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1707901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1717901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (eventCount == 0) { 1727901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 1737901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ pollOnce - timeout", this); 1747901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 1757901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return ALOOPER_POLL_TIMEOUT; 1767901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1777901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1787901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int result = ALOOPER_POLL_WAKE; 1797901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mResponses.clear(); 1807901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mResponseIndex = 0; 1817901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1827901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 1837901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ pollOnce - handling events from %d fds", this, eventCount); 1847901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 1857901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown { // acquire lock 1867901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown AutoMutex _l(mLock); 1877901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown for (int i = 0; i < eventCount; i++) { 1887901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int fd = eventItems[i].data.fd; 1897901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown uint32_t epollEvents = eventItems[i].events; 1907901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (fd == mWakeReadPipeFd) { 1917901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollEvents & EPOLLIN) { 1927901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 1937901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ pollOnce - awoken", this); 1947901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 1957901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown char buffer[16]; 1967901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown ssize_t nRead; 1977901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown do { 1987901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown nRead = read(mWakeReadPipeFd, buffer, sizeof(buffer)); 1997901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } while (nRead == sizeof(buffer)); 2007901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } else { 2017901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGW("Ignoring unexpected epoll events 0x%x on wake read pipe.", epollEvents); 2027901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2037901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } else { 2047901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown ssize_t requestIndex = mRequests.indexOfKey(fd); 2057901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (requestIndex >= 0) { 2067901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int events = 0; 2077901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollEvents & EPOLLIN) events |= ALOOPER_EVENT_INPUT; 2087901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollEvents & EPOLLOUT) events |= ALOOPER_EVENT_OUTPUT; 2097901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollEvents & EPOLLERR) events |= ALOOPER_EVENT_ERROR; 2107901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollEvents & EPOLLHUP) events |= ALOOPER_EVENT_HANGUP; 2117901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2127901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown Response response; 2137901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown response.events = events; 2147901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown response.request = mRequests.valueAt(requestIndex); 2157901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mResponses.push(response); 2167901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } else { 2177901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGW("Ignoring unexpected epoll events 0x%x on fd %d that is " 2187901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown "no longer registered.", epollEvents, fd); 2197901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2207901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2217901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2227901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2237901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2247901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown for (size_t i = 0; i < mResponses.size(); i++) { 2257901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown const Response& response = mResponses.itemAt(i); 2267901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (response.request.callback) { 2277901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE || DEBUG_CALLBACKS 2287901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ pollOnce - invoking callback: fd=%d, events=0x%x, data=%p", this, 2297901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown response.request.fd, response.events, response.request.data); 2307901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 2317901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int callbackResult = response.request.callback( 2327901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown response.request.fd, response.events, response.request.data); 2337901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (callbackResult == 0) { 2347901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown removeFd(response.request.fd); 2357901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2367901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2377901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = ALOOPER_POLL_CALLBACK; 2387901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2397901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2407901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return result; 2417901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 2427901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2437901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::pollAll(int timeoutMillis, int* outFd, int* outEvents, void** outData) { 2447901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (timeoutMillis <= 0) { 2457901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int result; 2467901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown do { 2477901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = pollOnce(timeoutMillis, outFd, outEvents, outData); 2487901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } while (result == ALOOPER_POLL_CALLBACK); 2497901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return result; 2507901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } else { 2517901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown nsecs_t endTime = systemTime(SYSTEM_TIME_MONOTONIC) 2527901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown + milliseconds_to_nanoseconds(timeoutMillis); 2537901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2547901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown for (;;) { 2557901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int result = pollOnce(timeoutMillis, outFd, outEvents, outData); 2567901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (result != ALOOPER_POLL_CALLBACK) { 2577901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return result; 2587901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2597901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2607901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown nsecs_t timeoutNanos = endTime - systemTime(SYSTEM_TIME_MONOTONIC); 2617901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (timeoutNanos <= 0) { 2627901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return ALOOPER_POLL_TIMEOUT; 2637901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2647901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2657901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown timeoutMillis = int(nanoseconds_to_milliseconds(timeoutNanos + 999999LL)); 2667901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2677901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2687901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 2697901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2707901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownvoid Looper::wake() { 2717901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 2727901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ wake", this); 2737901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 2747901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2757901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown ssize_t nWrite = write(mWakeWritePipeFd, "W", 1); 2767901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (nWrite != 1) { 2777901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (errno != EAGAIN) { 2787901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGW("Could not write wake signal, errno=%d", errno); 2797901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2807901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2817901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 2827901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2837901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::addFd(int fd, int ident, int events, ALooper_callbackFunc callback, void* data) { 2847901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_CALLBACKS 2857901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ addFd - fd=%d, ident=%d, events=0x%x, callback=%p, data=%p", this, fd, ident, 2867901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown events, callback, data); 2877901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 2887901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2897901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int epollEvents = 0; 2907901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (events & ALOOPER_EVENT_INPUT) epollEvents |= EPOLLIN; 2917901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (events & ALOOPER_EVENT_OUTPUT) epollEvents |= EPOLLOUT; 2927901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (events & ALOOPER_EVENT_ERROR) epollEvents |= EPOLLERR; 2937901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (events & ALOOPER_EVENT_HANGUP) epollEvents |= EPOLLHUP; 2947901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2957901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollEvents == 0) { 2967901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGE("Invalid attempt to set a callback with no selected poll events."); 2977901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 2987901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2997901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3007901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (! callback) { 3017901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (! mAllowNonCallbacks) { 3027901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGE("Invalid attempt to set NULL callback but not allowed for this looper."); 3037901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 3047901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3057901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3067901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (ident < 0) { 3077901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGE("Invalid attempt to set NULL callback with ident <= 0."); 3087901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 3097901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3107901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3117901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3127901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown { // acquire lock 3137901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown AutoMutex _l(mLock); 3147901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3157901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown Request request; 3167901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown request.fd = fd; 3177901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown request.ident = ident; 3187901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown request.callback = callback; 3197901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown request.data = data; 3207901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3217901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown struct epoll_event eventItem; 3227901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown eventItem.events = epollEvents; 3237901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown eventItem.data.fd = fd; 3247901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3257901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown ssize_t requestIndex = mRequests.indexOfKey(fd); 3267901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (requestIndex < 0) { 3277901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int epollResult = epoll_ctl(mEpollFd, EPOLL_CTL_ADD, fd, & eventItem); 3287901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollResult < 0) { 3297901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGE("Error adding epoll events for fd %d, errno=%d", fd, errno); 3307901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 3317901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3327901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mRequests.add(fd, request); 3337901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } else { 3347901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int epollResult = epoll_ctl(mEpollFd, EPOLL_CTL_MOD, fd, & eventItem); 3357901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollResult < 0) { 3367901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGE("Error modifying epoll events for fd %d, errno=%d", fd, errno); 3377901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 3387901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3397901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mRequests.replaceValueAt(requestIndex, request); 3407901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3417901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } // release lock 3427901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return 1; 3437901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 3447901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3457901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::removeFd(int fd) { 3467901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_CALLBACKS 3477901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGD("%p ~ removeFd - fd=%d", this, fd); 3487901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 3497901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3507901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown { // acquire lock 3517901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown AutoMutex _l(mLock); 3527901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown ssize_t requestIndex = mRequests.indexOfKey(fd); 3537901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (requestIndex < 0) { 3547901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return 0; 3557901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3567901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3577901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int epollResult = epoll_ctl(mEpollFd, EPOLL_CTL_DEL, fd, NULL); 3587901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollResult < 0) { 3597901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOGE("Error removing epoll events for fd %d, errno=%d", fd, errno); 3607901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 3617901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3627901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3637901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mRequests.removeItemsAt(requestIndex); 3647901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } // request lock 3657901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return 1; 3667901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 3677901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3687901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} // namespace android 369