138 lines
4.3 KiB
C++
138 lines
4.3 KiB
C++
/*
|
|
* Copyright (C) 2009 The Android Open Source Project
|
|
*
|
|
* Licensed under the Apache License, Version 2.0 (the "License");
|
|
* you may not use this file except in compliance with the License.
|
|
* You may obtain a copy of the License at
|
|
*
|
|
* http://www.apache.org/licenses/LICENSE-2.0
|
|
*
|
|
* Unless required by applicable law or agreed to in writing, software
|
|
* distributed under the License is distributed on an "AS IS" BASIS,
|
|
* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
* See the License for the specific language governing permissions and
|
|
* limitations under the License.
|
|
*/
|
|
|
|
// TODO(b/129481165): remove the #pragma below and fix conversion issues
|
|
#pragma clang diagnostic push
|
|
#pragma clang diagnostic ignored "-Wconversion"
|
|
|
|
#include <binder/IPCThreadState.h>
|
|
|
|
#include <utils/Log.h>
|
|
#include <utils/Timers.h>
|
|
#include <utils/threads.h>
|
|
|
|
#include <gui/DisplayEventReceiver.h>
|
|
#include <gui/IDisplayEventConnection.h>
|
|
|
|
#include "EventThread.h"
|
|
#include "MessageQueue.h"
|
|
#include "SurfaceFlinger.h"
|
|
|
|
namespace android::impl {
|
|
|
|
void MessageQueue::Handler::dispatchRefresh() {
|
|
if ((android_atomic_or(eventMaskRefresh, &mEventMask) & eventMaskRefresh) == 0) {
|
|
mQueue.mLooper->sendMessage(this, Message(MessageQueue::REFRESH));
|
|
}
|
|
}
|
|
|
|
void MessageQueue::Handler::dispatchInvalidate(nsecs_t expectedVSyncTimestamp) {
|
|
if ((android_atomic_or(eventMaskInvalidate, &mEventMask) & eventMaskInvalidate) == 0) {
|
|
mExpectedVSyncTime = expectedVSyncTimestamp;
|
|
mQueue.mLooper->sendMessage(this, Message(MessageQueue::INVALIDATE));
|
|
}
|
|
}
|
|
|
|
void MessageQueue::Handler::handleMessage(const Message& message) {
|
|
switch (message.what) {
|
|
case INVALIDATE:
|
|
android_atomic_and(~eventMaskInvalidate, &mEventMask);
|
|
mQueue.mFlinger->onMessageReceived(message.what, mExpectedVSyncTime);
|
|
break;
|
|
case REFRESH:
|
|
android_atomic_and(~eventMaskRefresh, &mEventMask);
|
|
mQueue.mFlinger->onMessageReceived(message.what, mExpectedVSyncTime);
|
|
break;
|
|
}
|
|
}
|
|
|
|
// ---------------------------------------------------------------------------
|
|
|
|
void MessageQueue::init(const sp<SurfaceFlinger>& flinger) {
|
|
mFlinger = flinger;
|
|
mLooper = new Looper(true);
|
|
mHandler = new Handler(*this);
|
|
}
|
|
|
|
void MessageQueue::setEventConnection(const sp<EventThreadConnection>& connection) {
|
|
if (mEventTube.getFd() >= 0) {
|
|
mLooper->removeFd(mEventTube.getFd());
|
|
}
|
|
|
|
mEvents = connection;
|
|
mEvents->stealReceiveChannel(&mEventTube);
|
|
mLooper->addFd(mEventTube.getFd(), 0, Looper::EVENT_INPUT, MessageQueue::cb_eventReceiver,
|
|
this);
|
|
}
|
|
|
|
void MessageQueue::waitMessage() {
|
|
do {
|
|
IPCThreadState::self()->flushCommands();
|
|
int32_t ret = mLooper->pollOnce(-1);
|
|
switch (ret) {
|
|
case Looper::POLL_WAKE:
|
|
case Looper::POLL_CALLBACK:
|
|
continue;
|
|
case Looper::POLL_ERROR:
|
|
ALOGE("Looper::POLL_ERROR");
|
|
continue;
|
|
case Looper::POLL_TIMEOUT:
|
|
// timeout (should not happen)
|
|
continue;
|
|
default:
|
|
// should not happen
|
|
ALOGE("Looper::pollOnce() returned unknown status %d", ret);
|
|
continue;
|
|
}
|
|
} while (true);
|
|
}
|
|
|
|
void MessageQueue::postMessage(sp<MessageHandler>&& handler) {
|
|
mLooper->sendMessage(handler, Message());
|
|
}
|
|
|
|
void MessageQueue::invalidate() {
|
|
mEvents->requestNextVsync();
|
|
}
|
|
|
|
void MessageQueue::refresh() {
|
|
mHandler->dispatchRefresh();
|
|
}
|
|
|
|
int MessageQueue::cb_eventReceiver(int fd, int events, void* data) {
|
|
MessageQueue* queue = reinterpret_cast<MessageQueue*>(data);
|
|
return queue->eventReceiver(fd, events);
|
|
}
|
|
|
|
int MessageQueue::eventReceiver(int /*fd*/, int /*events*/) {
|
|
ssize_t n;
|
|
DisplayEventReceiver::Event buffer[8];
|
|
while ((n = DisplayEventReceiver::getEvents(&mEventTube, buffer, 8)) > 0) {
|
|
for (int i = 0; i < n; i++) {
|
|
if (buffer[i].header.type == DisplayEventReceiver::DISPLAY_EVENT_VSYNC) {
|
|
mHandler->dispatchInvalidate(buffer[i].vsync.expectedVSyncTimestamp);
|
|
break;
|
|
}
|
|
}
|
|
}
|
|
return 1;
|
|
}
|
|
|
|
} // namespace android::impl
|
|
|
|
// TODO(b/129481165): remove the #pragma below and fix conversion issues
|
|
#pragma clang diagnostic pop // ignored "-Wconversion"
|