OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 "content/common/gpu/client/gpu_video_encode_accelerator_host.h" | 5 #include "content/common/gpu/client/gpu_video_encode_accelerator_host.h" |
6 | 6 |
7 #include "base/logging.h" | 7 #include "base/logging.h" |
8 #include "base/message_loop/message_loop_proxy.h" | 8 #include "base/message_loop/message_loop_proxy.h" |
9 #include "content/common/gpu/client/gpu_channel_host.h" | 9 #include "content/common/gpu/client/gpu_channel_host.h" |
10 #include "content/common/gpu/gpu_messages.h" | 10 #include "content/common/gpu/gpu_messages.h" |
11 #include "content/common/gpu/media/gpu_video_encode_accelerator.h" | 11 #include "content/common/gpu/media/gpu_video_encode_accelerator.h" |
12 #include "media/base/video_frame.h" | 12 #include "media/base/video_frame.h" |
13 | 13 |
14 namespace content { | 14 namespace content { |
15 | 15 |
16 #define NOTIFY_ERROR(error) \ | 16 #define NOTIFY_ERROR(error) \ |
17 PostNotifyError(error); \ | 17 PostNotifyError(error); \ |
18 DLOG(ERROR) | 18 DLOG(ERROR) |
19 | 19 |
20 GpuVideoEncodeAcceleratorHost::GpuVideoEncodeAcceleratorHost( | 20 GpuVideoEncodeAcceleratorHost::GpuVideoEncodeAcceleratorHost( |
21 GpuChannelHost* channel, | 21 GpuChannelHost* channel, |
22 CommandBufferProxyImpl* impl) | 22 CommandBufferProxyImpl* impl) |
23 : channel_(channel), | 23 : channel_(channel), |
24 encoder_route_id_(MSG_ROUTING_NONE), | 24 encoder_route_id_(MSG_ROUTING_NONE), |
25 client_(NULL), | 25 client_(nullptr), |
26 impl_(impl), | 26 impl_(impl), |
27 next_frame_id_(0), | 27 next_frame_id_(0), |
28 weak_this_factory_(this) { | 28 weak_this_factory_(this) { |
29 DCHECK(channel_); | 29 DCHECK(channel_); |
30 DCHECK(impl_); | 30 DCHECK(impl_); |
31 impl_->AddDeletionObserver(this); | 31 impl_->AddDeletionObserver(this); |
32 } | 32 } |
33 | 33 |
34 GpuVideoEncodeAcceleratorHost::~GpuVideoEncodeAcceleratorHost() { | 34 GpuVideoEncodeAcceleratorHost::~GpuVideoEncodeAcceleratorHost() { |
35 DCHECK(CalledOnValidThread()); | 35 DCHECK(CalledOnValidThread()); |
(...skipping 21 matching lines...) Expand all Loading... |
57 // See OnNotifyError for why |this| mustn't be used after OnNotifyError might | 57 // See OnNotifyError for why |this| mustn't be used after OnNotifyError might |
58 // have been called above. | 58 // have been called above. |
59 return handled; | 59 return handled; |
60 } | 60 } |
61 | 61 |
62 void GpuVideoEncodeAcceleratorHost::OnChannelError() { | 62 void GpuVideoEncodeAcceleratorHost::OnChannelError() { |
63 DCHECK(CalledOnValidThread()); | 63 DCHECK(CalledOnValidThread()); |
64 if (channel_) { | 64 if (channel_) { |
65 if (encoder_route_id_ != MSG_ROUTING_NONE) | 65 if (encoder_route_id_ != MSG_ROUTING_NONE) |
66 channel_->RemoveRoute(encoder_route_id_); | 66 channel_->RemoveRoute(encoder_route_id_); |
67 channel_ = NULL; | 67 channel_ = nullptr; |
68 } | 68 } |
69 NOTIFY_ERROR(kPlatformFailureError) << "OnChannelError()"; | 69 NOTIFY_ERROR(kPlatformFailureError) << "OnChannelError()"; |
70 } | 70 } |
71 | 71 |
72 std::vector<media::VideoEncodeAccelerator::SupportedProfile> | 72 std::vector<media::VideoEncodeAccelerator::SupportedProfile> |
73 GpuVideoEncodeAcceleratorHost::GetSupportedProfiles() { | 73 GpuVideoEncodeAcceleratorHost::GetSupportedProfiles() { |
74 DCHECK(CalledOnValidThread()); | 74 DCHECK(CalledOnValidThread()); |
75 if (!channel_) | 75 if (!channel_) |
76 return std::vector<media::VideoEncodeAccelerator::SupportedProfile>(); | 76 return std::vector<media::VideoEncodeAccelerator::SupportedProfile>(); |
77 return channel_->gpu_info().video_encode_accelerator_supported_profiles; | 77 return channel_->gpu_info().video_encode_accelerator_supported_profiles; |
(...skipping 97 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
175 return; | 175 return; |
176 | 176 |
177 Send(new AcceleratedVideoEncoderMsg_RequestEncodingParametersChange( | 177 Send(new AcceleratedVideoEncoderMsg_RequestEncodingParametersChange( |
178 encoder_route_id_, bitrate, framerate)); | 178 encoder_route_id_, bitrate, framerate)); |
179 } | 179 } |
180 | 180 |
181 void GpuVideoEncodeAcceleratorHost::Destroy() { | 181 void GpuVideoEncodeAcceleratorHost::Destroy() { |
182 DCHECK(CalledOnValidThread()); | 182 DCHECK(CalledOnValidThread()); |
183 if (channel_) | 183 if (channel_) |
184 Send(new AcceleratedVideoEncoderMsg_Destroy(encoder_route_id_)); | 184 Send(new AcceleratedVideoEncoderMsg_Destroy(encoder_route_id_)); |
185 client_ = NULL; | 185 client_ = nullptr; |
186 delete this; | 186 delete this; |
187 } | 187 } |
188 | 188 |
189 void GpuVideoEncodeAcceleratorHost::OnWillDeleteImpl() { | 189 void GpuVideoEncodeAcceleratorHost::OnWillDeleteImpl() { |
190 DCHECK(CalledOnValidThread()); | 190 DCHECK(CalledOnValidThread()); |
191 impl_ = NULL; | 191 impl_ = nullptr; |
192 | 192 |
193 // The CommandBufferProxyImpl is going away; error out this VEA. | 193 // The CommandBufferProxyImpl is going away; error out this VEA. |
194 OnChannelError(); | 194 OnChannelError(); |
195 } | 195 } |
196 | 196 |
197 void GpuVideoEncodeAcceleratorHost::PostNotifyError(Error error) { | 197 void GpuVideoEncodeAcceleratorHost::PostNotifyError(Error error) { |
198 DCHECK(CalledOnValidThread()); | 198 DCHECK(CalledOnValidThread()); |
199 DVLOG(2) << "PostNotifyError(): error=" << error; | 199 DVLOG(2) << "PostNotifyError(): error=" << error; |
200 // Post the error notification back to this thread, to avoid re-entrancy. | 200 // Post the error notification back to this thread, to avoid re-entrancy. |
201 base::MessageLoopProxy::current()->PostTask( | 201 base::MessageLoopProxy::current()->PostTask( |
(...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
238 // theoretical" - Android's std::hash_map crashes if we don't do this. | 238 // theoretical" - Android's std::hash_map crashes if we don't do this. |
239 scoped_refptr<media::VideoFrame> frame = frame_map_[frame_id]; | 239 scoped_refptr<media::VideoFrame> frame = frame_map_[frame_id]; |
240 if (!frame_map_.erase(frame_id)) { | 240 if (!frame_map_.erase(frame_id)) { |
241 DLOG(ERROR) << "OnNotifyInputDone(): " | 241 DLOG(ERROR) << "OnNotifyInputDone(): " |
242 "invalid frame_id=" << frame_id; | 242 "invalid frame_id=" << frame_id; |
243 // See OnNotifyError for why this needs to be the last thing in this | 243 // See OnNotifyError for why this needs to be the last thing in this |
244 // function. | 244 // function. |
245 OnNotifyError(kPlatformFailureError); | 245 OnNotifyError(kPlatformFailureError); |
246 return; | 246 return; |
247 } | 247 } |
248 frame = NULL; // Not necessary but nice to be explicit; see fun-fact above. | 248 frame = nullptr; // Not necessary but nice to be explicit; see fun-fact above. |
249 } | 249 } |
250 | 250 |
251 void GpuVideoEncodeAcceleratorHost::OnBitstreamBufferReady( | 251 void GpuVideoEncodeAcceleratorHost::OnBitstreamBufferReady( |
252 int32 bitstream_buffer_id, | 252 int32 bitstream_buffer_id, |
253 uint32 payload_size, | 253 uint32 payload_size, |
254 bool key_frame) { | 254 bool key_frame) { |
255 DCHECK(CalledOnValidThread()); | 255 DCHECK(CalledOnValidThread()); |
256 DVLOG(3) << "OnBitstreamBufferReady(): " | 256 DVLOG(3) << "OnBitstreamBufferReady(): " |
257 "bitstream_buffer_id=" << bitstream_buffer_id | 257 "bitstream_buffer_id=" << bitstream_buffer_id |
258 << ", payload_size=" << payload_size | 258 << ", payload_size=" << payload_size |
259 << ", key_frame=" << key_frame; | 259 << ", key_frame=" << key_frame; |
260 if (client_) | 260 if (client_) |
261 client_->BitstreamBufferReady(bitstream_buffer_id, payload_size, key_frame); | 261 client_->BitstreamBufferReady(bitstream_buffer_id, payload_size, key_frame); |
262 } | 262 } |
263 | 263 |
264 void GpuVideoEncodeAcceleratorHost::OnNotifyError(Error error) { | 264 void GpuVideoEncodeAcceleratorHost::OnNotifyError(Error error) { |
265 DCHECK(CalledOnValidThread()); | 265 DCHECK(CalledOnValidThread()); |
266 DVLOG(2) << "OnNotifyError(): error=" << error; | 266 DVLOG(2) << "OnNotifyError(): error=" << error; |
267 if (!client_) | 267 if (!client_) |
268 return; | 268 return; |
269 weak_this_factory_.InvalidateWeakPtrs(); | 269 weak_this_factory_.InvalidateWeakPtrs(); |
270 | 270 |
271 // Client::NotifyError() may Destroy() |this|, so calling it needs to be the | 271 // Client::NotifyError() may Destroy() |this|, so calling it needs to be the |
272 // last thing done on this stack! | 272 // last thing done on this stack! |
273 media::VideoEncodeAccelerator::Client* client = NULL; | 273 media::VideoEncodeAccelerator::Client* client = nullptr; |
274 std::swap(client_, client); | 274 std::swap(client_, client); |
275 client->NotifyError(error); | 275 client->NotifyError(error); |
276 } | 276 } |
277 | 277 |
278 } // namespace content | 278 } // namespace content |
OLD | NEW |