| Index: cc/layers/surface_layer.cc
|
| diff --git a/cc/layers/surface_layer.cc b/cc/layers/surface_layer.cc
|
| index 0f8bd3380be1aa873bf5ed197dcafabad45a9c51..38561e5ed00fdc085d04470e66097a165886b0aa 100644
|
| --- a/cc/layers/surface_layer.cc
|
| +++ b/cc/layers/surface_layer.cc
|
| @@ -7,6 +7,7 @@
|
| #include <stdint.h>
|
|
|
| #include "base/macros.h"
|
| +#include "base/threading/thread_task_runner_handle.h"
|
| #include "base/trace_event/trace_event.h"
|
| #include "cc/layers/surface_layer_impl.h"
|
| #include "cc/output/swap_promise.h"
|
| @@ -16,28 +17,52 @@
|
|
|
| namespace cc {
|
|
|
| +namespace {
|
| +
|
| +// Some thread checkers fail if satisfy callback is not run on the main thread.
|
| +void PostSatisfyCallbackToMainThread(
|
| + scoped_refptr<base::SingleThreadTaskRunner> main_task_runner,
|
| + SurfaceLayer::SatisfyCallback satisfy_callback,
|
| + SurfaceSequence sequence) {
|
| + main_task_runner->PostTask(FROM_HERE, base::Bind(satisfy_callback, sequence));
|
| +}
|
| +
|
| +} // namespace
|
| +
|
| class SatisfySwapPromise : public SwapPromise {
|
| public:
|
| - SatisfySwapPromise(SurfaceSequence sequence,
|
| - const SurfaceLayer::SatisfyCallback& satisfy_callback)
|
| - : sequence_(sequence), satisfy_callback_(satisfy_callback) {}
|
| + SatisfySwapPromise(
|
| + const SurfaceSequence& sequence,
|
| + const SurfaceLayer::SatisfyCallback& satisfy_callback,
|
| + scoped_refptr<base::SingleThreadTaskRunner> main_task_runner)
|
| + : sequence_(sequence),
|
| + satisfy_callback_(satisfy_callback),
|
| + main_task_runner_(std::move(main_task_runner)) {}
|
|
|
| ~SatisfySwapPromise() override {}
|
|
|
| private:
|
| void DidActivate() override {}
|
| void DidSwap(CompositorFrameMetadata* metadata) override {
|
| - metadata->satisfies_sequences.push_back(sequence_.sequence);
|
| + // This method is called before the swap is actually performed in order to
|
| + // potentially add some stuff to compositor frame's metadata.
|
| + // By posting a task, we ensure that satisfy callback is not called until
|
| + // the swap is over.
|
| + base::ThreadTaskRunnerHandle::Get()->PostTask(
|
| + FROM_HERE, base::Bind(PostSatisfyCallbackToMainThread,
|
| + main_task_runner_, satisfy_callback_, sequence_));
|
| }
|
|
|
| DidNotSwapAction DidNotSwap(DidNotSwapReason reason) override {
|
| - satisfy_callback_.Run(sequence_);
|
| + main_task_runner_->PostTask(FROM_HERE,
|
| + base::Bind(satisfy_callback_, sequence_));
|
| return DidNotSwapAction::BREAK_PROMISE;
|
| }
|
| int64_t TraceId() const override { return 0; }
|
|
|
| SurfaceSequence sequence_;
|
| SurfaceLayer::SatisfyCallback satisfy_callback_;
|
| + scoped_refptr<base::SingleThreadTaskRunner> main_task_runner_;
|
|
|
| DISALLOW_COPY_AND_ASSIGN(SatisfySwapPromise);
|
| };
|
| @@ -117,8 +142,9 @@ void SurfaceLayer::SatisfyDestroySequence() {
|
| if (!layer_tree_host())
|
| return;
|
| DCHECK(destroy_sequence_.is_valid());
|
| - std::unique_ptr<SatisfySwapPromise> satisfy(
|
| - new SatisfySwapPromise(destroy_sequence_, satisfy_callback_));
|
| + auto satisfy =
|
| + base::MakeUnique<SatisfySwapPromise>(destroy_sequence_, satisfy_callback_,
|
| + base::ThreadTaskRunnerHandle::Get());
|
| layer_tree_host()->GetSwapPromiseManager()->QueueSwapPromise(
|
| std::move(satisfy));
|
| destroy_sequence_ = SurfaceSequence();
|
|
|