1f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian/* 2f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * Copyright (C) 2009 The Android Open Source Project 3f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * 4f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * Licensed under the Apache License, Version 2.0 (the "License"); 5f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * you may not use this file except in compliance with the License. 6f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * You may obtain a copy of the License at 7f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * 8f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * http://www.apache.org/licenses/LICENSE-2.0 9f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * 10f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * Unless required by applicable law or agreed to in writing, software 11f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * distributed under the License is distributed on an "AS IS" BASIS, 12f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. 13f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * See the License for the specific language governing permissions and 14f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian * limitations under the License. 15f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian */ 16f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 17f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian#ifndef ANDROID_MESSAGE_QUEUE_H 18f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian#define ANDROID_MESSAGE_QUEUE_H 19f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 20f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian#include <stdint.h> 21f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian#include <errno.h> 22f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian#include <sys/types.h> 23f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 24f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian#include <utils/threads.h> 25f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian#include <utils/Timers.h> 26f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopian#include <utils/Looper.h> 27f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 286b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza#include <private/gui/BitTube.h> 298aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopian#include <gui/DisplayEventReceiver.h> 308aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopian 31bb641244d7d73312dc65b8e338df18b22e335107Mathias Agopian#include "Barrier.h" 32f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 33f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopiannamespace android { 34f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 358aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopianclass IDisplayEventConnection; 368aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopianclass EventThread; 3799ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopianclass SurfaceFlinger; 388aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopian 39f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian// --------------------------------------------------------------------------- 40f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 41f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopianclass MessageBase : public MessageHandler 42f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian{ 43f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopianpublic: 44f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopian MessageBase(); 45f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 46f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian // return true if message has a handler 47f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopian virtual bool handler() = 0; 48bb641244d7d73312dc65b8e338df18b22e335107Mathias Agopian 49bb641244d7d73312dc65b8e338df18b22e335107Mathias Agopian // waits for the handler to be processed 50bb641244d7d73312dc65b8e338df18b22e335107Mathias Agopian void wait() const { barrier.wait(); } 51bb641244d7d73312dc65b8e338df18b22e335107Mathias Agopian 52f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopianprotected: 53f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopian virtual ~MessageBase(); 54f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 55f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopianprivate: 56f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopian virtual void handleMessage(const Message& message); 57f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopian 58bb641244d7d73312dc65b8e338df18b22e335107Mathias Agopian mutable Barrier barrier; 59f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian}; 60f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 61f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian// --------------------------------------------------------------------------- 62f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 63f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopianclass MessageQueue { 6499ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian class Handler : public MessageHandler { 6599ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian enum { 669eb1f0558b5fc78920602afe7bcfa3115bb1f6beMathias Agopian eventMaskInvalidate = 0x1, 679eb1f0558b5fc78920602afe7bcfa3115bb1f6beMathias Agopian eventMaskRefresh = 0x2, 689eb1f0558b5fc78920602afe7bcfa3115bb1f6beMathias Agopian eventMaskTransaction = 0x4 6999ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian }; 7099ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian MessageQueue& mQueue; 7199ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian int32_t mEventMask; 7299ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian public: 73342b760763300593cd20b01dac8cef61e7b25b86Chih-Hung Hsieh explicit Handler(MessageQueue& queue) : mQueue(queue), mEventMask(0) { } 7499ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian virtual void handleMessage(const Message& message); 754fec873a98f7b4380720cd1ad006f74c8cdc73daMathias Agopian void dispatchRefresh(); 764fec873a98f7b4380720cd1ad006f74c8cdc73daMathias Agopian void dispatchInvalidate(); 7799ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian }; 7899ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian 7999ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian friend class Handler; 8099ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian 8199ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian sp<SurfaceFlinger> mFlinger; 82f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopian sp<Looper> mLooper; 838aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopian sp<EventThread> mEventThread; 848aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopian sp<IDisplayEventConnection> mEvents; 856b698e4fe4ff50dcef818452283637f9870ae770Dan Stoza gui::BitTube mEventTube; 8699ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian sp<Handler> mHandler; 8799ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian 888aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopian 898aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopian static int cb_eventReceiver(int fd, int events, void* data); 908aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopian int eventReceiver(int fd, int events); 91f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 92f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopianpublic: 9399ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian enum { 949eb1f0558b5fc78920602afe7bcfa3115bb1f6beMathias Agopian INVALIDATE = 0, 959eb1f0558b5fc78920602afe7bcfa3115bb1f6beMathias Agopian REFRESH = 1, 9699ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian }; 9799ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian 98f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian MessageQueue(); 99f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian ~MessageQueue(); 10099ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian void init(const sp<SurfaceFlinger>& flinger); 1018aedd4737d6ce8548d2fd5def65b1e1737283821Mathias Agopian void setEventThread(const sp<EventThread>& events); 102f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 103f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopian void waitMessage(); 104f61c57fe2e955e1c195bb0ca2dd7bcdaa922d5a9Mathias Agopian status_t postMessage(const sp<MessageBase>& message, nsecs_t reltime=0); 1059eb1f0558b5fc78920602afe7bcfa3115bb1f6beMathias Agopian 1069eb1f0558b5fc78920602afe7bcfa3115bb1f6beMathias Agopian // sends INVALIDATE message at next VSYNC 10799ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian void invalidate(); 1089eb1f0558b5fc78920602afe7bcfa3115bb1f6beMathias Agopian // sends REFRESH message at next VSYNC 10999ce5cdeb383216dee95af4d90e47406b0948ea1Mathias Agopian void refresh(); 110f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian}; 111f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 112f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian// --------------------------------------------------------------------------- 113f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 114f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian}; // namespace android 115f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian 116f1d8e87b09abf963cd5b6a026194c1940fadb7b4Mathias Agopian#endif /* ANDROID_MESSAGE_QUEUE_H */ 117