OLD | NEW |
| (Empty) |
1 // Copyright (c) 2010 The Chromium Authors. All rights reserved. | |
2 // Use of this source code is governed by a BSD-style license that can be | |
3 // found in the LICENSE file. | |
4 | |
5 #include "chrome/renderer/media/ipc_video_renderer.h" | |
6 | |
7 #include "chrome/common/render_messages.h" | |
8 #include "chrome/renderer/render_thread.h" | |
9 #include "media/base/video_frame.h" | |
10 #include "media/base/media_format.h" | |
11 | |
12 IPCVideoRenderer::IPCVideoRenderer(int routing_id) | |
13 : created_(false), | |
14 routing_id_(routing_id), | |
15 stopped_(false, false) { | |
16 } | |
17 | |
18 IPCVideoRenderer::~IPCVideoRenderer() { | |
19 } | |
20 | |
21 bool IPCVideoRenderer::OnInitialize(media::VideoDecoder* decoder) { | |
22 video_size_.SetSize(width(), height()); | |
23 | |
24 // TODO(scherkus): we're assuming YV12 here. | |
25 size_t size = (width() * height()) + ((width() * height()) >> 1); | |
26 uint32 epoch = static_cast<uint32>(reinterpret_cast<size_t>(this)); | |
27 transport_dib_.reset(TransportDIB::Create(size, epoch)); | |
28 CHECK(transport_dib_.get()); | |
29 | |
30 return true; | |
31 } | |
32 | |
33 void IPCVideoRenderer::OnStop(media::FilterCallback* callback) { | |
34 stopped_.Signal(); | |
35 | |
36 proxy_->message_loop()->PostTask(FROM_HERE, | |
37 NewRunnableMethod(this, &IPCVideoRenderer::DoDestroyVideo, callback)); | |
38 } | |
39 | |
40 void IPCVideoRenderer::OnFrameAvailable() { | |
41 proxy_->message_loop()->PostTask(FROM_HERE, | |
42 NewRunnableMethod(this, &IPCVideoRenderer::DoUpdateVideo)); | |
43 } | |
44 | |
45 void IPCVideoRenderer::SetWebMediaPlayerImplProxy( | |
46 webkit_glue::WebMediaPlayerImpl::Proxy* proxy) { | |
47 proxy_ = proxy; | |
48 } | |
49 | |
50 void IPCVideoRenderer::SetRect(const gfx::Rect& rect) { | |
51 DCHECK(MessageLoop::current() == proxy_->message_loop()); | |
52 | |
53 // TODO(scherkus): this is actually a SetSize() call... there's a pending | |
54 // WebKit bug to get this fixed up. It would be nice if this was a real | |
55 // SetRect() call so we could get the absolute coordinates instead of relying | |
56 // on Paint(). | |
57 } | |
58 | |
59 void IPCVideoRenderer::Paint(skia::PlatformCanvas* canvas, | |
60 const gfx::Rect& dest_rect) { | |
61 DCHECK(MessageLoop::current() == proxy_->message_loop()); | |
62 | |
63 // Copy the rect for UpdateVideo messages. | |
64 video_rect_ = dest_rect; | |
65 | |
66 if (!created_) { | |
67 created_ = true; | |
68 Send(new ViewHostMsg_CreateVideo(routing_id_, video_size_)); | |
69 | |
70 // Force an update in case the first frame arrived before the first | |
71 // Paint() call. | |
72 DoUpdateVideo(); | |
73 } | |
74 | |
75 // TODO(scherkus): code to punch a hole through the backing store goes here. | |
76 // We don't need it right away since we don't do a proper alpha composite | |
77 // between the browser BackingStore and VideoLayer. | |
78 } | |
79 | |
80 void IPCVideoRenderer::Send(IPC::Message* msg) { | |
81 DCHECK(routing_id_ != MSG_ROUTING_NONE); | |
82 DCHECK(routing_id_ == msg->routing_id()); | |
83 | |
84 bool result = RenderThread::current()->Send(msg); | |
85 LOG_IF(ERROR, !result) << "RenderThread::current()->Send(msg) failed"; | |
86 } | |
87 | |
88 void IPCVideoRenderer::DoUpdateVideo() { | |
89 DCHECK(MessageLoop::current() == proxy_->message_loop()); | |
90 | |
91 // Nothing to do if we don't know where we are positioned on the page. | |
92 if (!created_ || video_rect_.IsEmpty() || stopped_.IsSignaled()) { | |
93 return; | |
94 } | |
95 | |
96 scoped_refptr<media::VideoFrame> frame; | |
97 GetCurrentFrame(&frame); | |
98 if (!frame) { | |
99 PutCurrentFrame(frame); | |
100 return; | |
101 } | |
102 | |
103 CHECK(frame->width() == static_cast<size_t>(video_size_.width())); | |
104 CHECK(frame->height() == static_cast<size_t>(video_size_.height())); | |
105 CHECK(frame->format() == media::VideoFrame::YV12); | |
106 CHECK(frame->planes() == 3); | |
107 | |
108 uint8* dest = reinterpret_cast<uint8*>(transport_dib_->memory()); | |
109 | |
110 // Copy Y plane. | |
111 const uint8* src = frame->data(media::VideoFrame::kYPlane); | |
112 size_t stride = frame->stride(media::VideoFrame::kYPlane); | |
113 for (size_t row = 0; row < frame->height(); ++row) { | |
114 memcpy(dest, src, frame->width()); | |
115 dest += frame->width(); | |
116 src += stride; | |
117 } | |
118 | |
119 // Copy U plane. | |
120 src = frame->data(media::VideoFrame::kUPlane); | |
121 stride = frame->stride(media::VideoFrame::kUPlane); | |
122 for (size_t row = 0; row < frame->height() / 2; ++row) { | |
123 memcpy(dest, src, frame->width() / 2); | |
124 dest += frame->width() / 2; | |
125 src += stride; | |
126 } | |
127 | |
128 // Copy V plane. | |
129 src = frame->data(media::VideoFrame::kVPlane); | |
130 stride = frame->stride(media::VideoFrame::kVPlane); | |
131 for (size_t row = 0; row < frame->height() / 2; ++row) { | |
132 memcpy(dest, src, frame->width() / 2); | |
133 dest += frame->width() / 2; | |
134 src += stride; | |
135 } | |
136 | |
137 PutCurrentFrame(frame); | |
138 | |
139 // Sanity check! | |
140 uint8* expected = reinterpret_cast<uint8*>(transport_dib_->memory()) + | |
141 transport_dib_->size(); | |
142 CHECK(dest == expected); | |
143 | |
144 Send(new ViewHostMsg_UpdateVideo(routing_id_, | |
145 transport_dib_->id(), | |
146 video_rect_)); | |
147 } | |
148 | |
149 void IPCVideoRenderer::DoDestroyVideo(media::FilterCallback* callback) { | |
150 DCHECK(MessageLoop::current() == proxy_->message_loop()); | |
151 | |
152 // We shouldn't receive any more messages after the browser receives this. | |
153 Send(new ViewHostMsg_DestroyVideo(routing_id_)); | |
154 | |
155 // Detach ourselves from the proxy. | |
156 proxy_->SetVideoRenderer(NULL); | |
157 proxy_ = NULL; | |
158 if (callback) { | |
159 callback->Run(); | |
160 delete callback; | |
161 } | |
162 } | |
OLD | NEW |