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/base/video_frame.h" |
12 #include "media/capture/webm_muxer.h" | 13 #include "media/capture/webm_muxer.h" |
13 #include "third_party/WebKit/public/platform/WebMediaRecorderHandlerClient.h" | 14 #include "third_party/WebKit/public/platform/WebMediaRecorderHandlerClient.h" |
14 #include "third_party/WebKit/public/platform/WebString.h" | 15 #include "third_party/WebKit/public/platform/WebString.h" |
15 | 16 |
16 namespace content { | 17 namespace content { |
17 | 18 |
18 MediaRecorderHandler::MediaRecorderHandler() | 19 MediaRecorderHandler::MediaRecorderHandler() |
19 : recording_(false), client_(nullptr), weak_factory_(this) { | 20 : recording_(false), client_(nullptr), weak_factory_(this) { |
20 DVLOG(3) << __FUNCTION__; | 21 DVLOG(3) << __FUNCTION__; |
21 } | 22 } |
(...skipping 31 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
53 bool MediaRecorderHandler::start() { | 54 bool MediaRecorderHandler::start() { |
54 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 55 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
55 DCHECK(!recording_); | 56 DCHECK(!recording_); |
56 return start(0); | 57 return start(0); |
57 } | 58 } |
58 | 59 |
59 bool MediaRecorderHandler::start(int timeslice) { | 60 bool MediaRecorderHandler::start(int timeslice) { |
60 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 61 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
61 DCHECK(!recording_); | 62 DCHECK(!recording_); |
62 DCHECK(!media_stream_.isNull()); | 63 DCHECK(!media_stream_.isNull()); |
| 64 DCHECK(!webm_muxer_); |
63 | 65 |
64 webm_muxer_.reset(new media::WebmMuxer(media::BindToCurrentLoop(base::Bind( | 66 webm_muxer_.reset(new media::WebmMuxer(base::Bind( |
65 &MediaRecorderHandler::WriteData, weak_factory_.GetWeakPtr())))); | 67 &MediaRecorderHandler::WriteData, weak_factory_.GetWeakPtr()))); |
66 DCHECK(webm_muxer_); | |
67 | 68 |
68 blink::WebVector<blink::WebMediaStreamTrack> video_tracks; | 69 blink::WebVector<blink::WebMediaStreamTrack> video_tracks; |
69 media_stream_.videoTracks(video_tracks); | 70 media_stream_.videoTracks(video_tracks); |
70 | 71 |
71 if (video_tracks.isEmpty()) { | 72 if (video_tracks.isEmpty()) { |
72 // TODO(mcasas): Add audio_tracks and update the code in this function | 73 // TODO(mcasas): Add audio_tracks and update the code in this function |
73 // correspondingly, see http://crbug.com/528519. As of now, only video | 74 // correspondingly, see http://crbug.com/528519. As of now, only video |
74 // tracks are supported. | 75 // tracks are supported. |
75 LOG(WARNING) << "Recording no video tracks is not implemented"; | 76 LOG(WARNING) << "Recording no video tracks is not implemented"; |
76 return false; | 77 return false; |
77 } | 78 } |
78 // TODO(mcasas): The muxer API supports only one video track. Extend it to | 79 // TODO(mcasas): The muxer API supports only one video track. Extend it to |
79 // several video tracks, see http://crbug.com/528523. | 80 // several video tracks, see http://crbug.com/528523. |
80 LOG_IF(WARNING, video_tracks.size() > 1u) << "Recording multiple video" | 81 LOG_IF(WARNING, video_tracks.size() > 1u) << "Recording multiple video" |
81 << " tracks is not implemented. Only recording first video track."; | 82 << " tracks is not implemented. Only recording first video track."; |
82 const blink::WebMediaStreamTrack& video_track = video_tracks[0]; | 83 const blink::WebMediaStreamTrack& video_track = video_tracks[0]; |
83 if (video_track.isNull()) | 84 if (video_track.isNull()) |
84 return false; | 85 return false; |
85 | 86 |
86 const VideoTrackRecorder::OnEncodedVideoCB on_encoded_video_cb = | 87 const VideoTrackRecorder::OnEncodedVideoCB on_encoded_video_cb = |
87 base::Bind(&media::WebmMuxer::OnEncodedVideo, | 88 media::BindToCurrentLoop(base::Bind(&MediaRecorderHandler::OnEncodedVideo, |
88 base::Unretained(webm_muxer_.get())); | 89 weak_factory_.GetWeakPtr())); |
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 webm_muxer_.reset(); |
104 } | 105 } |
105 | 106 |
106 void MediaRecorderHandler::pause() { | 107 void MediaRecorderHandler::pause() { |
107 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 108 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
108 DCHECK(recording_); | 109 DCHECK(recording_); |
109 recording_ = false; | 110 recording_ = false; |
110 NOTIMPLEMENTED(); | 111 NOTIMPLEMENTED(); |
111 } | 112 } |
112 | 113 |
113 void MediaRecorderHandler::resume() { | 114 void MediaRecorderHandler::resume() { |
114 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 115 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
115 DCHECK(!recording_); | 116 DCHECK(!recording_); |
116 recording_ = true; | 117 recording_ = true; |
117 NOTIMPLEMENTED(); | 118 NOTIMPLEMENTED(); |
118 } | 119 } |
119 | 120 |
120 void MediaRecorderHandler::WriteData(const base::StringPiece& data) { | 121 void MediaRecorderHandler::OnEncodedVideo( |
| 122 const scoped_refptr<media::VideoFrame>& video_frame, |
| 123 scoped_ptr<std::string> encoded_data, |
| 124 base::TimeTicks timestamp, |
| 125 bool is_key_frame) { |
121 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 126 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
122 client_->writeData(data.data(), data.size(), false /* lastInSlice */); | 127 if (webm_muxer_) { |
| 128 webm_muxer_->OnEncodedVideo(video_frame, encoded_data.Pass(), timestamp, |
| 129 is_key_frame); |
| 130 } |
| 131 } |
| 132 |
| 133 void MediaRecorderHandler::WriteData(base::StringPiece data) { |
| 134 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
| 135 client_->writeData(data.data(), data.length(), false /* lastInSlice */); |
123 } | 136 } |
124 | 137 |
125 void MediaRecorderHandler::OnVideoFrameForTesting( | 138 void MediaRecorderHandler::OnVideoFrameForTesting( |
126 const scoped_refptr<media::VideoFrame>& frame, | 139 const scoped_refptr<media::VideoFrame>& frame, |
127 const base::TimeTicks& timestamp) { | 140 const base::TimeTicks& timestamp) { |
128 for (auto* recorder : video_recorders_) | 141 for (auto* recorder : video_recorders_) |
129 recorder->OnVideoFrameForTesting(frame, timestamp); | 142 recorder->OnVideoFrameForTesting(frame, timestamp); |
130 } | 143 } |
131 | 144 |
132 } // namespace content | 145 } // namespace content |
OLD | NEW |