1 // Copyright (c) 2011 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 "media/video/capture/video_capture_proxy.h"
6
7 #include "base/bind.h"
8 #include "base/location.h"
9 #include "base/message_loop/message_loop_proxy.h"
10 #include "media/base/video_frame.h"
11
12 namespace {
13
14 // Called on VC thread: extracts the state out of the VideoCapture, and
15 // serialize it into a VideoCaptureState.
GetState(media::VideoCapture * capture)16 media::VideoCaptureHandlerProxy::VideoCaptureState GetState(
17 media::VideoCapture* capture) {
18 media::VideoCaptureHandlerProxy::VideoCaptureState state;
19 state.started = capture->CaptureStarted();
20 state.frame_rate = capture->CaptureFrameRate();
21 return state;
22 }
23
24 } // anonymous namespace
25
26 namespace media {
27
VideoCaptureHandlerProxy(VideoCapture::EventHandler * proxied,scoped_refptr<base::MessageLoopProxy> main_message_loop)28 VideoCaptureHandlerProxy::VideoCaptureHandlerProxy(
29 VideoCapture::EventHandler* proxied,
30 scoped_refptr<base::MessageLoopProxy> main_message_loop)
31 : proxied_(proxied),
32 main_message_loop_(main_message_loop) {
33 }
34
~VideoCaptureHandlerProxy()35 VideoCaptureHandlerProxy::~VideoCaptureHandlerProxy() {
36 }
37
OnStarted(VideoCapture * capture)38 void VideoCaptureHandlerProxy::OnStarted(VideoCapture* capture) {
39 main_message_loop_->PostTask(FROM_HERE, base::Bind(
40 &VideoCaptureHandlerProxy::OnStartedOnMainThread,
41 base::Unretained(this),
42 capture,
43 GetState(capture)));
44 }
45
OnStopped(VideoCapture * capture)46 void VideoCaptureHandlerProxy::OnStopped(VideoCapture* capture) {
47 main_message_loop_->PostTask(FROM_HERE, base::Bind(
48 &VideoCaptureHandlerProxy::OnStoppedOnMainThread,
49 base::Unretained(this),
50 capture,
51 GetState(capture)));
52 }
53
OnPaused(VideoCapture * capture)54 void VideoCaptureHandlerProxy::OnPaused(VideoCapture* capture) {
55 main_message_loop_->PostTask(FROM_HERE, base::Bind(
56 &VideoCaptureHandlerProxy::OnPausedOnMainThread,
57 base::Unretained(this),
58 capture,
59 GetState(capture)));
60 }
61
OnError(VideoCapture * capture,int error_code)62 void VideoCaptureHandlerProxy::OnError(VideoCapture* capture, int error_code) {
63 main_message_loop_->PostTask(FROM_HERE, base::Bind(
64 &VideoCaptureHandlerProxy::OnErrorOnMainThread,
65 base::Unretained(this),
66 capture,
67 GetState(capture),
68 error_code));
69 }
70
OnRemoved(VideoCapture * capture)71 void VideoCaptureHandlerProxy::OnRemoved(VideoCapture* capture) {
72 main_message_loop_->PostTask(FROM_HERE, base::Bind(
73 &VideoCaptureHandlerProxy::OnRemovedOnMainThread,
74 base::Unretained(this),
75 capture,
76 GetState(capture)));
77 }
78
OnFrameReady(VideoCapture * capture,const scoped_refptr<VideoFrame> & frame)79 void VideoCaptureHandlerProxy::OnFrameReady(
80 VideoCapture* capture,
81 const scoped_refptr<VideoFrame>& frame) {
82 main_message_loop_->PostTask(
83 FROM_HERE,
84 base::Bind(&VideoCaptureHandlerProxy::OnFrameReadyOnMainThread,
85 base::Unretained(this),
86 capture,
87 GetState(capture),
88 frame));
89 }
90
OnStartedOnMainThread(VideoCapture * capture,const VideoCaptureState & state)91 void VideoCaptureHandlerProxy::OnStartedOnMainThread(
92 VideoCapture* capture,
93 const VideoCaptureState& state) {
94 state_ = state;
95 proxied_->OnStarted(capture);
96 }
97
OnStoppedOnMainThread(VideoCapture * capture,const VideoCaptureState & state)98 void VideoCaptureHandlerProxy::OnStoppedOnMainThread(
99 VideoCapture* capture,
100 const VideoCaptureState& state) {
101 state_ = state;
102 proxied_->OnStopped(capture);
103 }
104
OnPausedOnMainThread(VideoCapture * capture,const VideoCaptureState & state)105 void VideoCaptureHandlerProxy::OnPausedOnMainThread(
106 VideoCapture* capture,
107 const VideoCaptureState& state) {
108 state_ = state;
109 proxied_->OnPaused(capture);
110 }
111
OnErrorOnMainThread(VideoCapture * capture,const VideoCaptureState & state,int error_code)112 void VideoCaptureHandlerProxy::OnErrorOnMainThread(
113 VideoCapture* capture,
114 const VideoCaptureState& state,
115 int error_code) {
116 state_ = state;
117 proxied_->OnError(capture, error_code);
118 }
119
OnRemovedOnMainThread(VideoCapture * capture,const VideoCaptureState & state)120 void VideoCaptureHandlerProxy::OnRemovedOnMainThread(
121 VideoCapture* capture,
122 const VideoCaptureState& state) {
123 state_ = state;
124 proxied_->OnRemoved(capture);
125 }
126
OnFrameReadyOnMainThread(VideoCapture * capture,const VideoCaptureState & state,const scoped_refptr<VideoFrame> & frame)127 void VideoCaptureHandlerProxy::OnFrameReadyOnMainThread(
128 VideoCapture* capture,
129 const VideoCaptureState& state,
130 const scoped_refptr<VideoFrame>& frame) {
131 state_ = state;
132 proxied_->OnFrameReady(capture, frame);
133 }
134
135 } // namespace media
136