OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 "media/base/pipeline_impl.h" | 5 #include "media/base/pipeline_impl.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <utility> | 8 #include <utility> |
9 | 9 |
10 #include "base/bind.h" | 10 #include "base/bind.h" |
(...skipping 186 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
197 return statistics_; | 197 return statistics_; |
198 } | 198 } |
199 | 199 |
200 void PipelineImpl::SetCdm(CdmContext* cdm_context, | 200 void PipelineImpl::SetCdm(CdmContext* cdm_context, |
201 const CdmAttachedCB& cdm_attached_cb) { | 201 const CdmAttachedCB& cdm_attached_cb) { |
202 task_runner_->PostTask( | 202 task_runner_->PostTask( |
203 FROM_HERE, base::Bind(&PipelineImpl::SetCdmTask, weak_this_, cdm_context, | 203 FROM_HERE, base::Bind(&PipelineImpl::SetCdmTask, weak_this_, cdm_context, |
204 cdm_attached_cb)); | 204 cdm_attached_cb)); |
205 } | 205 } |
206 | 206 |
207 void PipelineImpl::OnEnabledAudioStreamsChanged( | |
208 const std::vector<const DemuxerStream*>& enabledAudioStreams) { | |
209 if (!task_runner_->BelongsToCurrentThread()) { | |
210 task_runner_->PostTask( | |
211 FROM_HERE, base::Bind(&PipelineImpl::OnEnabledAudioStreamsChanged, | |
212 weak_factory_.GetWeakPtr(), enabledAudioStreams)); | |
213 return; | |
214 } | |
215 base::AutoLock auto_lock(lock_); | |
216 DCHECK(task_runner_->BelongsToCurrentThread()); | |
217 if (renderer_) { | |
218 renderer_->OnEnabledAudioStreamsChanged(enabledAudioStreams); | |
219 } | |
220 } | |
221 | |
222 void PipelineImpl::OnSelectedVideoStreamChanged( | |
223 const DemuxerStream* selectedVideoStream) { | |
224 if (!task_runner_->BelongsToCurrentThread()) { | |
225 task_runner_->PostTask( | |
226 FROM_HERE, base::Bind(&PipelineImpl::OnSelectedVideoStreamChanged, | |
227 weak_factory_.GetWeakPtr(), selectedVideoStream)); | |
228 return; | |
229 } | |
230 base::AutoLock auto_lock(lock_); | |
231 DCHECK(task_runner_->BelongsToCurrentThread()); | |
232 if (renderer_) { | |
233 renderer_->OnSelectedVideoStreamChanged(selectedVideoStream); | |
234 } | |
235 } | |
236 | |
237 void PipelineImpl::SetErrorForTesting(PipelineStatus status) { | 207 void PipelineImpl::SetErrorForTesting(PipelineStatus status) { |
238 OnError(status); | 208 OnError(status); |
239 } | 209 } |
240 | 210 |
241 bool PipelineImpl::HasWeakPtrsForTesting() const { | 211 bool PipelineImpl::HasWeakPtrsForTesting() const { |
242 DCHECK(task_runner_->BelongsToCurrentThread()); | 212 DCHECK(task_runner_->BelongsToCurrentThread()); |
243 return weak_factory_.HasWeakPtrs(); | 213 return weak_factory_.HasWeakPtrs(); |
244 } | 214 } |
245 | 215 |
246 void PipelineImpl::SetState(State next_state) { | 216 void PipelineImpl::SetState(State next_state) { |
(...skipping 646 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
893 metadata_cb_.Run(metadata); | 863 metadata_cb_.Run(metadata); |
894 } | 864 } |
895 | 865 |
896 void PipelineImpl::BufferingStateChanged(BufferingState new_buffering_state) { | 866 void PipelineImpl::BufferingStateChanged(BufferingState new_buffering_state) { |
897 DVLOG(1) << __FUNCTION__ << "(" << new_buffering_state << ") "; | 867 DVLOG(1) << __FUNCTION__ << "(" << new_buffering_state << ") "; |
898 DCHECK(task_runner_->BelongsToCurrentThread()); | 868 DCHECK(task_runner_->BelongsToCurrentThread()); |
899 buffering_state_cb_.Run(new_buffering_state); | 869 buffering_state_cb_.Run(new_buffering_state); |
900 } | 870 } |
901 | 871 |
902 } // namespace media | 872 } // namespace media |
OLD | NEW |