123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166 |
- // Copyright 2016 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/host/mouse_cursor_monitor_proxy.h"
- #include <memory>
- #include "base/bind.h"
- #include "base/location.h"
- #include "base/logging.h"
- #include "base/task/single_thread_task_runner.h"
- #include "base/threading/thread_task_runner_handle.h"
- #include "build/chromeos_buildflags.h"
- #include "third_party/webrtc/modules/desktop_capture/desktop_capture_options.h"
- #include "third_party/webrtc/modules/desktop_capture/desktop_frame.h"
- #include "third_party/webrtc/modules/desktop_capture/mouse_cursor.h"
- #include "third_party/webrtc/modules/desktop_capture/mouse_cursor_monitor.h"
- #if BUILDFLAG(IS_CHROMEOS_ASH)
- #include "remoting/host/chromeos/mouse_cursor_monitor_aura.h"
- #endif
- namespace remoting {
- class MouseCursorMonitorProxy::Core
- : public webrtc::MouseCursorMonitor::Callback {
- public:
- explicit Core(base::WeakPtr<MouseCursorMonitorProxy> proxy);
- Core(const Core&) = delete;
- Core& operator=(const Core&) = delete;
- ~Core() override;
- void CreateMouseCursorMonitor(const webrtc::DesktopCaptureOptions& options);
- void Init(webrtc::MouseCursorMonitor::Mode mode);
- void Capture();
- void SetMouseCursorMonitorForTests(
- std::unique_ptr<webrtc::MouseCursorMonitor> mouse_cursor_monitor);
- private:
- // webrtc::MouseCursorMonitor::Callback implementation.
- void OnMouseCursor(webrtc::MouseCursor* mouse_cursor) override;
- void OnMouseCursorPosition(const webrtc::DesktopVector& position) override;
- base::ThreadChecker thread_checker_;
- base::WeakPtr<MouseCursorMonitorProxy> proxy_;
- scoped_refptr<base::SingleThreadTaskRunner> caller_task_runner_;
- std::unique_ptr<webrtc::MouseCursorMonitor> mouse_cursor_monitor_;
- };
- MouseCursorMonitorProxy::Core::Core(
- base::WeakPtr<MouseCursorMonitorProxy> proxy)
- : proxy_(proxy), caller_task_runner_(base::ThreadTaskRunnerHandle::Get()) {
- thread_checker_.DetachFromThread();
- }
- MouseCursorMonitorProxy::Core::~Core() {
- DCHECK(thread_checker_.CalledOnValidThread());
- }
- void MouseCursorMonitorProxy::Core::CreateMouseCursorMonitor(
- const webrtc::DesktopCaptureOptions& options) {
- DCHECK(thread_checker_.CalledOnValidThread());
- #if BUILDFLAG(IS_CHROMEOS_ASH)
- mouse_cursor_monitor_ = std::make_unique<MouseCursorMonitorAura>();
- #else // BUILDFLAG(IS_CHROMEOS_ASH)
- mouse_cursor_monitor_.reset(webrtc::MouseCursorMonitor::CreateForScreen(
- options, webrtc::kFullDesktopScreenId));
- #endif // BUILDFLAG(IS_CHROMEOS_ASH)
- if (!mouse_cursor_monitor_)
- LOG(ERROR) << "Failed to initialize MouseCursorMonitor.";
- }
- void MouseCursorMonitorProxy::Core::Init(
- webrtc::MouseCursorMonitor::Mode mode) {
- DCHECK(thread_checker_.CalledOnValidThread());
- if (mouse_cursor_monitor_)
- mouse_cursor_monitor_->Init(this, mode);
- }
- void MouseCursorMonitorProxy::Core::Capture() {
- DCHECK(thread_checker_.CalledOnValidThread());
- if (mouse_cursor_monitor_)
- mouse_cursor_monitor_->Capture();
- }
- void MouseCursorMonitorProxy::Core::SetMouseCursorMonitorForTests(
- std::unique_ptr<webrtc::MouseCursorMonitor> mouse_cursor_monitor) {
- mouse_cursor_monitor_ = std::move(mouse_cursor_monitor);
- }
- void MouseCursorMonitorProxy::Core::OnMouseCursor(webrtc::MouseCursor* cursor) {
- DCHECK(thread_checker_.CalledOnValidThread());
- std::unique_ptr<webrtc::MouseCursor> owned_cursor(cursor);
- caller_task_runner_->PostTask(
- FROM_HERE, base::BindOnce(&MouseCursorMonitorProxy::OnMouseCursor, proxy_,
- std::move(owned_cursor)));
- }
- void MouseCursorMonitorProxy::Core::OnMouseCursorPosition(
- const webrtc::DesktopVector& position) {
- DCHECK(thread_checker_.CalledOnValidThread());
- caller_task_runner_->PostTask(
- FROM_HERE, base::BindOnce(&MouseCursorMonitorProxy::OnMouseCursorPosition,
- proxy_, position));
- }
- MouseCursorMonitorProxy::MouseCursorMonitorProxy(
- scoped_refptr<base::SingleThreadTaskRunner> capture_task_runner,
- const webrtc::DesktopCaptureOptions& options)
- : capture_task_runner_(capture_task_runner) {
- core_ = std::make_unique<Core>(weak_factory_.GetWeakPtr());
- capture_task_runner_->PostTask(
- FROM_HERE, base::BindOnce(&Core::CreateMouseCursorMonitor,
- base::Unretained(core_.get()), options));
- }
- MouseCursorMonitorProxy::~MouseCursorMonitorProxy() {
- capture_task_runner_->DeleteSoon(FROM_HERE, core_.release());
- }
- void MouseCursorMonitorProxy::Init(Callback* callback, Mode mode) {
- DCHECK(thread_checker_.CalledOnValidThread());
- callback_ = callback;
- capture_task_runner_->PostTask(
- FROM_HERE,
- base::BindOnce(&Core::Init, base::Unretained(core_.get()), mode));
- }
- void MouseCursorMonitorProxy::Capture() {
- DCHECK(thread_checker_.CalledOnValidThread());
- capture_task_runner_->PostTask(
- FROM_HERE, base::BindOnce(&Core::Capture, base::Unretained(core_.get())));
- }
- void MouseCursorMonitorProxy::SetMouseCursorMonitorForTests(
- std::unique_ptr<webrtc::MouseCursorMonitor> mouse_cursor_monitor) {
- capture_task_runner_->PostTask(
- FROM_HERE, base::BindOnce(&Core::SetMouseCursorMonitorForTests,
- base::Unretained(core_.get()),
- std::move(mouse_cursor_monitor)));
- }
- void MouseCursorMonitorProxy::OnMouseCursor(
- std::unique_ptr<webrtc::MouseCursor> cursor) {
- DCHECK(thread_checker_.CalledOnValidThread());
- callback_->OnMouseCursor(cursor.release());
- }
- void MouseCursorMonitorProxy::OnMouseCursorPosition(
- const webrtc::DesktopVector& position) {
- DCHECK(thread_checker_.CalledOnValidThread());
- callback_->OnMouseCursorPosition(position);
- }
- } // namespace remoting
|