Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 1 | /* Copyright 2016 The Android Open Source Project |
| 2 | * |
| 3 | * Licensed under the Apache License, Version 2.0 (the "License"); |
| 4 | * you may not use this file except in compliance with the License. |
| 5 | * You may obtain a copy of the License at |
| 6 | * |
| 7 | * http://www.apache.org/licenses/LICENSE-2.0 |
| 8 | * |
| 9 | * Unless required by applicable law or agreed to in writing, software |
| 10 | * distributed under the License is distributed on an "AS IS" BASIS, |
| 11 | * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| 12 | * See the License for the specific language governing permissions and |
| 13 | * limitations under the License. |
| 14 | */ |
| 15 | |
| 16 | //#define LOG_NDEBUG 0 |
| 17 | #define LOG_TAG "SurfaceReplayer" |
| 18 | |
| 19 | #include "Replayer.h" |
| 20 | |
| 21 | #include <android/native_window.h> |
| 22 | |
Colin Cross | 6354938 | 2016-10-26 12:52:53 -0700 | [diff] [blame] | 23 | #include <android-base/file.h> |
| 24 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 25 | #include <gui/BufferQueue.h> |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 26 | #include <gui/ISurfaceComposer.h> |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 27 | #include <gui/LayerState.h> |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 28 | #include <gui/Surface.h> |
| 29 | #include <private/gui/ComposerService.h> |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 30 | |
| 31 | #include <ui/DisplayInfo.h> |
| 32 | #include <utils/Log.h> |
| 33 | #include <utils/String8.h> |
| 34 | #include <utils/Trace.h> |
| 35 | |
| 36 | #include <chrono> |
| 37 | #include <cmath> |
| 38 | #include <condition_variable> |
| 39 | #include <cstdlib> |
| 40 | #include <fstream> |
| 41 | #include <functional> |
| 42 | #include <iostream> |
| 43 | #include <mutex> |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 44 | #include <sstream> |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 45 | #include <string> |
| 46 | #include <thread> |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 47 | #include <vector> |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 48 | |
| 49 | using namespace android; |
| 50 | |
| 51 | std::atomic_bool Replayer::sReplayingManually(false); |
| 52 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 53 | Replayer::Replayer(const std::string& filename, bool replayManually, int numThreads, bool wait, |
| 54 | nsecs_t stopHere) |
| 55 | : mTrace(), |
| 56 | mLoaded(false), |
| 57 | mIncrementIndex(0), |
| 58 | mCurrentTime(0), |
| 59 | mNumThreads(numThreads), |
| 60 | mWaitForTimeStamps(wait), |
| 61 | mStopTimeStamp(stopHere) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 62 | srand(RAND_COLOR_SEED); |
| 63 | |
Colin Cross | 6354938 | 2016-10-26 12:52:53 -0700 | [diff] [blame] | 64 | std::string input; |
| 65 | if (!android::base::ReadFileToString(filename, &input, true)) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 66 | std::cerr << "Trace did not load. Does " << filename << " exist?" << std::endl; |
| 67 | abort(); |
| 68 | } |
| 69 | |
Colin Cross | 6354938 | 2016-10-26 12:52:53 -0700 | [diff] [blame] | 70 | mLoaded = mTrace.ParseFromString(input); |
| 71 | if (!mLoaded) { |
| 72 | std::cerr << "Trace did not load." << std::endl; |
| 73 | abort(); |
| 74 | } |
| 75 | |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 76 | mCurrentTime = mTrace.increment(0).time_stamp(); |
| 77 | |
| 78 | sReplayingManually.store(replayManually); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 79 | |
| 80 | if (stopHere < 0) { |
| 81 | mHasStopped = true; |
| 82 | } |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 83 | } |
| 84 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 85 | Replayer::Replayer(const Trace& t, bool replayManually, int numThreads, bool wait, nsecs_t stopHere) |
| 86 | : mTrace(t), |
| 87 | mLoaded(true), |
| 88 | mIncrementIndex(0), |
| 89 | mCurrentTime(0), |
| 90 | mNumThreads(numThreads), |
| 91 | mWaitForTimeStamps(wait), |
| 92 | mStopTimeStamp(stopHere) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 93 | srand(RAND_COLOR_SEED); |
| 94 | mCurrentTime = mTrace.increment(0).time_stamp(); |
| 95 | |
| 96 | sReplayingManually.store(replayManually); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 97 | |
| 98 | if (stopHere < 0) { |
| 99 | mHasStopped = true; |
| 100 | } |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 101 | } |
| 102 | |
| 103 | status_t Replayer::replay() { |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 104 | signal(SIGINT, Replayer::stopAutoReplayHandler); //for manual control |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 105 | |
| 106 | ALOGV("There are %d increments.", mTrace.increment_size()); |
| 107 | |
| 108 | status_t status = loadSurfaceComposerClient(); |
| 109 | |
| 110 | if (status != NO_ERROR) { |
| 111 | ALOGE("Couldn't create SurfaceComposerClient (%d)", status); |
| 112 | return status; |
| 113 | } |
| 114 | |
| 115 | SurfaceComposerClient::enableVSyncInjections(true); |
| 116 | |
| 117 | initReplay(); |
| 118 | |
| 119 | ALOGV("Starting actual Replay!"); |
| 120 | while (!mPendingIncrements.empty()) { |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 121 | mCurrentIncrement = mTrace.increment(mIncrementIndex); |
| 122 | |
| 123 | if (mHasStopped == false && mCurrentIncrement.time_stamp() >= mStopTimeStamp) { |
| 124 | mHasStopped = true; |
| 125 | sReplayingManually.store(true); |
| 126 | } |
| 127 | |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 128 | waitForConsoleCommmand(); |
| 129 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 130 | if (mWaitForTimeStamps) { |
| 131 | waitUntilTimestamp(mCurrentIncrement.time_stamp()); |
| 132 | } |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 133 | |
| 134 | auto event = mPendingIncrements.front(); |
| 135 | mPendingIncrements.pop(); |
| 136 | |
| 137 | event->complete(); |
| 138 | |
| 139 | if (event->getIncrementType() == Increment::kVsyncEvent) { |
| 140 | mWaitingForNextVSync = false; |
| 141 | } |
| 142 | |
| 143 | if (mIncrementIndex + mNumThreads < mTrace.increment_size()) { |
| 144 | status = dispatchEvent(mIncrementIndex + mNumThreads); |
| 145 | |
| 146 | if (status != NO_ERROR) { |
| 147 | SurfaceComposerClient::enableVSyncInjections(false); |
| 148 | return status; |
| 149 | } |
| 150 | } |
| 151 | |
| 152 | mIncrementIndex++; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 153 | mCurrentTime = mCurrentIncrement.time_stamp(); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 154 | } |
| 155 | |
| 156 | SurfaceComposerClient::enableVSyncInjections(false); |
| 157 | |
| 158 | return status; |
| 159 | } |
| 160 | |
| 161 | status_t Replayer::initReplay() { |
| 162 | for (int i = 0; i < mNumThreads && i < mTrace.increment_size(); i++) { |
| 163 | status_t status = dispatchEvent(i); |
| 164 | |
| 165 | if (status != NO_ERROR) { |
| 166 | ALOGE("Unable to dispatch event (%d)", status); |
| 167 | return status; |
| 168 | } |
| 169 | } |
| 170 | |
| 171 | return NO_ERROR; |
| 172 | } |
| 173 | |
| 174 | void Replayer::stopAutoReplayHandler(int /*signal*/) { |
| 175 | if (sReplayingManually) { |
| 176 | SurfaceComposerClient::enableVSyncInjections(false); |
| 177 | exit(0); |
| 178 | } |
| 179 | |
| 180 | sReplayingManually.store(true); |
| 181 | } |
| 182 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 183 | std::vector<std::string> split(const std::string& s, const char delim) { |
| 184 | std::vector<std::string> elems; |
| 185 | std::stringstream ss(s); |
| 186 | std::string item; |
| 187 | while (getline(ss, item, delim)) { |
| 188 | elems.push_back(item); |
| 189 | } |
| 190 | return elems; |
| 191 | } |
| 192 | |
| 193 | bool isNumber(const std::string& s) { |
| 194 | return !s.empty() && |
| 195 | std::find_if(s.begin(), s.end(), [](char c) { return !std::isdigit(c); }) == s.end(); |
| 196 | } |
| 197 | |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 198 | void Replayer::waitForConsoleCommmand() { |
| 199 | if (!sReplayingManually || mWaitingForNextVSync) { |
| 200 | return; |
| 201 | } |
| 202 | |
| 203 | while (true) { |
| 204 | std::string input = ""; |
| 205 | std::cout << "> "; |
| 206 | getline(std::cin, input); |
| 207 | |
| 208 | if (input.empty()) { |
| 209 | input = mLastInput; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 210 | } else { |
| 211 | mLastInput = input; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 212 | } |
| 213 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 214 | if (mLastInput.empty()) { |
| 215 | continue; |
| 216 | } |
| 217 | |
| 218 | std::vector<std::string> inputs = split(input, ' '); |
| 219 | |
| 220 | if (inputs[0] == "n") { // next vsync |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 221 | mWaitingForNextVSync = true; |
| 222 | break; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 223 | |
| 224 | } else if (inputs[0] == "ni") { // next increment |
| 225 | break; |
| 226 | |
| 227 | } else if (inputs[0] == "c") { // continue |
| 228 | if (inputs.size() > 1 && isNumber(inputs[1])) { |
| 229 | long milliseconds = stoi(inputs[1]); |
| 230 | std::thread([&] { |
| 231 | std::cout << "Started!" << std::endl; |
| 232 | std::this_thread::sleep_for(std::chrono::milliseconds(milliseconds)); |
| 233 | sReplayingManually.store(true); |
| 234 | std::cout << "Should have stopped!" << std::endl; |
| 235 | }).detach(); |
| 236 | } |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 237 | sReplayingManually.store(false); |
| 238 | mWaitingForNextVSync = false; |
| 239 | break; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 240 | |
| 241 | } else if (inputs[0] == "s") { // stop at this timestamp |
| 242 | if (inputs.size() < 1) { |
| 243 | std::cout << "No time stamp given" << std::endl; |
| 244 | continue; |
| 245 | } |
| 246 | sReplayingManually.store(false); |
| 247 | mStopTimeStamp = stol(inputs[1]); |
| 248 | mHasStopped = false; |
| 249 | break; |
| 250 | } else if (inputs[0] == "l") { // list |
| 251 | std::cout << "Time stamp: " << mCurrentIncrement.time_stamp() << "\n"; |
| 252 | continue; |
| 253 | } else if (inputs[0] == "q") { // quit |
| 254 | SurfaceComposerClient::enableVSyncInjections(false); |
| 255 | exit(0); |
| 256 | |
| 257 | } else if (inputs[0] == "h") { // help |
| 258 | // add help menu |
| 259 | std::cout << "Manual Replay options:\n"; |
| 260 | std::cout << " n - Go to next VSync\n"; |
| 261 | std::cout << " ni - Go to next increment\n"; |
| 262 | std::cout << " c - Continue\n"; |
| 263 | std::cout << " c [milliseconds] - Continue until specified number of milliseconds\n"; |
| 264 | std::cout << " s [timestamp] - Continue and stop at specified timestamp\n"; |
| 265 | std::cout << " l - List out timestamp of current increment\n"; |
| 266 | std::cout << " h - Display help menu\n"; |
| 267 | std::cout << std::endl; |
| 268 | continue; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 269 | } |
| 270 | |
| 271 | std::cout << "Invalid Command" << std::endl; |
| 272 | } |
| 273 | } |
| 274 | |
| 275 | status_t Replayer::dispatchEvent(int index) { |
| 276 | auto increment = mTrace.increment(index); |
| 277 | std::shared_ptr<Event> event = std::make_shared<Event>(increment.increment_case()); |
| 278 | mPendingIncrements.push(event); |
| 279 | |
| 280 | status_t status = NO_ERROR; |
| 281 | switch (increment.increment_case()) { |
| 282 | case increment.kTransaction: { |
| 283 | std::thread(&Replayer::doTransaction, this, increment.transaction(), event).detach(); |
| 284 | } break; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 285 | case increment.kSurfaceCreation: { |
| 286 | std::thread(&Replayer::createSurfaceControl, this, increment.surface_creation(), event) |
| 287 | .detach(); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 288 | } break; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 289 | case increment.kSurfaceDeletion: { |
| 290 | std::thread(&Replayer::deleteSurfaceControl, this, increment.surface_deletion(), event) |
| 291 | .detach(); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 292 | } break; |
| 293 | case increment.kBufferUpdate: { |
| 294 | std::lock_guard<std::mutex> lock1(mLayerLock); |
| 295 | std::lock_guard<std::mutex> lock2(mBufferQueueSchedulerLock); |
| 296 | |
| 297 | Dimensions dimensions(increment.buffer_update().w(), increment.buffer_update().h()); |
| 298 | BufferEvent bufferEvent(event, dimensions); |
| 299 | |
| 300 | auto layerId = increment.buffer_update().id(); |
| 301 | if (mBufferQueueSchedulers.count(layerId) == 0) { |
| 302 | mBufferQueueSchedulers[layerId] = std::make_shared<BufferQueueScheduler>( |
| 303 | mLayers[layerId], mColors[layerId], layerId); |
| 304 | mBufferQueueSchedulers[layerId]->addEvent(bufferEvent); |
| 305 | |
| 306 | std::thread(&BufferQueueScheduler::startScheduling, |
| 307 | mBufferQueueSchedulers[increment.buffer_update().id()].get()) |
| 308 | .detach(); |
| 309 | } else { |
| 310 | auto bqs = mBufferQueueSchedulers[increment.buffer_update().id()]; |
| 311 | bqs->addEvent(bufferEvent); |
| 312 | } |
| 313 | } break; |
| 314 | case increment.kVsyncEvent: { |
| 315 | std::thread(&Replayer::injectVSyncEvent, this, increment.vsync_event(), event).detach(); |
| 316 | } break; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 317 | case increment.kDisplayCreation: { |
| 318 | std::thread(&Replayer::createDisplay, this, increment.display_creation(), event) |
| 319 | .detach(); |
| 320 | } break; |
| 321 | case increment.kDisplayDeletion: { |
| 322 | std::thread(&Replayer::deleteDisplay, this, increment.display_deletion(), event) |
| 323 | .detach(); |
| 324 | } break; |
| 325 | case increment.kPowerModeUpdate: { |
| 326 | std::thread(&Replayer::updatePowerMode, this, increment.power_mode_update(), event) |
| 327 | .detach(); |
| 328 | } break; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 329 | default: |
| 330 | ALOGE("Unknown Increment Type: %d", increment.increment_case()); |
| 331 | status = BAD_VALUE; |
| 332 | break; |
| 333 | } |
| 334 | |
| 335 | return status; |
| 336 | } |
| 337 | |
| 338 | status_t Replayer::doTransaction(const Transaction& t, const std::shared_ptr<Event>& event) { |
| 339 | ALOGV("Started Transaction"); |
| 340 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 341 | SurfaceComposerClient::Transaction liveTransaction; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 342 | |
| 343 | status_t status = NO_ERROR; |
| 344 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 345 | status = doSurfaceTransaction(liveTransaction, t.surface_change()); |
| 346 | doDisplayTransaction(liveTransaction, t.display_change()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 347 | |
| 348 | if (t.animation()) { |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 349 | liveTransaction.setAnimationTransaction(); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 350 | } |
| 351 | |
| 352 | event->readyToExecute(); |
| 353 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 354 | liveTransaction.apply(t.synchronous()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 355 | |
| 356 | ALOGV("Ended Transaction"); |
| 357 | |
| 358 | return status; |
| 359 | } |
| 360 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 361 | status_t Replayer::doSurfaceTransaction( |
| 362 | SurfaceComposerClient::Transaction& transaction, |
| 363 | const SurfaceChanges& surfaceChanges) { |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 364 | status_t status = NO_ERROR; |
| 365 | |
| 366 | for (const SurfaceChange& change : surfaceChanges) { |
| 367 | std::unique_lock<std::mutex> lock(mLayerLock); |
| 368 | if (mLayers[change.id()] == nullptr) { |
| 369 | mLayerCond.wait(lock, [&] { return (mLayers[change.id()] != nullptr); }); |
| 370 | } |
| 371 | |
| 372 | switch (change.SurfaceChange_case()) { |
| 373 | case SurfaceChange::SurfaceChangeCase::kPosition: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 374 | setPosition(transaction, change.id(), change.position()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 375 | break; |
| 376 | case SurfaceChange::SurfaceChangeCase::kSize: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 377 | setSize(transaction, change.id(), change.size()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 378 | break; |
| 379 | case SurfaceChange::SurfaceChangeCase::kAlpha: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 380 | setAlpha(transaction, change.id(), change.alpha()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 381 | break; |
| 382 | case SurfaceChange::SurfaceChangeCase::kLayer: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 383 | setLayer(transaction, change.id(), change.layer()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 384 | break; |
| 385 | case SurfaceChange::SurfaceChangeCase::kCrop: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 386 | setCrop(transaction, change.id(), change.crop()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 387 | break; |
| 388 | case SurfaceChange::SurfaceChangeCase::kMatrix: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 389 | setMatrix(transaction, change.id(), change.matrix()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 390 | break; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 391 | case SurfaceChange::SurfaceChangeCase::kOverrideScalingMode: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 392 | setOverrideScalingMode(transaction, change.id(), |
| 393 | change.override_scaling_mode()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 394 | break; |
| 395 | case SurfaceChange::SurfaceChangeCase::kTransparentRegionHint: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 396 | setTransparentRegionHint(transaction, change.id(), |
| 397 | change.transparent_region_hint()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 398 | break; |
| 399 | case SurfaceChange::SurfaceChangeCase::kLayerStack: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 400 | setLayerStack(transaction, change.id(), change.layer_stack()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 401 | break; |
| 402 | case SurfaceChange::SurfaceChangeCase::kHiddenFlag: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 403 | setHiddenFlag(transaction, change.id(), change.hidden_flag()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 404 | break; |
| 405 | case SurfaceChange::SurfaceChangeCase::kOpaqueFlag: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 406 | setOpaqueFlag(transaction, change.id(), change.opaque_flag()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 407 | break; |
| 408 | case SurfaceChange::SurfaceChangeCase::kSecureFlag: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 409 | setSecureFlag(transaction, change.id(), change.secure_flag()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 410 | break; |
| 411 | case SurfaceChange::SurfaceChangeCase::kDeferredTransaction: |
| 412 | waitUntilDeferredTransactionLayerExists(change.deferred_transaction(), lock); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 413 | setDeferredTransaction(transaction, change.id(), |
| 414 | change.deferred_transaction()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 415 | break; |
| 416 | default: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 417 | status = 1; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 418 | break; |
| 419 | } |
| 420 | |
| 421 | if (status != NO_ERROR) { |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 422 | ALOGE("Unknown Transaction Code"); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 423 | return status; |
| 424 | } |
| 425 | } |
| 426 | return status; |
| 427 | } |
| 428 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 429 | void Replayer::doDisplayTransaction(SurfaceComposerClient::Transaction& t, |
| 430 | const DisplayChanges& displayChanges) { |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 431 | for (const DisplayChange& change : displayChanges) { |
| 432 | ALOGV("Doing display transaction"); |
| 433 | std::unique_lock<std::mutex> lock(mDisplayLock); |
| 434 | if (mDisplays[change.id()] == nullptr) { |
| 435 | mDisplayCond.wait(lock, [&] { return (mDisplays[change.id()] != nullptr); }); |
| 436 | } |
| 437 | |
| 438 | switch (change.DisplayChange_case()) { |
| 439 | case DisplayChange::DisplayChangeCase::kSurface: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 440 | setDisplaySurface(t, change.id(), change.surface()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 441 | break; |
| 442 | case DisplayChange::DisplayChangeCase::kLayerStack: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 443 | setDisplayLayerStack(t, change.id(), change.layer_stack()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 444 | break; |
| 445 | case DisplayChange::DisplayChangeCase::kSize: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 446 | setDisplaySize(t, change.id(), change.size()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 447 | break; |
| 448 | case DisplayChange::DisplayChangeCase::kProjection: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 449 | setDisplayProjection(t, change.id(), change.projection()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 450 | break; |
| 451 | default: |
| 452 | break; |
| 453 | } |
| 454 | } |
| 455 | } |
| 456 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 457 | void Replayer::setPosition(SurfaceComposerClient::Transaction& t, |
| 458 | layer_id id, const PositionChange& pc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 459 | ALOGV("Layer %d: Setting Position -- x=%f, y=%f", id, pc.x(), pc.y()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 460 | t.setPosition(mLayers[id], pc.x(), pc.y()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 461 | } |
| 462 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 463 | void Replayer::setSize(SurfaceComposerClient::Transaction& t, |
| 464 | layer_id id, const SizeChange& sc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 465 | ALOGV("Layer %d: Setting Size -- w=%u, h=%u", id, sc.w(), sc.h()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 466 | t.setSize(mLayers[id], sc.w(), sc.h()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 467 | } |
| 468 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 469 | void Replayer::setLayer(SurfaceComposerClient::Transaction& t, |
| 470 | layer_id id, const LayerChange& lc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 471 | ALOGV("Layer %d: Setting Layer -- layer=%d", id, lc.layer()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 472 | t.setLayer(mLayers[id], lc.layer()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 473 | } |
| 474 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 475 | void Replayer::setAlpha(SurfaceComposerClient::Transaction& t, |
| 476 | layer_id id, const AlphaChange& ac) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 477 | ALOGV("Layer %d: Setting Alpha -- alpha=%f", id, ac.alpha()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 478 | t.setAlpha(mLayers[id], ac.alpha()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 479 | } |
| 480 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 481 | void Replayer::setCrop(SurfaceComposerClient::Transaction& t, |
| 482 | layer_id id, const CropChange& cc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 483 | ALOGV("Layer %d: Setting Crop -- left=%d, top=%d, right=%d, bottom=%d", id, |
| 484 | cc.rectangle().left(), cc.rectangle().top(), cc.rectangle().right(), |
| 485 | cc.rectangle().bottom()); |
| 486 | |
| 487 | Rect r = Rect(cc.rectangle().left(), cc.rectangle().top(), cc.rectangle().right(), |
| 488 | cc.rectangle().bottom()); |
Marissa Wall | f58c14b | 2018-07-24 10:50:43 -0700 | [diff] [blame] | 489 | t.setCrop_legacy(mLayers[id], r); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 490 | } |
| 491 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 492 | void Replayer::setMatrix(SurfaceComposerClient::Transaction& t, |
| 493 | layer_id id, const MatrixChange& mc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 494 | ALOGV("Layer %d: Setting Matrix -- dsdx=%f, dtdx=%f, dsdy=%f, dtdy=%f", id, mc.dsdx(), |
| 495 | mc.dtdx(), mc.dsdy(), mc.dtdy()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 496 | t.setMatrix(mLayers[id], mc.dsdx(), mc.dtdx(), mc.dsdy(), mc.dtdy()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 497 | } |
| 498 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 499 | void Replayer::setOverrideScalingMode(SurfaceComposerClient::Transaction& t, |
| 500 | layer_id id, const OverrideScalingModeChange& osmc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 501 | ALOGV("Layer %d: Setting Override Scaling Mode -- mode=%d", id, osmc.override_scaling_mode()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 502 | t.setOverrideScalingMode(mLayers[id], osmc.override_scaling_mode()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 503 | } |
| 504 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 505 | void Replayer::setTransparentRegionHint(SurfaceComposerClient::Transaction& t, |
| 506 | layer_id id, const TransparentRegionHintChange& trhc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 507 | ALOGV("Setting Transparent Region Hint"); |
| 508 | Region re = Region(); |
| 509 | |
Chih-Hung Hsieh | cb057c2 | 2017-08-03 15:48:25 -0700 | [diff] [blame] | 510 | for (const auto& r : trhc.region()) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 511 | Rect rect = Rect(r.left(), r.top(), r.right(), r.bottom()); |
| 512 | re.merge(rect); |
| 513 | } |
| 514 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 515 | t.setTransparentRegionHint(mLayers[id], re); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 516 | } |
| 517 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 518 | void Replayer::setLayerStack(SurfaceComposerClient::Transaction& t, |
| 519 | layer_id id, const LayerStackChange& lsc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 520 | ALOGV("Layer %d: Setting LayerStack -- layer_stack=%d", id, lsc.layer_stack()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 521 | t.setLayerStack(mLayers[id], lsc.layer_stack()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 522 | } |
| 523 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 524 | void Replayer::setHiddenFlag(SurfaceComposerClient::Transaction& t, |
| 525 | layer_id id, const HiddenFlagChange& hfc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 526 | ALOGV("Layer %d: Setting Hidden Flag -- hidden_flag=%d", id, hfc.hidden_flag()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 527 | layer_id flag = hfc.hidden_flag() ? layer_state_t::eLayerHidden : 0; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 528 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 529 | t.setFlags(mLayers[id], flag, layer_state_t::eLayerHidden); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 530 | } |
| 531 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 532 | void Replayer::setOpaqueFlag(SurfaceComposerClient::Transaction& t, |
| 533 | layer_id id, const OpaqueFlagChange& ofc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 534 | ALOGV("Layer %d: Setting Opaque Flag -- opaque_flag=%d", id, ofc.opaque_flag()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 535 | layer_id flag = ofc.opaque_flag() ? layer_state_t::eLayerOpaque : 0; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 536 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 537 | t.setFlags(mLayers[id], flag, layer_state_t::eLayerOpaque); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 538 | } |
| 539 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 540 | void Replayer::setSecureFlag(SurfaceComposerClient::Transaction& t, |
| 541 | layer_id id, const SecureFlagChange& sfc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 542 | ALOGV("Layer %d: Setting Secure Flag -- secure_flag=%d", id, sfc.secure_flag()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 543 | layer_id flag = sfc.secure_flag() ? layer_state_t::eLayerSecure : 0; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 544 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 545 | t.setFlags(mLayers[id], flag, layer_state_t::eLayerSecure); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 546 | } |
| 547 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 548 | void Replayer::setDeferredTransaction(SurfaceComposerClient::Transaction& t, |
| 549 | layer_id id, const DeferredTransactionChange& dtc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 550 | ALOGV("Layer %d: Setting Deferred Transaction -- layer_id=%d, " |
| 551 | "frame_number=%llu", |
| 552 | id, dtc.layer_id(), dtc.frame_number()); |
| 553 | if (mLayers.count(dtc.layer_id()) == 0 || mLayers[dtc.layer_id()] == nullptr) { |
| 554 | ALOGE("Layer %d not found in Deferred Transaction", dtc.layer_id()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 555 | return; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 556 | } |
| 557 | |
| 558 | auto handle = mLayers[dtc.layer_id()]->getHandle(); |
| 559 | |
Marissa Wall | f58c14b | 2018-07-24 10:50:43 -0700 | [diff] [blame] | 560 | t.deferTransactionUntil_legacy(mLayers[id], handle, dtc.frame_number()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 561 | } |
| 562 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 563 | void Replayer::setDisplaySurface(SurfaceComposerClient::Transaction& t, |
| 564 | display_id id, const DispSurfaceChange& /*dsc*/) { |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 565 | sp<IGraphicBufferProducer> outProducer; |
| 566 | sp<IGraphicBufferConsumer> outConsumer; |
| 567 | BufferQueue::createBufferQueue(&outProducer, &outConsumer); |
| 568 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 569 | t.setDisplaySurface(mDisplays[id], outProducer); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 570 | } |
| 571 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 572 | void Replayer::setDisplayLayerStack(SurfaceComposerClient::Transaction& t, |
| 573 | display_id id, const LayerStackChange& lsc) { |
| 574 | t.setDisplayLayerStack(mDisplays[id], lsc.layer_stack()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 575 | } |
| 576 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 577 | void Replayer::setDisplaySize(SurfaceComposerClient::Transaction& t, |
| 578 | display_id id, const SizeChange& sc) { |
| 579 | t.setDisplaySize(mDisplays[id], sc.w(), sc.h()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 580 | } |
| 581 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 582 | void Replayer::setDisplayProjection(SurfaceComposerClient::Transaction& t, |
| 583 | display_id id, const ProjectionChange& pc) { |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 584 | Rect viewport = Rect(pc.viewport().left(), pc.viewport().top(), pc.viewport().right(), |
| 585 | pc.viewport().bottom()); |
| 586 | Rect frame = Rect(pc.frame().left(), pc.frame().top(), pc.frame().right(), pc.frame().bottom()); |
| 587 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 588 | t.setDisplayProjection(mDisplays[id], pc.orientation(), viewport, frame); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 589 | } |
| 590 | |
| 591 | status_t Replayer::createSurfaceControl( |
| 592 | const SurfaceCreation& create, const std::shared_ptr<Event>& event) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 593 | event->readyToExecute(); |
| 594 | |
| 595 | ALOGV("Creating Surface Control: ID: %d", create.id()); |
| 596 | sp<SurfaceControl> surfaceControl = mComposerClient->createSurface( |
| 597 | String8(create.name().c_str()), create.w(), create.h(), PIXEL_FORMAT_RGBA_8888, 0); |
| 598 | |
| 599 | if (surfaceControl == nullptr) { |
| 600 | ALOGE("CreateSurfaceControl: unable to create surface control"); |
| 601 | return BAD_VALUE; |
| 602 | } |
| 603 | |
| 604 | std::lock_guard<std::mutex> lock1(mLayerLock); |
| 605 | auto& layer = mLayers[create.id()]; |
| 606 | layer = surfaceControl; |
| 607 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 608 | mColors[create.id()] = HSV(rand() % 360, 1, 1); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 609 | |
| 610 | mLayerCond.notify_all(); |
| 611 | |
| 612 | std::lock_guard<std::mutex> lock2(mBufferQueueSchedulerLock); |
| 613 | if (mBufferQueueSchedulers.count(create.id()) != 0) { |
| 614 | mBufferQueueSchedulers[create.id()]->setSurfaceControl( |
| 615 | mLayers[create.id()], mColors[create.id()]); |
| 616 | } |
| 617 | |
| 618 | return NO_ERROR; |
| 619 | } |
| 620 | |
| 621 | status_t Replayer::deleteSurfaceControl( |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 622 | const SurfaceDeletion& delete_, const std::shared_ptr<Event>& event) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 623 | ALOGV("Deleting %d Surface Control", delete_.id()); |
| 624 | event->readyToExecute(); |
| 625 | |
| 626 | std::lock_guard<std::mutex> lock1(mPendingLayersLock); |
| 627 | |
| 628 | mLayersPendingRemoval.push_back(delete_.id()); |
| 629 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 630 | const auto& iterator = mBufferQueueSchedulers.find(delete_.id()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 631 | if (iterator != mBufferQueueSchedulers.end()) { |
| 632 | (*iterator).second->stopScheduling(); |
| 633 | } |
| 634 | |
| 635 | std::lock_guard<std::mutex> lock2(mLayerLock); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 636 | if (mLayers[delete_.id()] != nullptr) { |
| 637 | mComposerClient->destroySurface(mLayers[delete_.id()]->getHandle()); |
| 638 | } |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 639 | |
| 640 | return NO_ERROR; |
| 641 | } |
| 642 | |
| 643 | void Replayer::doDeleteSurfaceControls() { |
| 644 | std::lock_guard<std::mutex> lock1(mPendingLayersLock); |
| 645 | std::lock_guard<std::mutex> lock2(mLayerLock); |
| 646 | if (!mLayersPendingRemoval.empty()) { |
| 647 | for (int id : mLayersPendingRemoval) { |
| 648 | mLayers.erase(id); |
| 649 | mColors.erase(id); |
| 650 | mBufferQueueSchedulers.erase(id); |
| 651 | } |
| 652 | mLayersPendingRemoval.clear(); |
| 653 | } |
| 654 | } |
| 655 | |
| 656 | status_t Replayer::injectVSyncEvent( |
| 657 | const VSyncEvent& vSyncEvent, const std::shared_ptr<Event>& event) { |
| 658 | ALOGV("Injecting VSync Event"); |
| 659 | |
| 660 | doDeleteSurfaceControls(); |
| 661 | |
| 662 | event->readyToExecute(); |
| 663 | |
| 664 | SurfaceComposerClient::injectVSync(vSyncEvent.when()); |
| 665 | |
| 666 | return NO_ERROR; |
| 667 | } |
| 668 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 669 | void Replayer::createDisplay(const DisplayCreation& create, const std::shared_ptr<Event>& event) { |
| 670 | ALOGV("Creating display"); |
| 671 | event->readyToExecute(); |
| 672 | |
| 673 | std::lock_guard<std::mutex> lock(mDisplayLock); |
| 674 | sp<IBinder> display = SurfaceComposerClient::createDisplay( |
| 675 | String8(create.name().c_str()), create.is_secure()); |
| 676 | mDisplays[create.id()] = display; |
| 677 | |
| 678 | mDisplayCond.notify_all(); |
| 679 | |
| 680 | ALOGV("Done creating display"); |
| 681 | } |
| 682 | |
| 683 | void Replayer::deleteDisplay(const DisplayDeletion& delete_, const std::shared_ptr<Event>& event) { |
| 684 | ALOGV("Delete display"); |
| 685 | event->readyToExecute(); |
| 686 | |
| 687 | std::lock_guard<std::mutex> lock(mDisplayLock); |
| 688 | SurfaceComposerClient::destroyDisplay(mDisplays[delete_.id()]); |
| 689 | mDisplays.erase(delete_.id()); |
| 690 | } |
| 691 | |
| 692 | void Replayer::updatePowerMode(const PowerModeUpdate& pmu, const std::shared_ptr<Event>& event) { |
| 693 | ALOGV("Updating power mode"); |
| 694 | event->readyToExecute(); |
| 695 | SurfaceComposerClient::setDisplayPowerMode(mDisplays[pmu.id()], pmu.mode()); |
| 696 | } |
| 697 | |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 698 | void Replayer::waitUntilTimestamp(int64_t timestamp) { |
| 699 | ALOGV("Waiting for %lld nanoseconds...", static_cast<int64_t>(timestamp - mCurrentTime)); |
| 700 | std::this_thread::sleep_for(std::chrono::nanoseconds(timestamp - mCurrentTime)); |
| 701 | } |
| 702 | |
| 703 | void Replayer::waitUntilDeferredTransactionLayerExists( |
| 704 | const DeferredTransactionChange& dtc, std::unique_lock<std::mutex>& lock) { |
| 705 | if (mLayers.count(dtc.layer_id()) == 0 || mLayers[dtc.layer_id()] == nullptr) { |
| 706 | mLayerCond.wait(lock, [&] { return (mLayers[dtc.layer_id()] != nullptr); }); |
| 707 | } |
| 708 | } |
| 709 | |
| 710 | status_t Replayer::loadSurfaceComposerClient() { |
| 711 | mComposerClient = new SurfaceComposerClient; |
| 712 | return mComposerClient->initCheck(); |
| 713 | } |