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> 223e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#include <limits.h> 237901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 247901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 257901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownnamespace android { 267901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 273e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown// --- WeakMessageHandler --- 283e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 293e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff BrownWeakMessageHandler::WeakMessageHandler(const wp<MessageHandler>& handler) : 303e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mHandler(handler) { 313e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown} 323e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 33dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff BrownWeakMessageHandler::~WeakMessageHandler() { 34dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown} 35dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown 363e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brownvoid WeakMessageHandler::handleMessage(const Message& message) { 373e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown sp<MessageHandler> handler = mHandler.promote(); 383e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (handler != NULL) { 393e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown handler->handleMessage(message); 403e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 413e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown} 423e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 433e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 44dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown// --- SimpleLooperCallback --- 45dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown 46dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff BrownSimpleLooperCallback::SimpleLooperCallback(ALooper_callbackFunc callback) : 47dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown mCallback(callback) { 48dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown} 49dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown 50dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff BrownSimpleLooperCallback::~SimpleLooperCallback() { 51dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown} 52dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown 53dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brownint SimpleLooperCallback::handleEvent(int fd, int events, void* data) { 54dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown return mCallback(fd, events, data); 55dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown} 56dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown 57dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown 583e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown// --- Looper --- 593e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 607901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// Hint for number of file descriptors to be associated with the epoll instance. 617901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownstatic const int EPOLL_SIZE_HINT = 8; 627901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 637901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown// Maximum number of file descriptors for which to retrieve poll events each iteration. 647901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownstatic const int EPOLL_MAX_EVENTS = 16; 657901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 66d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brownstatic pthread_once_t gTLSOnce = PTHREAD_ONCE_INIT; 67d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brownstatic pthread_key_t gTLSKey = 0; 68d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown 697901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff BrownLooper::Looper(bool allowNonCallbacks) : 703e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mAllowNonCallbacks(allowNonCallbacks), mSendingMessage(false), 713e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mResponseIndex(0), mNextMessageUptime(LLONG_MAX) { 727901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int wakeFds[2]; 737901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int result = pipe(wakeFds); 747901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not create wake pipe. errno=%d", errno); 757901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 767901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mWakeReadPipeFd = wakeFds[0]; 777901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mWakeWritePipeFd = wakeFds[1]; 787901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 797901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = fcntl(mWakeReadPipeFd, F_SETFL, O_NONBLOCK); 807901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake read pipe non-blocking. errno=%d", 817901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown errno); 827901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 837901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = fcntl(mWakeWritePipeFd, F_SETFL, O_NONBLOCK); 847901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake write pipe non-blocking. errno=%d", 857901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown errno); 867901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 8719159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn mIdling = false; 8819159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn 898d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown // Allocate the epoll instance and register the wake pipe. 908d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown mEpollFd = epoll_create(EPOLL_SIZE_HINT); 918d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown LOG_ALWAYS_FATAL_IF(mEpollFd < 0, "Could not create epoll instance. errno=%d", errno); 928d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 937901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown struct epoll_event eventItem; 94d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown memset(& eventItem, 0, sizeof(epoll_event)); // zero out unused members of data field union 957901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown eventItem.events = EPOLLIN; 967901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown eventItem.data.fd = mWakeReadPipeFd; 977901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = epoll_ctl(mEpollFd, EPOLL_CTL_ADD, mWakeReadPipeFd, & eventItem); 987901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not add wake read pipe to epoll instance. errno=%d", 997901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown errno); 1007901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1017901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1027901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff BrownLooper::~Looper() { 1037901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown close(mWakeReadPipeFd); 1047901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown close(mWakeWritePipeFd); 1057901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown close(mEpollFd); 1067901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1077901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 108d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brownvoid Looper::initTLSKey() { 109d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown int result = pthread_key_create(& gTLSKey, threadDestructor); 110d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not allocate TLS key."); 111d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown} 112d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown 1137901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownvoid Looper::threadDestructor(void *st) { 1147901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown Looper* const self = static_cast<Looper*>(st); 1157901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (self != NULL) { 1167901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown self->decStrong((void*)threadDestructor); 1177901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1187901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1197901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1207901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownvoid Looper::setForThread(const sp<Looper>& looper) { 1217901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown sp<Looper> old = getForThread(); // also has side-effect of initializing TLS 1227901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1237901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (looper != NULL) { 1247901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown looper->incStrong((void*)threadDestructor); 1257901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1267901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 127d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown pthread_setspecific(gTLSKey, looper.get()); 1287901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1297901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (old != NULL) { 1307901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown old->decStrong((void*)threadDestructor); 1317901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1327901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1337901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1347901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownsp<Looper> Looper::getForThread() { 135d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown int result = pthread_once(& gTLSOnce, initTLSKey); 136d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "pthread_once failed"); 1377901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 138d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown return (Looper*)pthread_getspecific(gTLSKey); 1397901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1407901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1417901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownsp<Looper> Looper::prepare(int opts) { 1427901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown bool allowNonCallbacks = opts & ALOOPER_PREPARE_ALLOW_NON_CALLBACKS; 1437901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown sp<Looper> looper = Looper::getForThread(); 1447901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (looper == NULL) { 1457901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown looper = new Looper(allowNonCallbacks); 1467901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown Looper::setForThread(looper); 1477901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1487901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (looper->getAllowNonCallbacks() != allowNonCallbacks) { 14961d341b8d3d771f4ef3dd54df0502b19b7a2ab4dSteve Block ALOGW("Looper already prepared for this thread with a different value for the " 1507901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown "ALOOPER_PREPARE_ALLOW_NON_CALLBACKS option."); 1517901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1527901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return looper; 1537901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1547901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1557901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownbool Looper::getAllowNonCallbacks() const { 1567901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return mAllowNonCallbacks; 1577901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1587901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1597901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::pollOnce(int timeoutMillis, int* outFd, int* outEvents, void** outData) { 1607901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int result = 0; 1617901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown for (;;) { 1627901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown while (mResponseIndex < mResponses.size()) { 1637901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown const Response& response = mResponses.itemAt(mResponseIndex++); 164dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown int ident = response.request.ident; 165dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown if (ident >= 0) { 1663e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown int fd = response.request.fd; 1673e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown int events = response.events; 1683e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown void* data = response.request.data; 1697901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 170eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ pollOnce - returning signalled identifier %d: " 1713e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown "fd=%d, events=0x%x, data=%p", 1723e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown this, ident, fd, events, data); 1737901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 1743e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (outFd != NULL) *outFd = fd; 1753e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (outEvents != NULL) *outEvents = events; 1763e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (outData != NULL) *outData = data; 1773e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown return ident; 1787901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1797901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1807901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1817901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (result != 0) { 1827901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 183eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ pollOnce - returning result %d", this, result); 1847901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 1857901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (outFd != NULL) *outFd = 0; 186dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown if (outEvents != NULL) *outEvents = 0; 1877901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (outData != NULL) *outData = NULL; 1887901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return result; 1897901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1907901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1917901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = pollInner(timeoutMillis); 1927901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 1937901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 1947901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 1957901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::pollInner(int timeoutMillis) { 1967901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 197eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ pollOnce - waiting: timeoutMillis=%d", this, timeoutMillis); 1987901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 1998d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 2003e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Adjust the timeout based on when the next message is due. 2013e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (timeoutMillis != 0 && mNextMessageUptime != LLONG_MAX) { 2023e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown nsecs_t now = systemTime(SYSTEM_TIME_MONOTONIC); 20343550eee5bfeaf7832487a2285ae86be0f7ce561Jeff Brown int messageTimeoutMillis = toMillisecondTimeoutDelay(now, mNextMessageUptime); 20443550eee5bfeaf7832487a2285ae86be0f7ce561Jeff Brown if (messageTimeoutMillis >= 0 20543550eee5bfeaf7832487a2285ae86be0f7ce561Jeff Brown && (timeoutMillis < 0 || messageTimeoutMillis < timeoutMillis)) { 20643550eee5bfeaf7832487a2285ae86be0f7ce561Jeff Brown timeoutMillis = messageTimeoutMillis; 2073e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 2083e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#if DEBUG_POLL_AND_WAKE 209eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ pollOnce - next message in %lldns, adjusted timeout: timeoutMillis=%d", 2103e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown this, mNextMessageUptime - now, timeoutMillis); 2113e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#endif 2123e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 2133e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 2143e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Poll. 2158d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown int result = ALOOPER_POLL_WAKE; 2168d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown mResponses.clear(); 2178d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown mResponseIndex = 0; 2188d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 21919159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn // We are about to idle. 22019159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn mIdling = true; 22119159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn 2227901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown struct epoll_event eventItems[EPOLL_MAX_EVENTS]; 2237901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int eventCount = epoll_wait(mEpollFd, eventItems, EPOLL_MAX_EVENTS, timeoutMillis); 2248d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 22519159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn // No longer idling. 22619159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn mIdling = false; 22719159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn 2283e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Acquire lock. 2293e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mLock.lock(); 2303e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 2313e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Check for poll error. 2327901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (eventCount < 0) { 233171bf9e69792f4796e27334c8a97dbd8576ad78aJeff Brown if (errno == EINTR) { 2348d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown goto Done; 2357901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 23661d341b8d3d771f4ef3dd54df0502b19b7a2ab4dSteve Block ALOGW("Poll failed with an unexpected error, errno=%d", errno); 2378d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown result = ALOOPER_POLL_ERROR; 2388d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown goto Done; 2397901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2407901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2413e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Check for poll timeout. 2427901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (eventCount == 0) { 2437901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 244eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ pollOnce - timeout", this); 2457901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 2468d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown result = ALOOPER_POLL_TIMEOUT; 2478d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown goto Done; 2487901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2497901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 2503e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Handle all events. 2517901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 252eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ pollOnce - handling events from %d fds", this, eventCount); 2537901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 2548d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 2559da1810050d8825e51dabdd0262173432d49c16cJeff Brown for (int i = 0; i < eventCount; i++) { 2569da1810050d8825e51dabdd0262173432d49c16cJeff Brown int fd = eventItems[i].data.fd; 2579da1810050d8825e51dabdd0262173432d49c16cJeff Brown uint32_t epollEvents = eventItems[i].events; 2589da1810050d8825e51dabdd0262173432d49c16cJeff Brown if (fd == mWakeReadPipeFd) { 2599da1810050d8825e51dabdd0262173432d49c16cJeff Brown if (epollEvents & EPOLLIN) { 2608d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown awoken(); 2617901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } else { 26261d341b8d3d771f4ef3dd54df0502b19b7a2ab4dSteve Block ALOGW("Ignoring unexpected epoll events 0x%x on wake read pipe.", epollEvents); 2639da1810050d8825e51dabdd0262173432d49c16cJeff Brown } 2649da1810050d8825e51dabdd0262173432d49c16cJeff Brown } else { 2659da1810050d8825e51dabdd0262173432d49c16cJeff Brown ssize_t requestIndex = mRequests.indexOfKey(fd); 2669da1810050d8825e51dabdd0262173432d49c16cJeff Brown if (requestIndex >= 0) { 2679da1810050d8825e51dabdd0262173432d49c16cJeff Brown int events = 0; 2689da1810050d8825e51dabdd0262173432d49c16cJeff Brown if (epollEvents & EPOLLIN) events |= ALOOPER_EVENT_INPUT; 2699da1810050d8825e51dabdd0262173432d49c16cJeff Brown if (epollEvents & EPOLLOUT) events |= ALOOPER_EVENT_OUTPUT; 2709da1810050d8825e51dabdd0262173432d49c16cJeff Brown if (epollEvents & EPOLLERR) events |= ALOOPER_EVENT_ERROR; 2719da1810050d8825e51dabdd0262173432d49c16cJeff Brown if (epollEvents & EPOLLHUP) events |= ALOOPER_EVENT_HANGUP; 2728d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown pushResponse(events, mRequests.valueAt(requestIndex)); 2739da1810050d8825e51dabdd0262173432d49c16cJeff Brown } else { 27461d341b8d3d771f4ef3dd54df0502b19b7a2ab4dSteve Block ALOGW("Ignoring unexpected epoll events 0x%x on fd %d that is " 2759da1810050d8825e51dabdd0262173432d49c16cJeff Brown "no longer registered.", epollEvents, fd); 2767901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2777901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2787901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 2798d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff BrownDone: ; 2808d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 2813e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Invoke pending message callbacks. 2823e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mNextMessageUptime = LLONG_MAX; 2833e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown while (mMessageEnvelopes.size() != 0) { 2843e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown nsecs_t now = systemTime(SYSTEM_TIME_MONOTONIC); 2853e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown const MessageEnvelope& messageEnvelope = mMessageEnvelopes.itemAt(0); 2863e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (messageEnvelope.uptime <= now) { 2873e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Remove the envelope from the list. 2883e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // We keep a strong reference to the handler until the call to handleMessage 2893e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // finishes. Then we drop it so that the handler can be deleted *before* 2903e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // we reacquire our lock. 2913e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown { // obtain handler 2923e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown sp<MessageHandler> handler = messageEnvelope.handler; 2933e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown Message message = messageEnvelope.message; 2943e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mMessageEnvelopes.removeAt(0); 2953e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mSendingMessage = true; 2963e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mLock.unlock(); 2973e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 2983e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#if DEBUG_POLL_AND_WAKE || DEBUG_CALLBACKS 299eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ pollOnce - sending message: handler=%p, what=%d", 3003e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown this, handler.get(), message.what); 3013e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#endif 3023e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown handler->handleMessage(message); 3033e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } // release handler 3043e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 3053e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mLock.lock(); 3063e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mSendingMessage = false; 3073e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown result = ALOOPER_POLL_CALLBACK; 3083e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } else { 3093e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // The last message left at the head of the queue determines the next wakeup time. 3103e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mNextMessageUptime = messageEnvelope.uptime; 3113e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown break; 3123e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 3133e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 3143e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 3153e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Release lock. 3163e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mLock.unlock(); 3173e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 3183e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Invoke all response callbacks. 3197901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown for (size_t i = 0; i < mResponses.size(); i++) { 320dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown Response& response = mResponses.editItemAt(i); 321dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown if (response.request.ident == ALOOPER_POLL_CALLBACK) { 3223e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown int fd = response.request.fd; 3233e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown int events = response.events; 3243e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown void* data = response.request.data; 3257901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE || DEBUG_CALLBACKS 326eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ pollOnce - invoking fd event callback %p: fd=%d, events=0x%x, data=%p", 327dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown this, response.request.callback.get(), fd, events, data); 3287901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 329dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown int callbackResult = response.request.callback->handleEvent(fd, events, data); 3307901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (callbackResult == 0) { 3313e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown removeFd(fd); 3327901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 333dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown // Clear the callback reference in the response structure promptly because we 334dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown // will not clear the response vector itself until the next poll. 335dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown response.request.callback.clear(); 3367901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = ALOOPER_POLL_CALLBACK; 3377901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3387901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3397901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return result; 3407901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 3417901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3427901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::pollAll(int timeoutMillis, int* outFd, int* outEvents, void** outData) { 3437901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (timeoutMillis <= 0) { 3447901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int result; 3457901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown do { 3467901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown result = pollOnce(timeoutMillis, outFd, outEvents, outData); 3477901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } while (result == ALOOPER_POLL_CALLBACK); 3487901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return result; 3497901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } else { 3507901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown nsecs_t endTime = systemTime(SYSTEM_TIME_MONOTONIC) 3517901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown + milliseconds_to_nanoseconds(timeoutMillis); 3527901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3537901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown for (;;) { 3547901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int result = pollOnce(timeoutMillis, outFd, outEvents, outData); 3557901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (result != ALOOPER_POLL_CALLBACK) { 3567901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return result; 3577901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3587901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 35943550eee5bfeaf7832487a2285ae86be0f7ce561Jeff Brown nsecs_t now = systemTime(SYSTEM_TIME_MONOTONIC); 36043550eee5bfeaf7832487a2285ae86be0f7ce561Jeff Brown timeoutMillis = toMillisecondTimeoutDelay(now, endTime); 36143550eee5bfeaf7832487a2285ae86be0f7ce561Jeff Brown if (timeoutMillis == 0) { 3627901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return ALOOPER_POLL_TIMEOUT; 3637901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3647901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3657901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3667901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 3677901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3687901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownvoid Looper::wake() { 3697901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_POLL_AND_WAKE 370eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ wake", this); 3717901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 3727901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 373171bf9e69792f4796e27334c8a97dbd8576ad78aJeff Brown ssize_t nWrite; 374171bf9e69792f4796e27334c8a97dbd8576ad78aJeff Brown do { 375171bf9e69792f4796e27334c8a97dbd8576ad78aJeff Brown nWrite = write(mWakeWritePipeFd, "W", 1); 376171bf9e69792f4796e27334c8a97dbd8576ad78aJeff Brown } while (nWrite == -1 && errno == EINTR); 377171bf9e69792f4796e27334c8a97dbd8576ad78aJeff Brown 3787901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (nWrite != 1) { 3797901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (errno != EAGAIN) { 38061d341b8d3d771f4ef3dd54df0502b19b7a2ab4dSteve Block ALOGW("Could not write wake signal, errno=%d", errno); 3817901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3827901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 3837901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 3847901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 3858d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brownvoid Looper::awoken() { 3868d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown#if DEBUG_POLL_AND_WAKE 387eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ awoken", this); 3888d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown#endif 3898d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 3908d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown char buffer[16]; 3918d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown ssize_t nRead; 3928d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown do { 3938d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown nRead = read(mWakeReadPipeFd, buffer, sizeof(buffer)); 3948d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown } while ((nRead == -1 && errno == EINTR) || nRead == sizeof(buffer)); 3958d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown} 3968d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 3978d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brownvoid Looper::pushResponse(int events, const Request& request) { 3988d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown Response response; 3998d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown response.events = events; 4008d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown response.request = request; 4018d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown mResponses.push(response); 4028d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown} 4038d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 4047901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::addFd(int fd, int ident, int events, ALooper_callbackFunc callback, void* data) { 405dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown return addFd(fd, ident, events, callback ? new SimpleLooperCallback(callback) : NULL, data); 406dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown} 407dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown 408dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brownint Looper::addFd(int fd, int ident, int events, const sp<LooperCallback>& callback, void* data) { 4097901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_CALLBACKS 410eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ addFd - fd=%d, ident=%d, events=0x%x, callback=%p, data=%p", this, fd, ident, 411dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown events, callback.get(), data); 4127901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 4137901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 414dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown if (!callback.get()) { 4157901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (! mAllowNonCallbacks) { 4161b781ab0e0e8d59a7a8d1140bf6dee96a48a160cSteve Block ALOGE("Invalid attempt to set NULL callback but not allowed for this looper."); 4177901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 4187901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 4197901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4207901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (ident < 0) { 421dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown ALOGE("Invalid attempt to set NULL callback with ident < 0."); 4227901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 4237901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 424dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown } else { 425dd1b0378cec939e7c90f8e8d8216b481f9f2035aJeff Brown ident = ALOOPER_POLL_CALLBACK; 4267901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 4277901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4288d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown int epollEvents = 0; 4298d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown if (events & ALOOPER_EVENT_INPUT) epollEvents |= EPOLLIN; 4308d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown if (events & ALOOPER_EVENT_OUTPUT) epollEvents |= EPOLLOUT; 4318d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown 4327901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown { // acquire lock 4337901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown AutoMutex _l(mLock); 4347901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4357901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown Request request; 4367901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown request.fd = fd; 4377901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown request.ident = ident; 4387901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown request.callback = callback; 4397901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown request.data = data; 4407901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4417901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown struct epoll_event eventItem; 442d18051870e8e2a5f55237a2c11fde75f46082639Jeff Brown memset(& eventItem, 0, sizeof(epoll_event)); // zero out unused members of data field union 4437901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown eventItem.events = epollEvents; 4447901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown eventItem.data.fd = fd; 4457901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4467901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown ssize_t requestIndex = mRequests.indexOfKey(fd); 4477901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (requestIndex < 0) { 4487901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int epollResult = epoll_ctl(mEpollFd, EPOLL_CTL_ADD, fd, & eventItem); 4497901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollResult < 0) { 4501b781ab0e0e8d59a7a8d1140bf6dee96a48a160cSteve Block ALOGE("Error adding epoll events for fd %d, errno=%d", fd, errno); 4517901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 4527901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 4537901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mRequests.add(fd, request); 4547901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } else { 4557901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int epollResult = epoll_ctl(mEpollFd, EPOLL_CTL_MOD, fd, & eventItem); 4567901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollResult < 0) { 4571b781ab0e0e8d59a7a8d1140bf6dee96a48a160cSteve Block ALOGE("Error modifying epoll events for fd %d, errno=%d", fd, errno); 4587901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 4597901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 4607901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mRequests.replaceValueAt(requestIndex, request); 4617901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 4627901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } // release lock 4637901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return 1; 4647901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 4657901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4667901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brownint Looper::removeFd(int fd) { 4677901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#if DEBUG_CALLBACKS 468eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ removeFd - fd=%d", this, fd); 4697901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown#endif 4707901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4717901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown { // acquire lock 4727901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown AutoMutex _l(mLock); 4737901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown ssize_t requestIndex = mRequests.indexOfKey(fd); 4747901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (requestIndex < 0) { 4757901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return 0; 4767901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 4777901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4787901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown int epollResult = epoll_ctl(mEpollFd, EPOLL_CTL_DEL, fd, NULL); 4797901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown if (epollResult < 0) { 4801b781ab0e0e8d59a7a8d1140bf6dee96a48a160cSteve Block ALOGE("Error removing epoll events for fd %d, errno=%d", fd, errno); 4817901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return -1; 4827901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown } 4837901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4847901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown mRequests.removeItemsAt(requestIndex); 4858d15c74d50fd01d6e63970aadd261a9d3bed27e7Jeff Brown } // release lock 4867901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown return 1; 4877901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} 4887901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown 4893e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brownvoid Looper::sendMessage(const sp<MessageHandler>& handler, const Message& message) { 490aa13c1b90e5d9cae064bb425dd094ccbd411e073Jeff Brown nsecs_t now = systemTime(SYSTEM_TIME_MONOTONIC); 491aa13c1b90e5d9cae064bb425dd094ccbd411e073Jeff Brown sendMessageAtTime(now, handler, message); 4923e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown} 4933e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 4943e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brownvoid Looper::sendMessageDelayed(nsecs_t uptimeDelay, const sp<MessageHandler>& handler, 4953e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown const Message& message) { 4963e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown nsecs_t now = systemTime(SYSTEM_TIME_MONOTONIC); 4973e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown sendMessageAtTime(now + uptimeDelay, handler, message); 4983e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown} 4993e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5003e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brownvoid Looper::sendMessageAtTime(nsecs_t uptime, const sp<MessageHandler>& handler, 5013e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown const Message& message) { 5023e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#if DEBUG_CALLBACKS 503eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ sendMessageAtTime - uptime=%lld, handler=%p, what=%d", 5043e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown this, uptime, handler.get(), message.what); 5053e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#endif 5063e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5073e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown size_t i = 0; 5083e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown { // acquire lock 5093e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown AutoMutex _l(mLock); 5103e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5113e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown size_t messageCount = mMessageEnvelopes.size(); 5123e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown while (i < messageCount && uptime >= mMessageEnvelopes.itemAt(i).uptime) { 5133e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown i += 1; 5143e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 5153e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5163e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown MessageEnvelope messageEnvelope(uptime, handler, message); 5173e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mMessageEnvelopes.insertAt(messageEnvelope, i, 1); 5183e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5193e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Optimization: If the Looper is currently sending a message, then we can skip 5203e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // the call to wake() because the next thing the Looper will do after processing 5213e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // messages is to decide when the next wakeup time should be. In fact, it does 5223e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // not even matter whether this code is running on the Looper thread. 5233e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (mSendingMessage) { 5243e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown return; 5253e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 5263e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } // release lock 5273e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5283e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown // Wake the poll loop only when we enqueue a new message at the head. 5293e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (i == 0) { 5303e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown wake(); 5313e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 5323e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown} 5333e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5343e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brownvoid Looper::removeMessages(const sp<MessageHandler>& handler) { 5353e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#if DEBUG_CALLBACKS 536eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ removeMessages - handler=%p", this, handler.get()); 5373e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#endif 5383e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5393e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown { // acquire lock 5403e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown AutoMutex _l(mLock); 5413e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5423e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown for (size_t i = mMessageEnvelopes.size(); i != 0; ) { 5433e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown const MessageEnvelope& messageEnvelope = mMessageEnvelopes.itemAt(--i); 5443e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (messageEnvelope.handler == handler) { 5453e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mMessageEnvelopes.removeAt(i); 5463e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 5473e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 5483e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } // release lock 5493e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown} 5503e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5513e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brownvoid Looper::removeMessages(const sp<MessageHandler>& handler, int what) { 5523e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#if DEBUG_CALLBACKS 553eb0953307ce75cec031aedbf21abff08e5a737e5Steve Block ALOGD("%p ~ removeMessages - handler=%p, what=%d", this, handler.get(), what); 5543e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown#endif 5553e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5563e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown { // acquire lock 5573e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown AutoMutex _l(mLock); 5583e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 5593e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown for (size_t i = mMessageEnvelopes.size(); i != 0; ) { 5603e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown const MessageEnvelope& messageEnvelope = mMessageEnvelopes.itemAt(--i); 5613e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown if (messageEnvelope.handler == handler 5623e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown && messageEnvelope.message.what == what) { 5633e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown mMessageEnvelopes.removeAt(i); 5643e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 5653e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } 5663e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown } // release lock 5673e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown} 5683e2e38bc5bbf658eb9940f72974270b11c5b84e1Jeff Brown 56919159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackbornbool Looper::isIdling() const { 57019159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn return mIdling; 57119159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn} 57219159f90020c04ac2f4dcb39424d740f765ed9a3Dianne Hackborn 5737901eb25c60b1df00050d6c3772505d8dcfcdab9Jeff Brown} // namespace android 574