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; |
| 391 | case SurfaceChange::SurfaceChangeCase::kFinalCrop: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 392 | setFinalCrop(transaction, change.id(), change.final_crop()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 393 | break; |
| 394 | case SurfaceChange::SurfaceChangeCase::kOverrideScalingMode: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 395 | setOverrideScalingMode(transaction, change.id(), |
| 396 | change.override_scaling_mode()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 397 | break; |
| 398 | case SurfaceChange::SurfaceChangeCase::kTransparentRegionHint: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 399 | setTransparentRegionHint(transaction, change.id(), |
| 400 | change.transparent_region_hint()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 401 | break; |
| 402 | case SurfaceChange::SurfaceChangeCase::kLayerStack: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 403 | setLayerStack(transaction, change.id(), change.layer_stack()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 404 | break; |
| 405 | case SurfaceChange::SurfaceChangeCase::kHiddenFlag: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 406 | setHiddenFlag(transaction, change.id(), change.hidden_flag()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 407 | break; |
| 408 | case SurfaceChange::SurfaceChangeCase::kOpaqueFlag: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 409 | setOpaqueFlag(transaction, change.id(), change.opaque_flag()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 410 | break; |
| 411 | case SurfaceChange::SurfaceChangeCase::kSecureFlag: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 412 | setSecureFlag(transaction, change.id(), change.secure_flag()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 413 | break; |
| 414 | case SurfaceChange::SurfaceChangeCase::kDeferredTransaction: |
| 415 | waitUntilDeferredTransactionLayerExists(change.deferred_transaction(), lock); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 416 | setDeferredTransaction(transaction, change.id(), |
| 417 | change.deferred_transaction()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 418 | break; |
| 419 | default: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 420 | status = 1; |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 421 | break; |
| 422 | } |
| 423 | |
| 424 | if (status != NO_ERROR) { |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 425 | ALOGE("Unknown Transaction Code"); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 426 | return status; |
| 427 | } |
| 428 | } |
| 429 | return status; |
| 430 | } |
| 431 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 432 | void Replayer::doDisplayTransaction(SurfaceComposerClient::Transaction& t, |
| 433 | const DisplayChanges& displayChanges) { |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 434 | for (const DisplayChange& change : displayChanges) { |
| 435 | ALOGV("Doing display transaction"); |
| 436 | std::unique_lock<std::mutex> lock(mDisplayLock); |
| 437 | if (mDisplays[change.id()] == nullptr) { |
| 438 | mDisplayCond.wait(lock, [&] { return (mDisplays[change.id()] != nullptr); }); |
| 439 | } |
| 440 | |
| 441 | switch (change.DisplayChange_case()) { |
| 442 | case DisplayChange::DisplayChangeCase::kSurface: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 443 | setDisplaySurface(t, change.id(), change.surface()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 444 | break; |
| 445 | case DisplayChange::DisplayChangeCase::kLayerStack: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 446 | setDisplayLayerStack(t, change.id(), change.layer_stack()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 447 | break; |
| 448 | case DisplayChange::DisplayChangeCase::kSize: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 449 | setDisplaySize(t, change.id(), change.size()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 450 | break; |
| 451 | case DisplayChange::DisplayChangeCase::kProjection: |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 452 | setDisplayProjection(t, change.id(), change.projection()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 453 | break; |
| 454 | default: |
| 455 | break; |
| 456 | } |
| 457 | } |
| 458 | } |
| 459 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 460 | void Replayer::setPosition(SurfaceComposerClient::Transaction& t, |
| 461 | layer_id id, const PositionChange& pc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 462 | 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] | 463 | t.setPosition(mLayers[id], pc.x(), pc.y()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 464 | } |
| 465 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 466 | void Replayer::setSize(SurfaceComposerClient::Transaction& t, |
| 467 | layer_id id, const SizeChange& sc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 468 | 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] | 469 | t.setSize(mLayers[id], sc.w(), sc.h()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 470 | } |
| 471 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 472 | void Replayer::setLayer(SurfaceComposerClient::Transaction& t, |
| 473 | layer_id id, const LayerChange& lc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 474 | ALOGV("Layer %d: Setting Layer -- layer=%d", id, lc.layer()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 475 | t.setLayer(mLayers[id], lc.layer()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 476 | } |
| 477 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 478 | void Replayer::setAlpha(SurfaceComposerClient::Transaction& t, |
| 479 | layer_id id, const AlphaChange& ac) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 480 | ALOGV("Layer %d: Setting Alpha -- alpha=%f", id, ac.alpha()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 481 | t.setAlpha(mLayers[id], ac.alpha()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 482 | } |
| 483 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 484 | void Replayer::setCrop(SurfaceComposerClient::Transaction& t, |
| 485 | layer_id id, const CropChange& cc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 486 | ALOGV("Layer %d: Setting Crop -- left=%d, top=%d, right=%d, bottom=%d", id, |
| 487 | cc.rectangle().left(), cc.rectangle().top(), cc.rectangle().right(), |
| 488 | cc.rectangle().bottom()); |
| 489 | |
| 490 | Rect r = Rect(cc.rectangle().left(), cc.rectangle().top(), cc.rectangle().right(), |
| 491 | cc.rectangle().bottom()); |
Marissa Wall | f58c14b | 2018-07-24 10:50:43 -0700 | [diff] [blame^] | 492 | t.setCrop_legacy(mLayers[id], r); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 493 | } |
| 494 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 495 | void Replayer::setFinalCrop(SurfaceComposerClient::Transaction& t, |
| 496 | layer_id id, const FinalCropChange& fcc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 497 | ALOGV("Layer %d: Setting Final Crop -- left=%d, top=%d, right=%d, bottom=%d", id, |
| 498 | fcc.rectangle().left(), fcc.rectangle().top(), fcc.rectangle().right(), |
| 499 | fcc.rectangle().bottom()); |
| 500 | Rect r = Rect(fcc.rectangle().left(), fcc.rectangle().top(), fcc.rectangle().right(), |
| 501 | fcc.rectangle().bottom()); |
Marissa Wall | f58c14b | 2018-07-24 10:50:43 -0700 | [diff] [blame^] | 502 | t.setFinalCrop_legacy(mLayers[id], r); |
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::setMatrix(SurfaceComposerClient::Transaction& t, |
| 506 | layer_id id, const MatrixChange& mc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 507 | ALOGV("Layer %d: Setting Matrix -- dsdx=%f, dtdx=%f, dsdy=%f, dtdy=%f", id, mc.dsdx(), |
| 508 | mc.dtdx(), mc.dsdy(), mc.dtdy()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 509 | t.setMatrix(mLayers[id], mc.dsdx(), mc.dtdx(), mc.dsdy(), mc.dtdy()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 510 | } |
| 511 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 512 | void Replayer::setOverrideScalingMode(SurfaceComposerClient::Transaction& t, |
| 513 | layer_id id, const OverrideScalingModeChange& osmc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 514 | 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] | 515 | t.setOverrideScalingMode(mLayers[id], osmc.override_scaling_mode()); |
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::setTransparentRegionHint(SurfaceComposerClient::Transaction& t, |
| 519 | layer_id id, const TransparentRegionHintChange& trhc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 520 | ALOGV("Setting Transparent Region Hint"); |
| 521 | Region re = Region(); |
| 522 | |
Chih-Hung Hsieh | cb057c2 | 2017-08-03 15:48:25 -0700 | [diff] [blame] | 523 | for (const auto& r : trhc.region()) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 524 | Rect rect = Rect(r.left(), r.top(), r.right(), r.bottom()); |
| 525 | re.merge(rect); |
| 526 | } |
| 527 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 528 | t.setTransparentRegionHint(mLayers[id], re); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 529 | } |
| 530 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 531 | void Replayer::setLayerStack(SurfaceComposerClient::Transaction& t, |
| 532 | layer_id id, const LayerStackChange& lsc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 533 | ALOGV("Layer %d: Setting LayerStack -- layer_stack=%d", id, lsc.layer_stack()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 534 | t.setLayerStack(mLayers[id], lsc.layer_stack()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 535 | } |
| 536 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 537 | void Replayer::setHiddenFlag(SurfaceComposerClient::Transaction& t, |
| 538 | layer_id id, const HiddenFlagChange& hfc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 539 | 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] | 540 | layer_id flag = hfc.hidden_flag() ? layer_state_t::eLayerHidden : 0; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 541 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 542 | t.setFlags(mLayers[id], flag, layer_state_t::eLayerHidden); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 543 | } |
| 544 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 545 | void Replayer::setOpaqueFlag(SurfaceComposerClient::Transaction& t, |
| 546 | layer_id id, const OpaqueFlagChange& ofc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 547 | 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] | 548 | layer_id flag = ofc.opaque_flag() ? layer_state_t::eLayerOpaque : 0; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 549 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 550 | t.setFlags(mLayers[id], flag, layer_state_t::eLayerOpaque); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 551 | } |
| 552 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 553 | void Replayer::setSecureFlag(SurfaceComposerClient::Transaction& t, |
| 554 | layer_id id, const SecureFlagChange& sfc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 555 | 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] | 556 | layer_id flag = sfc.secure_flag() ? layer_state_t::eLayerSecure : 0; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 557 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 558 | t.setFlags(mLayers[id], flag, layer_state_t::eLayerSecure); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 559 | } |
| 560 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 561 | void Replayer::setDeferredTransaction(SurfaceComposerClient::Transaction& t, |
| 562 | layer_id id, const DeferredTransactionChange& dtc) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 563 | ALOGV("Layer %d: Setting Deferred Transaction -- layer_id=%d, " |
| 564 | "frame_number=%llu", |
| 565 | id, dtc.layer_id(), dtc.frame_number()); |
| 566 | if (mLayers.count(dtc.layer_id()) == 0 || mLayers[dtc.layer_id()] == nullptr) { |
| 567 | ALOGE("Layer %d not found in Deferred Transaction", dtc.layer_id()); |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 568 | return; |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 569 | } |
| 570 | |
| 571 | auto handle = mLayers[dtc.layer_id()]->getHandle(); |
| 572 | |
Marissa Wall | f58c14b | 2018-07-24 10:50:43 -0700 | [diff] [blame^] | 573 | t.deferTransactionUntil_legacy(mLayers[id], handle, dtc.frame_number()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 574 | } |
| 575 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 576 | void Replayer::setDisplaySurface(SurfaceComposerClient::Transaction& t, |
| 577 | display_id id, const DispSurfaceChange& /*dsc*/) { |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 578 | sp<IGraphicBufferProducer> outProducer; |
| 579 | sp<IGraphicBufferConsumer> outConsumer; |
| 580 | BufferQueue::createBufferQueue(&outProducer, &outConsumer); |
| 581 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 582 | t.setDisplaySurface(mDisplays[id], outProducer); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 583 | } |
| 584 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 585 | void Replayer::setDisplayLayerStack(SurfaceComposerClient::Transaction& t, |
| 586 | display_id id, const LayerStackChange& lsc) { |
| 587 | t.setDisplayLayerStack(mDisplays[id], lsc.layer_stack()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 588 | } |
| 589 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 590 | void Replayer::setDisplaySize(SurfaceComposerClient::Transaction& t, |
| 591 | display_id id, const SizeChange& sc) { |
| 592 | t.setDisplaySize(mDisplays[id], sc.w(), sc.h()); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 593 | } |
| 594 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 595 | void Replayer::setDisplayProjection(SurfaceComposerClient::Transaction& t, |
| 596 | display_id id, const ProjectionChange& pc) { |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 597 | Rect viewport = Rect(pc.viewport().left(), pc.viewport().top(), pc.viewport().right(), |
| 598 | pc.viewport().bottom()); |
| 599 | Rect frame = Rect(pc.frame().left(), pc.frame().top(), pc.frame().right(), pc.frame().bottom()); |
| 600 | |
Robert Carr | 4cdc58f | 2017-08-23 14:22:20 -0700 | [diff] [blame] | 601 | t.setDisplayProjection(mDisplays[id], pc.orientation(), viewport, frame); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 602 | } |
| 603 | |
| 604 | status_t Replayer::createSurfaceControl( |
| 605 | const SurfaceCreation& create, const std::shared_ptr<Event>& event) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 606 | event->readyToExecute(); |
| 607 | |
| 608 | ALOGV("Creating Surface Control: ID: %d", create.id()); |
| 609 | sp<SurfaceControl> surfaceControl = mComposerClient->createSurface( |
| 610 | String8(create.name().c_str()), create.w(), create.h(), PIXEL_FORMAT_RGBA_8888, 0); |
| 611 | |
| 612 | if (surfaceControl == nullptr) { |
| 613 | ALOGE("CreateSurfaceControl: unable to create surface control"); |
| 614 | return BAD_VALUE; |
| 615 | } |
| 616 | |
| 617 | std::lock_guard<std::mutex> lock1(mLayerLock); |
| 618 | auto& layer = mLayers[create.id()]; |
| 619 | layer = surfaceControl; |
| 620 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 621 | mColors[create.id()] = HSV(rand() % 360, 1, 1); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 622 | |
| 623 | mLayerCond.notify_all(); |
| 624 | |
| 625 | std::lock_guard<std::mutex> lock2(mBufferQueueSchedulerLock); |
| 626 | if (mBufferQueueSchedulers.count(create.id()) != 0) { |
| 627 | mBufferQueueSchedulers[create.id()]->setSurfaceControl( |
| 628 | mLayers[create.id()], mColors[create.id()]); |
| 629 | } |
| 630 | |
| 631 | return NO_ERROR; |
| 632 | } |
| 633 | |
| 634 | status_t Replayer::deleteSurfaceControl( |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 635 | const SurfaceDeletion& delete_, const std::shared_ptr<Event>& event) { |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 636 | ALOGV("Deleting %d Surface Control", delete_.id()); |
| 637 | event->readyToExecute(); |
| 638 | |
| 639 | std::lock_guard<std::mutex> lock1(mPendingLayersLock); |
| 640 | |
| 641 | mLayersPendingRemoval.push_back(delete_.id()); |
| 642 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 643 | const auto& iterator = mBufferQueueSchedulers.find(delete_.id()); |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 644 | if (iterator != mBufferQueueSchedulers.end()) { |
| 645 | (*iterator).second->stopScheduling(); |
| 646 | } |
| 647 | |
| 648 | std::lock_guard<std::mutex> lock2(mLayerLock); |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 649 | if (mLayers[delete_.id()] != nullptr) { |
| 650 | mComposerClient->destroySurface(mLayers[delete_.id()]->getHandle()); |
| 651 | } |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 652 | |
| 653 | return NO_ERROR; |
| 654 | } |
| 655 | |
| 656 | void Replayer::doDeleteSurfaceControls() { |
| 657 | std::lock_guard<std::mutex> lock1(mPendingLayersLock); |
| 658 | std::lock_guard<std::mutex> lock2(mLayerLock); |
| 659 | if (!mLayersPendingRemoval.empty()) { |
| 660 | for (int id : mLayersPendingRemoval) { |
| 661 | mLayers.erase(id); |
| 662 | mColors.erase(id); |
| 663 | mBufferQueueSchedulers.erase(id); |
| 664 | } |
| 665 | mLayersPendingRemoval.clear(); |
| 666 | } |
| 667 | } |
| 668 | |
| 669 | status_t Replayer::injectVSyncEvent( |
| 670 | const VSyncEvent& vSyncEvent, const std::shared_ptr<Event>& event) { |
| 671 | ALOGV("Injecting VSync Event"); |
| 672 | |
| 673 | doDeleteSurfaceControls(); |
| 674 | |
| 675 | event->readyToExecute(); |
| 676 | |
| 677 | SurfaceComposerClient::injectVSync(vSyncEvent.when()); |
| 678 | |
| 679 | return NO_ERROR; |
| 680 | } |
| 681 | |
Sahil Dhanju | 01041fe | 2016-08-08 20:27:23 -0700 | [diff] [blame] | 682 | void Replayer::createDisplay(const DisplayCreation& create, const std::shared_ptr<Event>& event) { |
| 683 | ALOGV("Creating display"); |
| 684 | event->readyToExecute(); |
| 685 | |
| 686 | std::lock_guard<std::mutex> lock(mDisplayLock); |
| 687 | sp<IBinder> display = SurfaceComposerClient::createDisplay( |
| 688 | String8(create.name().c_str()), create.is_secure()); |
| 689 | mDisplays[create.id()] = display; |
| 690 | |
| 691 | mDisplayCond.notify_all(); |
| 692 | |
| 693 | ALOGV("Done creating display"); |
| 694 | } |
| 695 | |
| 696 | void Replayer::deleteDisplay(const DisplayDeletion& delete_, const std::shared_ptr<Event>& event) { |
| 697 | ALOGV("Delete display"); |
| 698 | event->readyToExecute(); |
| 699 | |
| 700 | std::lock_guard<std::mutex> lock(mDisplayLock); |
| 701 | SurfaceComposerClient::destroyDisplay(mDisplays[delete_.id()]); |
| 702 | mDisplays.erase(delete_.id()); |
| 703 | } |
| 704 | |
| 705 | void Replayer::updatePowerMode(const PowerModeUpdate& pmu, const std::shared_ptr<Event>& event) { |
| 706 | ALOGV("Updating power mode"); |
| 707 | event->readyToExecute(); |
| 708 | SurfaceComposerClient::setDisplayPowerMode(mDisplays[pmu.id()], pmu.mode()); |
| 709 | } |
| 710 | |
Sahil Dhanju | c1ba5c4 | 2016-06-07 20:09:20 -0700 | [diff] [blame] | 711 | void Replayer::waitUntilTimestamp(int64_t timestamp) { |
| 712 | ALOGV("Waiting for %lld nanoseconds...", static_cast<int64_t>(timestamp - mCurrentTime)); |
| 713 | std::this_thread::sleep_for(std::chrono::nanoseconds(timestamp - mCurrentTime)); |
| 714 | } |
| 715 | |
| 716 | void Replayer::waitUntilDeferredTransactionLayerExists( |
| 717 | const DeferredTransactionChange& dtc, std::unique_lock<std::mutex>& lock) { |
| 718 | if (mLayers.count(dtc.layer_id()) == 0 || mLayers[dtc.layer_id()] == nullptr) { |
| 719 | mLayerCond.wait(lock, [&] { return (mLayers[dtc.layer_id()] != nullptr); }); |
| 720 | } |
| 721 | } |
| 722 | |
| 723 | status_t Replayer::loadSurfaceComposerClient() { |
| 724 | mComposerClient = new SurfaceComposerClient; |
| 725 | return mComposerClient->initCheck(); |
| 726 | } |