| // Copyright 2015 The Chromium Authors. All rights reserved. |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #include "remoting/client/plugin/pepper_main_thread_task_runner.h" |
| |
| #include <memory> |
| #include <utility> |
| |
| #include "base/bind.h" |
| #include "ppapi/cpp/completion_callback.h" |
| #include "ppapi/cpp/core.h" |
| #include "ppapi/cpp/module.h" |
| |
| namespace remoting { |
| namespace { |
| |
| void RunAndDestroy(void* task_ptr, int32_t) { |
| std::unique_ptr<base::OnceClosure> task( |
| static_cast<base::OnceClosure*>(task_ptr)); |
| std::move(*task).Run(); |
| } |
| |
| } // namespace |
| |
| PepperMainThreadTaskRunner::PepperMainThreadTaskRunner() |
| : core_(pp::Module::Get()->core()), weak_ptr_factory_(this) { |
| DCHECK(core_->IsMainThread()); |
| weak_ptr_ = weak_ptr_factory_.GetWeakPtr(); |
| } |
| |
| bool PepperMainThreadTaskRunner::PostDelayedTask( |
| const base::Location& from_here, |
| base::OnceClosure task, |
| base::TimeDelta delay) { |
| auto task_ptr = std::make_unique<base::OnceClosure>(base::Bind( |
| &PepperMainThreadTaskRunner::RunTask, weak_ptr_, base::Passed(&task))); |
| core_->CallOnMainThread( |
| delay.InMillisecondsRoundedUp(), |
| pp::CompletionCallback(&RunAndDestroy, task_ptr.release())); |
| return true; |
| } |
| |
| bool PepperMainThreadTaskRunner::PostNonNestableDelayedTask( |
| const base::Location& from_here, |
| base::OnceClosure task, |
| base::TimeDelta delay) { |
| return PostDelayedTask(from_here, std::move(task), delay); |
| } |
| |
| bool PepperMainThreadTaskRunner::RunsTasksInCurrentSequence() const { |
| return core_->IsMainThread(); |
| } |
| |
| PepperMainThreadTaskRunner::~PepperMainThreadTaskRunner() {} |
| |
| void PepperMainThreadTaskRunner::RunTask(base::OnceClosure task) { |
| std::move(task).Run(); |
| } |
| |
| } // namespace remoting |