1/* 2 * Copyright (C) 2009 The Android Open Source Project 3 * 4 * Licensed under the Apache License, Version 2.0 (the "License"); 5 * you may not use this file except in compliance with the License. 6 * You may obtain a copy of the License at 7 * 8 * http://www.apache.org/licenses/LICENSE-2.0 9 * 10 * Unless required by applicable law or agreed to in writing, software 11 * distributed under the License is distributed on an "AS IS" BASIS, 12 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13 * See the License for the specific language governing permissions and 14 * limitations under the License. 15 */ 16 17#include <stdint.h> 18#include <errno.h> 19#include <sys/types.h> 20 21#include <binder/IPCThreadState.h> 22 23#include <utils/threads.h> 24#include <utils/Timers.h> 25#include <utils/Log.h> 26 27#include <gui/IDisplayEventConnection.h> 28#include <gui/BitTube.h> 29 30#include "MessageQueue.h" 31#include "EventThread.h" 32#include "SurfaceFlinger.h" 33 34namespace android { 35 36// --------------------------------------------------------------------------- 37 38MessageBase::MessageBase() 39 : MessageHandler() { 40} 41 42MessageBase::~MessageBase() { 43} 44 45void MessageBase::handleMessage(const Message&) { 46 this->handler(); 47 barrier.open(); 48}; 49 50// --------------------------------------------------------------------------- 51 52void MessageQueue::Handler::dispatchRefresh() { 53 if ((android_atomic_or(eventMaskRefresh, &mEventMask) & eventMaskRefresh) == 0) { 54 mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH)); 55 } 56} 57 58void MessageQueue::Handler::dispatchInvalidate() { 59 if ((android_atomic_or(eventMaskInvalidate, &mEventMask) & eventMaskInvalidate) == 0) { 60 mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE)); 61 } 62} 63 64void MessageQueue::Handler::handleMessage(const Message& message) { 65 switch (message.what) { 66 case INVALIDATE: 67 android_atomic_and(~eventMaskInvalidate, &mEventMask); 68 mQueue.mFlinger->onMessageReceived(message.what); 69 break; 70 case REFRESH: 71 android_atomic_and(~eventMaskRefresh, &mEventMask); 72 mQueue.mFlinger->onMessageReceived(message.what); 73 break; 74 } 75} 76 77// --------------------------------------------------------------------------- 78 79MessageQueue::MessageQueue() 80{ 81} 82 83MessageQueue::~MessageQueue() { 84} 85 86void MessageQueue::init(const sp<SurfaceFlinger>& flinger) 87{ 88 mFlinger = flinger; 89 mLooper = new Looper(true); 90 mHandler = new Handler(*this); 91} 92 93void MessageQueue::setEventThread(const sp<EventThread>& eventThread) 94{ 95 mEventThread = eventThread; 96 mEvents = eventThread->createEventConnection(); 97 mEventTube = mEvents->getDataChannel(); 98 mLooper->addFd(mEventTube->getFd(), 0, Looper::EVENT_INPUT, 99 MessageQueue::cb_eventReceiver, this); 100} 101 102void MessageQueue::waitMessage() { 103 do { 104 IPCThreadState::self()->flushCommands(); 105 int32_t ret = mLooper->pollOnce(-1); 106 switch (ret) { 107 case Looper::POLL_WAKE: 108 case Looper::POLL_CALLBACK: 109 continue; 110 case Looper::POLL_ERROR: 111 ALOGE("Looper::POLL_ERROR"); 112 continue; 113 case Looper::POLL_TIMEOUT: 114 // timeout (should not happen) 115 continue; 116 default: 117 // should not happen 118 ALOGE("Looper::pollOnce() returned unknown status %d", ret); 119 continue; 120 } 121 } while (true); 122} 123 124status_t MessageQueue::postMessage( 125 const sp<MessageBase>& messageHandler, nsecs_t relTime) 126{ 127 const Message dummyMessage; 128 if (relTime > 0) { 129 mLooper->sendMessageDelayed(relTime, messageHandler, dummyMessage); 130 } else { 131 mLooper->sendMessage(messageHandler, dummyMessage); 132 } 133 return NO_ERROR; 134} 135 136 137void MessageQueue::invalidate() { 138 mEvents->requestNextVsync(); 139} 140 141void MessageQueue::refresh() { 142 mHandler->dispatchRefresh(); 143} 144 145int MessageQueue::cb_eventReceiver(int fd, int events, void* data) { 146 MessageQueue* queue = reinterpret_cast<MessageQueue *>(data); 147 return queue->eventReceiver(fd, events); 148} 149 150int MessageQueue::eventReceiver(int /*fd*/, int /*events*/) { 151 ssize_t n; 152 DisplayEventReceiver::Event buffer[8]; 153 while ((n = DisplayEventReceiver::getEvents(mEventTube, buffer, 8)) > 0) { 154 for (int i=0 ; i<n ; i++) { 155 if (buffer[i].header.type == DisplayEventReceiver::DISPLAY_EVENT_VSYNC) { 156 mHandler->dispatchInvalidate(); 157 break; 158 } 159 } 160 } 161 return 1; 162} 163 164// --------------------------------------------------------------------------- 165 166}; // namespace android 167