Merge "Check for spurious wake ups"

am: 3a3cd0a27f

Change-Id: Ia445070278f5a80c85b48e06ddf614d462db45af
This commit is contained in:
Tom Cherry
2017-03-06 19:57:18 +00:00
committed by android-build-merger
4 changed files with 10 additions and 3 deletions

View File

@@ -685,7 +685,9 @@ void* RenderProxy::postAndWait(MethodInvokeRenderTask* task) {
SignalingRenderTask syncTask(task, &mSyncMutex, &mSyncCondition);
AutoMutex _lock(mSyncMutex);
mRenderThread.queue(&syncTask);
mSyncCondition.wait(mSyncMutex);
while (!syncTask.hasRun()) {
mSyncCondition.wait(mSyncMutex);
}
return retval;
}

View File

@@ -26,6 +26,7 @@ namespace renderthread {
void SignalingRenderTask::run() {
mTask->run();
mLock->lock();
mHasRun = true;
mSignal->signal();
mLock->unlock();
}

View File

@@ -60,13 +60,15 @@ class SignalingRenderTask : public RenderTask {
public:
// Takes ownership of task, caller owns lock and signal
SignalingRenderTask(RenderTask* task, Mutex* lock, Condition* signal)
: mTask(task), mLock(lock), mSignal(signal) {}
: mTask(task), mLock(lock), mSignal(signal), mHasRun(false) {}
virtual void run() override;
bool hasRun() const { return mHasRun; }
private:
RenderTask* mTask;
Mutex* mLock;
Condition* mSignal;
bool mHasRun;
};
typedef void* (*RunnableMethod)(void* data);

View File

@@ -345,7 +345,9 @@ void RenderThread::queueAndWait(RenderTask* task) {
AutoMutex _lock(mutex);
queue(&syncTask);
condition.wait(mutex);
while (!syncTask.hasRun()) {
condition.wait(mutex);
}
}
void RenderThread::queueAtFront(RenderTask* task) {