OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 | 4 |
5 #include "remoting/client/jni/jni_gl_display_handler.h" | 5 #include "remoting/client/jni/jni_gl_display_handler.h" |
6 | 6 |
7 #include <android/native_window_jni.h> | 7 #include <android/native_window_jni.h> |
8 #include <array> | 8 #include <array> |
9 | 9 |
10 #include "base/android/jni_android.h" | 10 #include "base/android/jni_android.h" |
11 #include "base/bind.h" | 11 #include "base/bind.h" |
12 #include "base/logging.h" | 12 #include "base/logging.h" |
13 #include "base/memory/ptr_util.h" | 13 #include "base/memory/ptr_util.h" |
14 #include "jni/GlDisplay_jni.h" | 14 #include "jni/GlDisplay_jni.h" |
15 #include "remoting/client/cursor_shape_stub_proxy.h" | 15 #include "remoting/client/cursor_shape_stub_proxy.h" |
| 16 #include "remoting/client/display/gl_canvas.h" |
16 #include "remoting/client/dual_buffer_frame_consumer.h" | 17 #include "remoting/client/dual_buffer_frame_consumer.h" |
17 #include "remoting/client/jni/chromoting_jni_runtime.h" | 18 #include "remoting/client/jni/chromoting_jni_runtime.h" |
18 #include "remoting/client/jni/egl_thread_context.h" | 19 #include "remoting/client/jni/egl_thread_context.h" |
19 #include "remoting/client/software_video_renderer.h" | 20 #include "remoting/client/software_video_renderer.h" |
20 #include "remoting/protocol/frame_consumer.h" | 21 #include "remoting/protocol/frame_consumer.h" |
21 | 22 |
22 namespace remoting { | 23 namespace remoting { |
23 | 24 |
24 // The core that lives on the display thread. | 25 // The core that lives on the display thread. |
25 class JniGlDisplayHandler::Core : public protocol::CursorShapeStub, | 26 class JniGlDisplayHandler::Core : public protocol::CursorShapeStub, |
(...skipping 29 matching lines...) Expand all Loading... |
55 ChromotingJniRuntime* runtime_; | 56 ChromotingJniRuntime* runtime_; |
56 base::WeakPtr<JniGlDisplayHandler> shell_; | 57 base::WeakPtr<JniGlDisplayHandler> shell_; |
57 | 58 |
58 // Will be std::move'd when GrabFrameConsumer() is called. | 59 // Will be std::move'd when GrabFrameConsumer() is called. |
59 std::unique_ptr<DualBufferFrameConsumer> owned_frame_consumer_; | 60 std::unique_ptr<DualBufferFrameConsumer> owned_frame_consumer_; |
60 | 61 |
61 base::WeakPtr<DualBufferFrameConsumer> frame_consumer_; | 62 base::WeakPtr<DualBufferFrameConsumer> frame_consumer_; |
62 | 63 |
63 ANativeWindow* window_ = nullptr; | 64 ANativeWindow* window_ = nullptr; |
64 std::unique_ptr<EglThreadContext> egl_context_; | 65 std::unique_ptr<EglThreadContext> egl_context_; |
65 GlRenderer renderer_; | 66 std::unique_ptr<GlRenderer> renderer_; |
66 | 67 |
67 // Used on display thread. | 68 // Used on display thread. |
68 base::WeakPtr<Core> weak_ptr_; | 69 base::WeakPtr<Core> weak_ptr_; |
69 base::WeakPtrFactory<Core> weak_factory_; | 70 base::WeakPtrFactory<Core> weak_factory_; |
70 | 71 |
71 DISALLOW_COPY_AND_ASSIGN(Core); | 72 DISALLOW_COPY_AND_ASSIGN(Core); |
72 }; | 73 }; |
73 | 74 |
74 JniGlDisplayHandler::Core::Core(ChromotingJniRuntime* runtime, | 75 JniGlDisplayHandler::Core::Core(ChromotingJniRuntime* runtime, |
75 base::WeakPtr<JniGlDisplayHandler> shell) | 76 base::WeakPtr<JniGlDisplayHandler> shell) |
76 : runtime_(runtime), shell_(shell), weak_factory_(this) { | 77 : runtime_(runtime), shell_(shell), weak_factory_(this) { |
| 78 renderer_ = GlRenderer::CreateGlRendererWithDesktop(); |
77 weak_ptr_ = weak_factory_.GetWeakPtr(); | 79 weak_ptr_ = weak_factory_.GetWeakPtr(); |
78 renderer_.SetDelegate(weak_ptr_); | 80 renderer_->SetDelegate(weak_ptr_); |
79 owned_frame_consumer_.reset(new DualBufferFrameConsumer( | 81 owned_frame_consumer_.reset(new DualBufferFrameConsumer( |
80 base::Bind(&GlRenderer::OnFrameReceived, renderer_.GetWeakPtr()), | 82 base::Bind(&GlRenderer::OnFrameReceived, renderer_->GetWeakPtr()), |
81 runtime_->display_task_runner(), | 83 runtime_->display_task_runner(), |
82 protocol::FrameConsumer::PixelFormat::FORMAT_RGBA)); | 84 protocol::FrameConsumer::PixelFormat::FORMAT_RGBA)); |
83 frame_consumer_ = owned_frame_consumer_->GetWeakPtr(); | 85 frame_consumer_ = owned_frame_consumer_->GetWeakPtr(); |
84 } | 86 } |
85 | 87 |
86 JniGlDisplayHandler::Core::~Core() {} | 88 JniGlDisplayHandler::Core::~Core() {} |
87 | 89 |
88 bool JniGlDisplayHandler::Core::CanRenderFrame() { | 90 bool JniGlDisplayHandler::Core::CanRenderFrame() { |
89 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 91 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
90 return egl_context_ && egl_context_->IsWindowBound(); | 92 return egl_context_ && egl_context_->IsWindowBound(); |
91 } | 93 } |
92 | 94 |
93 void JniGlDisplayHandler::Core::OnFrameRendered() { | 95 void JniGlDisplayHandler::Core::OnFrameRendered() { |
94 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 96 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
95 egl_context_->SwapBuffers(); | 97 egl_context_->SwapBuffers(); |
96 runtime_->ui_task_runner()->PostTask( | 98 runtime_->ui_task_runner()->PostTask( |
97 FROM_HERE, base::Bind(&JniGlDisplayHandler::OnRenderDone, shell_)); | 99 FROM_HERE, base::Bind(&JniGlDisplayHandler::OnRenderDone, shell_)); |
98 } | 100 } |
99 | 101 |
100 void JniGlDisplayHandler::Core::OnSizeChanged(int width, int height) { | 102 void JniGlDisplayHandler::Core::OnSizeChanged(int width, int height) { |
101 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 103 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
102 runtime_->ui_task_runner()->PostTask( | 104 runtime_->ui_task_runner()->PostTask( |
103 FROM_HERE, base::Bind(&JniGlDisplayHandler::OnCanvasSizeChanged, shell_, | 105 FROM_HERE, base::Bind(&JniGlDisplayHandler::OnCanvasSizeChanged, shell_, |
104 width, height)); | 106 width, height)); |
105 } | 107 } |
106 | 108 |
107 void JniGlDisplayHandler::Core::SetCursorShape( | 109 void JniGlDisplayHandler::Core::SetCursorShape( |
108 const protocol::CursorShapeInfo& cursor_shape) { | 110 const protocol::CursorShapeInfo& cursor_shape) { |
109 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 111 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
110 renderer_.OnCursorShapeChanged(cursor_shape); | 112 renderer_->OnCursorShapeChanged(cursor_shape); |
111 } | 113 } |
112 | 114 |
113 std::unique_ptr<protocol::FrameConsumer> | 115 std::unique_ptr<protocol::FrameConsumer> |
114 JniGlDisplayHandler::Core::GrabFrameConsumer() { | 116 JniGlDisplayHandler::Core::GrabFrameConsumer() { |
115 DCHECK(owned_frame_consumer_) << "The frame consumer is already grabbed."; | 117 DCHECK(owned_frame_consumer_) << "The frame consumer is already grabbed."; |
116 return std::move(owned_frame_consumer_); | 118 return std::move(owned_frame_consumer_); |
117 } | 119 } |
118 | 120 |
119 void JniGlDisplayHandler::Core::SurfaceCreated( | 121 void JniGlDisplayHandler::Core::SurfaceCreated( |
120 base::android::ScopedJavaGlobalRef<jobject> surface) { | 122 base::android::ScopedJavaGlobalRef<jobject> surface) { |
121 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 123 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
122 DCHECK(!egl_context_); | 124 DCHECK(!egl_context_); |
123 DCHECK(!window_); | 125 DCHECK(!window_); |
124 renderer_.RequestCanvasSize(); | 126 renderer_->RequestCanvasSize(); |
125 window_ = ANativeWindow_fromSurface(base::android::AttachCurrentThread(), | 127 window_ = ANativeWindow_fromSurface(base::android::AttachCurrentThread(), |
126 surface.obj()); | 128 surface.obj()); |
127 egl_context_.reset(new EglThreadContext()); | 129 egl_context_.reset(new EglThreadContext()); |
128 egl_context_->BindToWindow(window_); | 130 egl_context_->BindToWindow(window_); |
129 renderer_.OnSurfaceCreated(static_cast<int>(egl_context_->client_version())); | 131 |
| 132 renderer_->OnSurfaceCreated(base::MakeUnique<GlCanvas>( |
| 133 static_cast<int>(egl_context_->client_version()))); |
| 134 |
130 runtime_->network_task_runner()->PostTask( | 135 runtime_->network_task_runner()->PostTask( |
131 FROM_HERE, base::Bind(&DualBufferFrameConsumer::RequestFullDesktopFrame, | 136 FROM_HERE, base::Bind(&DualBufferFrameConsumer::RequestFullDesktopFrame, |
132 frame_consumer_)); | 137 frame_consumer_)); |
133 } | 138 } |
134 | 139 |
135 void JniGlDisplayHandler::Core::SurfaceChanged(int width, int height) { | 140 void JniGlDisplayHandler::Core::SurfaceChanged(int width, int height) { |
136 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 141 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
137 renderer_.OnSurfaceChanged(width, height); | 142 renderer_->OnSurfaceChanged(width, height); |
138 } | 143 } |
139 | 144 |
140 void JniGlDisplayHandler::Core::SurfaceDestroyed() { | 145 void JniGlDisplayHandler::Core::SurfaceDestroyed() { |
141 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 146 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
142 DCHECK(egl_context_); | 147 DCHECK(egl_context_); |
143 DCHECK(window_); | 148 DCHECK(window_); |
144 renderer_.OnSurfaceDestroyed(); | 149 renderer_->OnSurfaceDestroyed(); |
145 egl_context_.reset(); | 150 egl_context_.reset(); |
146 ANativeWindow_release(window_); | 151 ANativeWindow_release(window_); |
147 window_ = nullptr; | 152 window_ = nullptr; |
148 } | 153 } |
149 | 154 |
150 void JniGlDisplayHandler::Core::SetTransformation( | 155 void JniGlDisplayHandler::Core::SetTransformation( |
151 const std::array<float, 9>& matrix) { | 156 const std::array<float, 9>& matrix) { |
152 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 157 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
153 renderer_.OnPixelTransformationChanged(matrix); | 158 renderer_->OnPixelTransformationChanged(matrix); |
154 } | 159 } |
155 | 160 |
156 void JniGlDisplayHandler::Core::MoveCursor(float x, float y) { | 161 void JniGlDisplayHandler::Core::MoveCursor(float x, float y) { |
157 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 162 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
158 renderer_.OnCursorMoved(x, y); | 163 renderer_->OnCursorMoved(x, y); |
159 } | 164 } |
160 | 165 |
161 void JniGlDisplayHandler::Core::SetCursorVisibility(bool visible) { | 166 void JniGlDisplayHandler::Core::SetCursorVisibility(bool visible) { |
162 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 167 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
163 renderer_.OnCursorVisibilityChanged(visible); | 168 renderer_->OnCursorVisibilityChanged(visible); |
164 } | 169 } |
165 | 170 |
166 void JniGlDisplayHandler::Core::StartInputFeedback(float x, | 171 void JniGlDisplayHandler::Core::StartInputFeedback(float x, |
167 float y, | 172 float y, |
168 float diameter) { | 173 float diameter) { |
169 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); | 174 DCHECK(runtime_->display_task_runner()->BelongsToCurrentThread()); |
170 renderer_.OnCursorInputFeedback(x, y, diameter); | 175 renderer_->OnCursorInputFeedback(x, y, diameter); |
171 } | 176 } |
172 | 177 |
173 base::WeakPtr<JniGlDisplayHandler::Core> | 178 base::WeakPtr<JniGlDisplayHandler::Core> |
174 JniGlDisplayHandler::Core::GetWeakPtr() { | 179 JniGlDisplayHandler::Core::GetWeakPtr() { |
175 return weak_ptr_; | 180 return weak_ptr_; |
176 } | 181 } |
177 | 182 |
178 // Shell implementations. | 183 // Shell implementations. |
179 | 184 |
180 JniGlDisplayHandler::JniGlDisplayHandler( | 185 JniGlDisplayHandler::JniGlDisplayHandler( |
(...skipping 110 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
291 java_display_); | 296 java_display_); |
292 } | 297 } |
293 | 298 |
294 void JniGlDisplayHandler::OnCanvasSizeChanged(int width, int height) { | 299 void JniGlDisplayHandler::OnCanvasSizeChanged(int width, int height) { |
295 DCHECK(runtime_->ui_task_runner()->BelongsToCurrentThread()); | 300 DCHECK(runtime_->ui_task_runner()->BelongsToCurrentThread()); |
296 Java_GlDisplay_changeCanvasSize(base::android::AttachCurrentThread(), | 301 Java_GlDisplay_changeCanvasSize(base::android::AttachCurrentThread(), |
297 java_display_, width, height); | 302 java_display_, width, height); |
298 } | 303 } |
299 | 304 |
300 } // namespace remoting | 305 } // namespace remoting |
OLD | NEW |