| 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" |
| (...skipping 58 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 69 blink::WebVector<blink::WebMediaStreamTrack> video_tracks; | 69 blink::WebVector<blink::WebMediaStreamTrack> video_tracks; |
| 70 media_stream_.videoTracks(video_tracks); | 70 media_stream_.videoTracks(video_tracks); |
| 71 | 71 |
| 72 if (video_tracks.isEmpty()) { | 72 if (video_tracks.isEmpty()) { |
| 73 // 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 |
| 74 // correspondingly, see http://crbug.com/528519. As of now, only video | 74 // correspondingly, see http://crbug.com/528519. As of now, only video |
| 75 // tracks are supported. | 75 // tracks are supported. |
| 76 LOG(WARNING) << "Recording no video tracks is not implemented"; | 76 LOG(WARNING) << "Recording no video tracks is not implemented"; |
| 77 return false; | 77 return false; |
| 78 } | 78 } |
| 79 // TODO(mcasas): The muxer API supports only one video track. Extend it to | |
| 80 // several video tracks, see http://crbug.com/528523. | |
| 81 LOG_IF(WARNING, video_tracks.size() > 1u) << "Recording multiple video" | |
| 82 << " tracks is not implemented. Only recording first video track."; | |
| 83 const blink::WebMediaStreamTrack& video_track = video_tracks[0]; | |
| 84 if (video_track.isNull()) | |
| 85 return false; | |
| 86 | 79 |
| 87 const VideoTrackRecorder::OnEncodedVideoCB on_encoded_video_cb = | 80 for (const blink::WebMediaStreamTrack& video_track : video_tracks) { |
| 88 media::BindToCurrentLoop(base::Bind(&MediaRecorderHandler::OnEncodedVideo, | 81 if (video_track.isNull()) { |
| 89 weak_factory_.GetWeakPtr())); | 82 LOG(WARNING) << "|video_track| is null"; |
| 83 continue; |
| 84 } |
| 90 | 85 |
| 91 video_recorders_.push_back(new VideoTrackRecorder(video_track, | 86 const VideoTrackRecorder::OnEncodedVideoCB on_encoded_video_cb = |
| 92 on_encoded_video_cb)); | 87 media::BindToCurrentLoop(webm_muxer_->GenerateOnEncodedVideoCallback()); |
| 88 video_recorders_.push_back( |
| 89 new VideoTrackRecorder(video_track, on_encoded_video_cb)); |
| 90 recording_ = true; |
| 91 } |
| 93 | 92 |
| 94 recording_ = true; | |
| 95 return true; | 93 return true; |
| 96 } | 94 } |
| 97 | 95 |
| 98 void MediaRecorderHandler::stop() { | 96 void MediaRecorderHandler::stop() { |
| 99 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 97 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
| 100 DCHECK(recording_); | 98 DCHECK(recording_); |
| 101 | 99 |
| 102 recording_ = false; | 100 recording_ = false; |
| 103 video_recorders_.clear(); | 101 video_recorders_.clear(); |
| 104 webm_muxer_.reset(); | 102 webm_muxer_.reset(); |
| 105 } | 103 } |
| 106 | 104 |
| 107 void MediaRecorderHandler::pause() { | 105 void MediaRecorderHandler::pause() { |
| 108 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 106 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
| 109 DCHECK(recording_); | 107 DCHECK(recording_); |
| 110 recording_ = false; | 108 recording_ = false; |
| 111 NOTIMPLEMENTED(); | 109 NOTIMPLEMENTED(); |
| 112 } | 110 } |
| 113 | 111 |
| 114 void MediaRecorderHandler::resume() { | 112 void MediaRecorderHandler::resume() { |
| 115 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 113 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
| 116 DCHECK(!recording_); | 114 DCHECK(!recording_); |
| 117 recording_ = true; | 115 recording_ = true; |
| 118 NOTIMPLEMENTED(); | 116 NOTIMPLEMENTED(); |
| 119 } | 117 } |
| 120 | 118 |
| 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) { | |
| 126 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | |
| 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) { | 119 void MediaRecorderHandler::WriteData(base::StringPiece data) { |
| 134 DCHECK(main_render_thread_checker_.CalledOnValidThread()); | 120 DCHECK(main_render_thread_checker_.CalledOnValidThread()); |
| 135 client_->writeData(data.data(), data.length(), false /* lastInSlice */); | 121 client_->writeData(data.data(), data.length(), false /* lastInSlice */); |
| 136 } | 122 } |
| 137 | 123 |
| 138 void MediaRecorderHandler::OnVideoFrameForTesting( | 124 void MediaRecorderHandler::OnVideoFrameForTesting( |
| 139 const scoped_refptr<media::VideoFrame>& frame, | 125 const scoped_refptr<media::VideoFrame>& frame, |
| 140 const base::TimeTicks& timestamp) { | 126 const base::TimeTicks& timestamp) { |
| 141 for (auto* recorder : video_recorders_) | 127 for (auto* recorder : video_recorders_) |
| 142 recorder->OnVideoFrameForTesting(frame, timestamp); | 128 recorder->OnVideoFrameForTesting(frame, timestamp); |
| 143 } | 129 } |
| 144 | 130 |
| 145 } // namespace content | 131 } // namespace content |
| OLD | NEW |