Looper.cpp revision 59abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8a
159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown// 259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown// Copyright 2010 The Android Open Source Project 359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown// 459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown// A looper implementation based on epoll(). 559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown// 659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#define LOG_TAG "Looper" 759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown//#define LOG_NDEBUG 0 959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 1059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown// Debugs poll and wake interactions. 1159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#define DEBUG_POLL_AND_WAKE 0 1259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 1359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown// Debugs callback registration and invocation. 1459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#define DEBUG_CALLBACKS 0 1559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 1659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#include <cutils/log.h> 1759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#include <utils/Looper.h> 1859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#include <utils/Timers.h> 1959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 2059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#include <unistd.h> 2159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#include <fcntl.h> 2259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#include <sys/epoll.h> 2359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 2459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 2559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownnamespace android { 2659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 2759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownstatic pthread_mutex_t gTLSMutex = PTHREAD_MUTEX_INITIALIZER; 2859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownstatic bool gHaveTLS = false; 2959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownstatic pthread_key_t gTLS = 0; 3059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 3159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown// Hint for number of file descriptors to be associated with the epoll instance. 3259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownstatic const int EPOLL_SIZE_HINT = 8; 3359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 3459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown// Maximum number of file descriptors for which to retrieve poll events each iteration. 3559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownstatic const int EPOLL_MAX_EVENTS = 16; 3659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 3759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff BrownLooper::Looper(bool allowNonCallbacks) : 3859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mAllowNonCallbacks(allowNonCallbacks), 3959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mResponseIndex(0) { 4059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mEpollFd = epoll_create(EPOLL_SIZE_HINT); 4159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOG_ALWAYS_FATAL_IF(mEpollFd < 0, "Could not create epoll instance. errno=%d", errno); 4259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 4359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int wakeFds[2]; 4459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int result = pipe(wakeFds); 4559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not create wake pipe. errno=%d", errno); 4659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 4759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mWakeReadPipeFd = wakeFds[0]; 4859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mWakeWritePipeFd = wakeFds[1]; 4959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 5059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown result = fcntl(mWakeReadPipeFd, F_SETFL, O_NONBLOCK); 5159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake read pipe non-blocking. errno=%d", 5259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown errno); 5359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 5459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown result = fcntl(mWakeWritePipeFd, F_SETFL, O_NONBLOCK); 5559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not make wake write pipe non-blocking. errno=%d", 5659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown errno); 5759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 5859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown struct epoll_event eventItem; 5959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown eventItem.events = EPOLLIN; 6059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown eventItem.data.fd = mWakeReadPipeFd; 6159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown result = epoll_ctl(mEpollFd, EPOLL_CTL_ADD, mWakeReadPipeFd, & eventItem); 6259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOG_ALWAYS_FATAL_IF(result != 0, "Could not add wake read pipe to epoll instance. errno=%d", 6359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown errno); 6459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 6559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 6659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff BrownLooper::~Looper() { 6759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown close(mWakeReadPipeFd); 6859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown close(mWakeWritePipeFd); 6959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown close(mEpollFd); 7059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 7159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 7259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownvoid Looper::threadDestructor(void *st) { 7359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown Looper* const self = static_cast<Looper*>(st); 7459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (self != NULL) { 7559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown self->decStrong((void*)threadDestructor); 7659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 7759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 7859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 7959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownvoid Looper::setForThread(const sp<Looper>& looper) { 8059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown sp<Looper> old = getForThread(); // also has side-effect of initializing TLS 8159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 8259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (looper != NULL) { 8359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown looper->incStrong((void*)threadDestructor); 8459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 8559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 8659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown pthread_setspecific(gTLS, looper.get()); 8759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 8859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (old != NULL) { 8959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown old->decStrong((void*)threadDestructor); 9059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 9159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 9259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 9359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownsp<Looper> Looper::getForThread() { 9459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (!gHaveTLS) { 9559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown pthread_mutex_lock(&gTLSMutex); 9659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (pthread_key_create(&gTLS, threadDestructor) != 0) { 9759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown pthread_mutex_unlock(&gTLSMutex); 9859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return NULL; 9959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 10059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown gHaveTLS = true; 10159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown pthread_mutex_unlock(&gTLSMutex); 10259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 10359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 10459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return (Looper*)pthread_getspecific(gTLS); 10559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 10659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 10759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownsp<Looper> Looper::prepare(int opts) { 10859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown bool allowNonCallbacks = opts & ALOOPER_PREPARE_ALLOW_NON_CALLBACKS; 10959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown sp<Looper> looper = Looper::getForThread(); 11059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (looper == NULL) { 11159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown looper = new Looper(allowNonCallbacks); 11259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown Looper::setForThread(looper); 11359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 11459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (looper->getAllowNonCallbacks() != allowNonCallbacks) { 11559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGW("Looper already prepared for this thread with a different value for the " 11659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown "ALOOPER_PREPARE_ALLOW_NON_CALLBACKS option."); 11759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 11859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return looper; 11959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 12059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 12159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownbool Looper::getAllowNonCallbacks() const { 12259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return mAllowNonCallbacks; 12359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 12459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 12559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownint Looper::pollOnce(int timeoutMillis, int* outFd, int* outEvents, void** outData) { 12659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int result = 0; 12759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown for (;;) { 12859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown while (mResponseIndex < mResponses.size()) { 12959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown const Response& response = mResponses.itemAt(mResponseIndex++); 13059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (! response.request.callback) { 13159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_POLL_AND_WAKE 13259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ pollOnce - returning signalled identifier %d: " 13359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown "fd=%d, events=0x%x, data=%p", this, 13459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown response.request.ident, response.request.fd, 13559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown response.events, response.request.data); 13659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 13759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (outFd != NULL) *outFd = response.request.fd; 13859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (outEvents != NULL) *outEvents = response.events; 13959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (outData != NULL) *outData = response.request.data; 14059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return response.request.ident; 14159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 14259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 14359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 14459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (result != 0) { 14559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_POLL_AND_WAKE 14659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ pollOnce - returning result %d", this, result); 14759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 14859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (outFd != NULL) *outFd = 0; 14959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (outEvents != NULL) *outEvents = NULL; 15059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (outData != NULL) *outData = NULL; 15159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return result; 15259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 15359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 15459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown result = pollInner(timeoutMillis); 15559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 15659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 15759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 15859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownint Looper::pollInner(int timeoutMillis) { 15959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_POLL_AND_WAKE 16059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ pollOnce - waiting: timeoutMillis=%d", this, timeoutMillis); 16159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 16259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown struct epoll_event eventItems[EPOLL_MAX_EVENTS]; 16359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int eventCount = epoll_wait(mEpollFd, eventItems, EPOLL_MAX_EVENTS, timeoutMillis); 16459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (eventCount < 0) { 16559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (errno != EINTR) { 16659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGW("Poll failed with an unexpected error, errno=%d", errno); 16759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 16859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return ALOOPER_POLL_ERROR; 16959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 17059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 17159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (eventCount == 0) { 17259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_POLL_AND_WAKE 17359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ pollOnce - timeout", this); 17459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 17559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return ALOOPER_POLL_TIMEOUT; 17659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 17759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 17859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int result = ALOOPER_POLL_WAKE; 17959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mResponses.clear(); 18059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mResponseIndex = 0; 18159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 18259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_POLL_AND_WAKE 18359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ pollOnce - handling events from %d fds", this, eventCount); 18459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 18559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown { // acquire lock 18659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown AutoMutex _l(mLock); 18759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown for (int i = 0; i < eventCount; i++) { 18859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int fd = eventItems[i].data.fd; 18959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown uint32_t epollEvents = eventItems[i].events; 19059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (fd == mWakeReadPipeFd) { 19159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (epollEvents & EPOLLIN) { 19259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_POLL_AND_WAKE 19359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ pollOnce - awoken", this); 19459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 19559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown char buffer[16]; 19659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown ssize_t nRead; 19759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown do { 19859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown nRead = read(mWakeReadPipeFd, buffer, sizeof(buffer)); 19959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } while (nRead == sizeof(buffer)); 20059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } else { 20159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGW("Ignoring unexpected epoll events 0x%x on wake read pipe.", epollEvents); 20259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 20359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } else { 20459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown ssize_t requestIndex = mRequests.indexOfKey(fd); 20559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (requestIndex >= 0) { 20659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int events = 0; 20759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (epollEvents & EPOLLIN) events |= ALOOPER_EVENT_INPUT; 20859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (epollEvents & EPOLLOUT) events |= ALOOPER_EVENT_OUTPUT; 20959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (epollEvents & EPOLLERR) events |= ALOOPER_EVENT_ERROR; 21059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (epollEvents & EPOLLHUP) events |= ALOOPER_EVENT_HANGUP; 21159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 21259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown Response response; 21359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown response.events = events; 21459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown response.request = mRequests.valueAt(requestIndex); 21559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mResponses.push(response); 21659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } else { 21759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGW("Ignoring unexpected epoll events 0x%x on fd %d that is " 21859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown "no longer registered.", epollEvents, fd); 21959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 22059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 22159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 22259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 22359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 22459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown for (size_t i = 0; i < mResponses.size(); i++) { 22559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown const Response& response = mResponses.itemAt(i); 22659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (response.request.callback) { 22759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_POLL_AND_WAKE || DEBUG_CALLBACKS 22859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ pollOnce - invoking callback: fd=%d, events=0x%x, data=%p", this, 22959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown response.request.fd, response.events, response.request.data); 23059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 23159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int callbackResult = response.request.callback( 23259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown response.request.fd, response.events, response.request.data); 23359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (callbackResult == 0) { 23459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown removeFd(response.request.fd); 23559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 23659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 23759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown result = ALOOPER_POLL_CALLBACK; 23859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 23959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 24059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return result; 24159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 24259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 24359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownint Looper::pollAll(int timeoutMillis, int* outFd, int* outEvents, void** outData) { 24459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (timeoutMillis <= 0) { 24559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int result; 24659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown do { 24759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown result = pollOnce(timeoutMillis, outFd, outEvents, outData); 24859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } while (result == ALOOPER_POLL_CALLBACK); 24959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return result; 25059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } else { 25159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown nsecs_t endTime = systemTime(SYSTEM_TIME_MONOTONIC) 25259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown + milliseconds_to_nanoseconds(timeoutMillis); 25359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 25459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown for (;;) { 25559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int result = pollOnce(timeoutMillis, outFd, outEvents, outData); 25659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (result != ALOOPER_POLL_CALLBACK) { 25759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return result; 25859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 25959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 26059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown nsecs_t timeoutNanos = endTime - systemTime(SYSTEM_TIME_MONOTONIC); 26159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (timeoutNanos <= 0) { 26259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return ALOOPER_POLL_TIMEOUT; 26359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 26459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 26559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown timeoutMillis = int(nanoseconds_to_milliseconds(timeoutNanos + 999999LL)); 26659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 26759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 26859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 26959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 27059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownvoid Looper::wake() { 27159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_POLL_AND_WAKE 27259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ wake", this); 27359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 27459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 27559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown ssize_t nWrite = write(mWakeWritePipeFd, "W", 1); 27659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (nWrite != 1) { 27759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (errno != EAGAIN) { 27859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGW("Could not write wake signal, errno=%d", errno); 27959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 28059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 28159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 28259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 28359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownint Looper::addFd(int fd, int ident, int events, ALooper_callbackFunc callback, void* data) { 28459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_CALLBACKS 28559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ addFd - fd=%d, ident=%d, events=0x%x, callback=%p, data=%p", this, fd, ident, 28659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown events, callback, data); 28759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 28859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 28959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int epollEvents = 0; 29059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (events & ALOOPER_EVENT_INPUT) epollEvents |= EPOLLIN; 29159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (events & ALOOPER_EVENT_OUTPUT) epollEvents |= EPOLLOUT; 29259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (events & ALOOPER_EVENT_ERROR) epollEvents |= EPOLLERR; 29359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (events & ALOOPER_EVENT_HANGUP) epollEvents |= EPOLLHUP; 29459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 29559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (epollEvents == 0) { 29659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGE("Invalid attempt to set a callback with no selected poll events."); 29759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return -1; 29859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 29959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 30059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (! callback) { 30159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (! mAllowNonCallbacks) { 30259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGE("Invalid attempt to set NULL callback but not allowed for this looper."); 30359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return -1; 30459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 30559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 30659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (ident < 0) { 30759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGE("Invalid attempt to set NULL callback with ident <= 0."); 30859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return -1; 30959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 31059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 31159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 31259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown { // acquire lock 31359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown AutoMutex _l(mLock); 31459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 31559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown Request request; 31659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown request.fd = fd; 31759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown request.ident = ident; 31859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown request.callback = callback; 31959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown request.data = data; 32059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 32159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown struct epoll_event eventItem; 32259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown eventItem.events = epollEvents; 32359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown eventItem.data.fd = fd; 32459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 32559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown ssize_t requestIndex = mRequests.indexOfKey(fd); 32659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (requestIndex < 0) { 32759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int epollResult = epoll_ctl(mEpollFd, EPOLL_CTL_ADD, fd, & eventItem); 32859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (epollResult < 0) { 32959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGE("Error adding epoll events for fd %d, errno=%d", fd, errno); 33059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return -1; 33159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 33259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mRequests.add(fd, request); 33359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } else { 33459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int epollResult = epoll_ctl(mEpollFd, EPOLL_CTL_MOD, fd, & eventItem); 33559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (epollResult < 0) { 33659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGE("Error modifying epoll events for fd %d, errno=%d", fd, errno); 33759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return -1; 33859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 33959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mRequests.replaceValueAt(requestIndex, request); 34059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 34159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } // release lock 34259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return 1; 34359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 34459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 34559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brownint Looper::removeFd(int fd) { 34659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#if DEBUG_CALLBACKS 34759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGD("%p ~ removeFd - fd=%d", this, fd); 34859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown#endif 34959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 35059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown { // acquire lock 35159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown AutoMutex _l(mLock); 35259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown ssize_t requestIndex = mRequests.indexOfKey(fd); 35359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (requestIndex < 0) { 35459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return 0; 35559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 35659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 35759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown int epollResult = epoll_ctl(mEpollFd, EPOLL_CTL_DEL, fd, NULL); 35859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown if (epollResult < 0) { 35959abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown LOGE("Error removing epoll events for fd %d, errno=%d", fd, errno); 36059abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return -1; 36159abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } 36259abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 36359abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown mRequests.removeItemsAt(requestIndex); 36459abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown } // request lock 36559abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown return 1; 36659abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} 36759abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown 36859abe7e0909bf4b7bf7b9601e1e40a05f6d4fd8aJeff Brown} // namespace android 369