OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/renderer/media/media_recorder_handler.h" | 5 #include "content/renderer/media/media_recorder_handler.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/location.h" | 8 #include "base/location.h" |
9 #include "base/logging.h" | 9 #include "base/logging.h" |
10 #include "content/renderer/media/video_track_recorder.h" | 10 #include "content/renderer/media/video_track_recorder.h" |
11 #include "media/base/bind_to_current_loop.h" | 11 #include "media/base/bind_to_current_loop.h" |
12 #include "media/capture/webm_muxer.h" | 12 #include "media/capture/webm_muxer.h" |
13 #include "third_party/WebKit/public/platform/WebMediaRecorderHandlerClient.h" | 13 #include "third_party/WebKit/public/platform/WebMediaRecorderHandlerClient.h" |
14 #include "third_party/WebKit/public/platform/WebString.h" | 14 #include "third_party/WebKit/public/platform/WebString.h" |
15 | 15 |
16 namespace content { | 16 namespace content { |
17 | 17 |
18 MediaRecorderHandler::MediaRecorderHandler() | 18 MediaRecorderHandler::MediaRecorderHandler() |
19 : recording_(false), client_(nullptr), weak_factory_(this) { | 19 : recording_(false), client_(nullptr), weak_factory_(this) { |
20 DVLOG(3) << __FUNCTION__; | 20 DVLOG(3) << __FUNCTION__; |
| 21 webm_muxer_ = make_scoped_refptr( |
| 22 new media::WebmMuxer(base::MessageLoop::current()->task_runner(), |
| 23 media::BindToCurrentLoop( |
| 24 base::Bind(&MediaRecorderHandler::WriteData, |
| 25 weak_factory_.GetWeakPtr())))); |
21 } | 26 } |
22 | 27 |
23 MediaRecorderHandler::~MediaRecorderHandler() { | 28 MediaRecorderHandler::~MediaRecorderHandler() { |
24 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 29 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
25 // Send a |last_in_slice| to our |client_|. | 30 // Send a |last_in_slice| to our |client_|. |
26 if (client_) | 31 if (client_) |
27 client_->writeData(nullptr, 0u, true); | 32 client_->writeData(nullptr, 0u, true); |
28 } | 33 } |
29 | 34 |
30 bool MediaRecorderHandler::canSupportMimeType( | 35 bool MediaRecorderHandler::canSupportMimeType( |
(...skipping 22 matching lines...) Expand all Loading... |
53 bool MediaRecorderHandler::start() { | 58 bool MediaRecorderHandler::start() { |
54 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 59 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
55 DCHECK(!recording_); | 60 DCHECK(!recording_); |
56 return start(0); | 61 return start(0); |
57 } | 62 } |
58 | 63 |
59 bool MediaRecorderHandler::start(int timeslice) { | 64 bool MediaRecorderHandler::start(int timeslice) { |
60 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 65 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
61 DCHECK(!recording_); | 66 DCHECK(!recording_); |
62 DCHECK(!media_stream_.isNull()); | 67 DCHECK(!media_stream_.isNull()); |
63 | |
64 webm_muxer_.reset(new media::WebmMuxer(media::BindToCurrentLoop(base::Bind( | |
65 &MediaRecorderHandler::WriteData, weak_factory_.GetWeakPtr())))); | |
66 DCHECK(webm_muxer_); | 68 DCHECK(webm_muxer_); |
67 | 69 |
68 blink::WebVector<blink::WebMediaStreamTrack> video_tracks; | 70 blink::WebVector<blink::WebMediaStreamTrack> video_tracks; |
69 media_stream_.videoTracks(video_tracks); | 71 media_stream_.videoTracks(video_tracks); |
70 | 72 |
71 if (video_tracks.isEmpty()) { | 73 if (video_tracks.isEmpty()) { |
72 // TODO(mcasas): Add audio_tracks and update the code in this function | 74 // TODO(mcasas): Add audio_tracks and update the code in this function |
73 // correspondingly, see http://crbug.com/528519. As of now, only video | 75 // correspondingly, see http://crbug.com/528519. As of now, only video |
74 // tracks are supported. | 76 // tracks are supported. |
75 LOG(WARNING) << "Recording no video tracks is not implemented"; | 77 LOG(WARNING) << "Recording no video tracks is not implemented"; |
76 return false; | 78 return false; |
77 } | 79 } |
78 // TODO(mcasas): The muxer API supports only one video track. Extend it to | 80 // TODO(mcasas): The muxer API supports only one video track. Extend it to |
79 // several video tracks, see http://crbug.com/528523. | 81 // several video tracks, see http://crbug.com/528523. |
80 LOG_IF(WARNING, video_tracks.size() > 1u) << "Recording multiple video" | 82 LOG_IF(WARNING, video_tracks.size() > 1u) << "Recording multiple video" |
81 << " tracks is not implemented. Only recording first video track."; | 83 << " tracks is not implemented. Only recording first video track."; |
82 const blink::WebMediaStreamTrack& video_track = video_tracks[0]; | 84 const blink::WebMediaStreamTrack& video_track = video_tracks[0]; |
83 if (video_track.isNull()) | 85 if (video_track.isNull()) |
84 return false; | 86 return false; |
85 | 87 |
86 const VideoTrackRecorder::OnEncodedVideoCB on_encoded_video_cb = | 88 const VideoTrackRecorder::OnEncodedVideoCB on_encoded_video_cb = |
87 base::Bind(&media::WebmMuxer::OnEncodedVideo, | 89 base::Bind(&media::WebmMuxer::OnEncodedVideo, webm_muxer_); |
88 base::Unretained(webm_muxer_.get())); | |
89 | 90 |
90 video_recorders_.push_back(new VideoTrackRecorder(video_track, | 91 video_recorders_.push_back(new VideoTrackRecorder(video_track, |
91 on_encoded_video_cb)); | 92 on_encoded_video_cb)); |
92 | 93 |
93 recording_ = true; | 94 recording_ = true; |
94 return true; | 95 return true; |
95 } | 96 } |
96 | 97 |
97 void MediaRecorderHandler::stop() { | 98 void MediaRecorderHandler::stop() { |
98 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 99 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
99 DCHECK(recording_); | 100 DCHECK(recording_); |
100 | 101 |
101 recording_ = false; | 102 recording_ = false; |
102 video_recorders_.clear(); | 103 video_recorders_.clear(); |
103 webm_muxer_.reset(NULL); | |
104 } | 104 } |
105 | 105 |
106 void MediaRecorderHandler::pause() { | 106 void MediaRecorderHandler::pause() { |
107 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 107 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
108 DCHECK(recording_); | 108 DCHECK(recording_); |
109 recording_ = false; | 109 recording_ = false; |
110 NOTIMPLEMENTED(); | 110 NOTIMPLEMENTED(); |
111 } | 111 } |
112 | 112 |
113 void MediaRecorderHandler::resume() { | 113 void MediaRecorderHandler::resume() { |
114 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 114 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
115 DCHECK(!recording_); | 115 DCHECK(!recording_); |
116 recording_ = true; | 116 recording_ = true; |
117 NOTIMPLEMENTED(); | 117 NOTIMPLEMENTED(); |
118 } | 118 } |
119 | 119 |
120 void MediaRecorderHandler::WriteData(const base::StringPiece& data) { | 120 void MediaRecorderHandler::WriteData(const base::StringPiece& data) { |
121 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 121 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
122 client_->writeData(data.data(), data.size(), false /* lastInSlice */); | 122 client_->writeData(data.data(), data.size(), false /* lastInSlice */); |
123 } | 123 } |
124 | 124 |
125 void MediaRecorderHandler::OnVideoFrameForTesting( | 125 void MediaRecorderHandler::OnVideoFrameForTesting( |
126 const scoped_refptr<media::VideoFrame>& frame, | 126 const scoped_refptr<media::VideoFrame>& frame, |
127 const base::TimeTicks& timestamp) { | 127 const base::TimeTicks& timestamp) { |
128 for (auto* recorder : video_recorders_) | 128 for (auto* recorder : video_recorders_) |
129 recorder->OnVideoFrameForTesting(frame, timestamp); | 129 recorder->OnVideoFrameForTesting(frame, timestamp); |
130 } | 130 } |
131 | 131 |
132 } // namespace content | 132 } // namespace content |
OLD | NEW |