| 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 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/bind_helpers.h" | 10 #include "base/bind_helpers.h" |
| (...skipping 49 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 60 void Suspend(); | 60 void Suspend(); |
| 61 void Resume(std::unique_ptr<Renderer> renderer, base::TimeDelta time); | 61 void Resume(std::unique_ptr<Renderer> renderer, base::TimeDelta time); |
| 62 void SetPlaybackRate(double playback_rate); | 62 void SetPlaybackRate(double playback_rate); |
| 63 void SetVolume(float volume); | 63 void SetVolume(float volume); |
| 64 base::TimeDelta GetMediaTime() const; | 64 base::TimeDelta GetMediaTime() const; |
| 65 Ranges<base::TimeDelta> GetBufferedTimeRanges() const; | 65 Ranges<base::TimeDelta> GetBufferedTimeRanges() const; |
| 66 bool DidLoadingProgress(); | 66 bool DidLoadingProgress(); |
| 67 PipelineStatistics GetStatistics() const; | 67 PipelineStatistics GetStatistics() const; |
| 68 void SetCdm(CdmContext* cdm_context, const CdmAttachedCB& cdm_attached_cb); | 68 void SetCdm(CdmContext* cdm_context, const CdmAttachedCB& cdm_attached_cb); |
| 69 | 69 |
| 70 // |enabledTrackIds| contains track ids of enabled audio tracks. | 70 // |enabled_track_ids| contains track ids of enabled audio tracks. |
| 71 void OnEnabledAudioTracksChanged( | 71 void OnEnabledAudioTracksChanged( |
| 72 const std::vector<MediaTrack::Id>& enabledTrackIds); | 72 const std::vector<MediaTrack::Id>& enabled_track_ids); |
| 73 | 73 |
| 74 // |trackId| either empty, which means no video track is selected, or contain | 74 // |selected_track_id| is either empty, which means no video track is |
| 75 // one element - the selected video track id. | 75 // selected, or contains the selected video track id. |
| 76 void OnSelectedVideoTrackChanged( | 76 void OnSelectedVideoTrackChanged( |
| 77 const std::vector<MediaTrack::Id>& selectedTrackId); | 77 base::Optional<MediaTrack::Id> selected_track_id); |
| 78 | 78 |
| 79 private: | 79 private: |
| 80 // Contains state shared between main and media thread. | 80 // Contains state shared between main and media thread. |
| 81 // Main thread can only read. Media thread can both - read and write. | 81 // Main thread can only read. Media thread can both - read and write. |
| 82 // So it is not necessary to lock when reading from the media thread. | 82 // So it is not necessary to lock when reading from the media thread. |
| 83 // This struct should only contain state that is not immediately needed by | 83 // This struct should only contain state that is not immediately needed by |
| 84 // PipelineClient and can be cached on the media thread until queried. | 84 // PipelineClient and can be cached on the media thread until queried. |
| 85 // Alternatively we could cache it on the main thread by posting the | 85 // Alternatively we could cache it on the main thread by posting the |
| 86 // notification to the main thread. But some of the state change notifications | 86 // notification to the main thread. But some of the state change notifications |
| 87 // (OnStatisticsUpdate and OnBufferedTimeRangesChanged) arrive much more | 87 // (OnStatisticsUpdate and OnBufferedTimeRangesChanged) arrive much more |
| (...skipping 465 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 553 | 553 |
| 554 if (state_ != kPlaying) | 554 if (state_ != kPlaying) |
| 555 return; | 555 return; |
| 556 | 556 |
| 557 DCHECK(!renderer_ended_); | 557 DCHECK(!renderer_ended_); |
| 558 renderer_ended_ = true; | 558 renderer_ended_ = true; |
| 559 CheckPlaybackEnded(); | 559 CheckPlaybackEnded(); |
| 560 } | 560 } |
| 561 | 561 |
| 562 void PipelineImpl::OnEnabledAudioTracksChanged( | 562 void PipelineImpl::OnEnabledAudioTracksChanged( |
| 563 const std::vector<MediaTrack::Id>& enabledTrackIds) { | 563 const std::vector<MediaTrack::Id>& enabled_track_ids) { |
| 564 DCHECK(thread_checker_.CalledOnValidThread()); | 564 DCHECK(thread_checker_.CalledOnValidThread()); |
| 565 media_task_runner_->PostTask( | 565 media_task_runner_->PostTask( |
| 566 FROM_HERE, | 566 FROM_HERE, |
| 567 base::Bind(&RendererWrapper::OnEnabledAudioTracksChanged, | 567 base::Bind(&RendererWrapper::OnEnabledAudioTracksChanged, |
| 568 base::Unretained(renderer_wrapper_.get()), enabledTrackIds)); | 568 base::Unretained(renderer_wrapper_.get()), enabled_track_ids)); |
| 569 } | 569 } |
| 570 | 570 |
| 571 void PipelineImpl::OnSelectedVideoTrackChanged( | 571 void PipelineImpl::OnSelectedVideoTrackChanged( |
| 572 const std::vector<MediaTrack::Id>& selectedTrackId) { | 572 base::Optional<MediaTrack::Id> selected_track_id) { |
| 573 DCHECK(thread_checker_.CalledOnValidThread()); | 573 DCHECK(thread_checker_.CalledOnValidThread()); |
| 574 media_task_runner_->PostTask( | 574 media_task_runner_->PostTask( |
| 575 FROM_HERE, | 575 FROM_HERE, |
| 576 base::Bind(&RendererWrapper::OnSelectedVideoTrackChanged, | 576 base::Bind(&RendererWrapper::OnSelectedVideoTrackChanged, |
| 577 base::Unretained(renderer_wrapper_.get()), selectedTrackId)); | 577 base::Unretained(renderer_wrapper_.get()), selected_track_id)); |
| 578 } | 578 } |
| 579 | 579 |
| 580 void PipelineImpl::RendererWrapper::OnEnabledAudioTracksChanged( | 580 void PipelineImpl::RendererWrapper::OnEnabledAudioTracksChanged( |
| 581 const std::vector<MediaTrack::Id>& enabledTrackIds) { | 581 const std::vector<MediaTrack::Id>& enabled_track_ids) { |
| 582 DCHECK(media_task_runner_->BelongsToCurrentThread()); | 582 DCHECK(media_task_runner_->BelongsToCurrentThread()); |
| 583 | 583 |
| 584 // If the pipeline has been created, but not started yet, we may still receive | 584 // If the pipeline has been created, but not started yet, we may still receive |
| 585 // track notifications from blink level (e.g. when video track gets deselected | 585 // track notifications from blink level (e.g. when video track gets deselected |
| 586 // due to player/pipeline belonging to a background tab). We can safely ignore | 586 // due to player/pipeline belonging to a background tab). We can safely ignore |
| 587 // these, since WebMediaPlayerImpl will ensure that demuxer stream / track | 587 // these, since WebMediaPlayerImpl will ensure that demuxer stream / track |
| 588 // status is in sync with blink after pipeline is started. | 588 // status is in sync with blink after pipeline is started. |
| 589 if (state_ == kCreated) { | 589 if (state_ == kCreated) { |
| 590 DCHECK(!demuxer_); | 590 DCHECK(!demuxer_); |
| 591 return; | 591 return; |
| 592 } | 592 } |
| 593 | 593 |
| 594 // Track status notifications might be delivered asynchronously. If we receive | 594 // Track status notifications might be delivered asynchronously. If we receive |
| 595 // a notification when pipeline is stopped/shut down, it's safe to ignore it. | 595 // a notification when pipeline is stopped/shut down, it's safe to ignore it. |
| 596 if (state_ == kStopping || state_ == kStopped) { | 596 if (state_ == kStopping || state_ == kStopped) { |
| 597 return; | 597 return; |
| 598 } | 598 } |
| 599 | 599 |
| 600 DCHECK(demuxer_); | 600 DCHECK(demuxer_); |
| 601 DCHECK(shared_state_.renderer || (state_ != kPlaying)); | 601 DCHECK(shared_state_.renderer || (state_ != kPlaying)); |
| 602 | 602 |
| 603 base::TimeDelta currTime = (state_ == kPlaying) | 603 base::TimeDelta curr_time = (state_ == kPlaying) |
| 604 ? shared_state_.renderer->GetMediaTime() | 604 ? shared_state_.renderer->GetMediaTime() |
| 605 : demuxer_->GetStartTime(); | 605 : demuxer_->GetStartTime(); |
| 606 demuxer_->OnEnabledAudioTracksChanged(enabledTrackIds, currTime); | 606 demuxer_->OnEnabledAudioTracksChanged(enabled_track_ids, curr_time); |
| 607 } | 607 } |
| 608 | 608 |
| 609 void PipelineImpl::RendererWrapper::OnSelectedVideoTrackChanged( | 609 void PipelineImpl::RendererWrapper::OnSelectedVideoTrackChanged( |
| 610 const std::vector<MediaTrack::Id>& selectedTrackId) { | 610 base::Optional<MediaTrack::Id> selected_track_id) { |
| 611 DCHECK(media_task_runner_->BelongsToCurrentThread()); | 611 DCHECK(media_task_runner_->BelongsToCurrentThread()); |
| 612 | 612 |
| 613 // If the pipeline has been created, but not started yet, we may still receive | 613 // If the pipeline has been created, but not started yet, we may still receive |
| 614 // track notifications from blink level (e.g. when video track gets deselected | 614 // track notifications from blink level (e.g. when video track gets deselected |
| 615 // due to player/pipeline belonging to a background tab). We can safely ignore | 615 // due to player/pipeline belonging to a background tab). We can safely ignore |
| 616 // these, since WebMediaPlayerImpl will ensure that demuxer stream / track | 616 // these, since WebMediaPlayerImpl will ensure that demuxer stream / track |
| 617 // status is in sync with blink after pipeline is started. | 617 // status is in sync with blink after pipeline is started. |
| 618 if (state_ == kCreated) { | 618 if (state_ == kCreated) { |
| 619 DCHECK(!demuxer_); | 619 DCHECK(!demuxer_); |
| 620 return; | 620 return; |
| 621 } | 621 } |
| 622 | 622 |
| 623 // Track status notifications might be delivered asynchronously. If we receive | 623 // Track status notifications might be delivered asynchronously. If we receive |
| 624 // a notification when pipeline is stopped/shut down, it's safe to ignore it. | 624 // a notification when pipeline is stopped/shut down, it's safe to ignore it. |
| 625 if (state_ == kStopping || state_ == kStopped) { | 625 if (state_ == kStopping || state_ == kStopped) { |
| 626 return; | 626 return; |
| 627 } | 627 } |
| 628 | 628 |
| 629 DCHECK(demuxer_); | 629 DCHECK(demuxer_); |
| 630 DCHECK(shared_state_.renderer || (state_ != kPlaying)); | 630 DCHECK(shared_state_.renderer || (state_ != kPlaying)); |
| 631 | 631 |
| 632 base::TimeDelta currTime = (state_ == kPlaying) | 632 base::TimeDelta curr_time = (state_ == kPlaying) |
| 633 ? shared_state_.renderer->GetMediaTime() | 633 ? shared_state_.renderer->GetMediaTime() |
| 634 : demuxer_->GetStartTime(); | 634 : demuxer_->GetStartTime(); |
| 635 demuxer_->OnSelectedVideoTrackChanged(selectedTrackId, currTime); | 635 demuxer_->OnSelectedVideoTrackChanged(selected_track_id, curr_time); |
| 636 } | 636 } |
| 637 | 637 |
| 638 void PipelineImpl::RendererWrapper::OnStatisticsUpdate( | 638 void PipelineImpl::RendererWrapper::OnStatisticsUpdate( |
| 639 const PipelineStatistics& stats) { | 639 const PipelineStatistics& stats) { |
| 640 DVLOG(3) << __func__; | 640 DVLOG(3) << __func__; |
| 641 DCHECK(media_task_runner_->BelongsToCurrentThread()); | 641 DCHECK(media_task_runner_->BelongsToCurrentThread()); |
| 642 | 642 |
| 643 base::AutoLock auto_lock(shared_state_lock_); | 643 base::AutoLock auto_lock(shared_state_lock_); |
| 644 shared_state_.statistics.audio_bytes_decoded += stats.audio_bytes_decoded; | 644 shared_state_.statistics.audio_bytes_decoded += stats.audio_bytes_decoded; |
| 645 shared_state_.statistics.video_bytes_decoded += stats.video_bytes_decoded; | 645 shared_state_.statistics.video_bytes_decoded += stats.video_bytes_decoded; |
| (...skipping 711 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1357 void PipelineImpl::OnSuspendDone() { | 1357 void PipelineImpl::OnSuspendDone() { |
| 1358 DVLOG(3) << __func__; | 1358 DVLOG(3) << __func__; |
| 1359 DCHECK(thread_checker_.CalledOnValidThread()); | 1359 DCHECK(thread_checker_.CalledOnValidThread()); |
| 1360 DCHECK(IsRunning()); | 1360 DCHECK(IsRunning()); |
| 1361 | 1361 |
| 1362 DCHECK(!suspend_cb_.is_null()); | 1362 DCHECK(!suspend_cb_.is_null()); |
| 1363 base::ResetAndReturn(&suspend_cb_).Run(PIPELINE_OK); | 1363 base::ResetAndReturn(&suspend_cb_).Run(PIPELINE_OK); |
| 1364 } | 1364 } |
| 1365 | 1365 |
| 1366 } // namespace media | 1366 } // namespace media |
| OLD | NEW |