Use of the playback time in the MSE garbage collection.

media/filters/chunk_demuxer.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "media/filters/chunk_demuxer.h"
 
 #include <algorithm>
 #include <limits>
 #include <list>
 
@@ skipping 1014 matching lines @@
   CHECK_EQ(type_, TEXT);
   base::AutoLock auto_lock(lock_);
   return stream_->GetCurrentTextTrackConfig();
 }
 
 void ChunkDemuxerStream::SetLiveness(Liveness liveness) {
   base::AutoLock auto_lock(lock_);
   liveness_ = liveness;
 }
 
+void ChunkDemuxerStream::NotifyMediaTimeUpdate(DecodeTimestamp media_time) {
+  base::AutoLock auto_lock(lock_);
+  stream_->NotifyMediaTimeUpdate(media_time);
+}
+
 void ChunkDemuxerStream::ChangeState_Locked(State state) {
   lock_.AssertAcquired();
   DVLOG(1) << "ChunkDemuxerStream::ChangeState_Locked() : "
            << "type " << type_
            << " - " << state_ << " -> " << state;
   state_ = state;
 }
 
 ChunkDemuxerStream::~ChunkDemuxerStream() {}
 
@@ skipping 72 matching lines @@
       log_cb_(log_cb),
       media_log_(media_log),
       duration_(kNoTimestamp()),
       user_specified_duration_(-1),
       liveness_(DemuxerStream::LIVENESS_UNKNOWN),
       splice_frames_enabled_(splice_frames_enabled) {
   DCHECK(!open_cb_.is_null());
   DCHECK(!encrypted_media_init_data_cb_.is_null());
 }
 
+void ChunkDemuxer::SetMediaTimeProvider(
+    const base::Callback<base::TimeDelta(void)>& get_media_time_cb) {
+  get_media_time_cb_ = get_media_time_cb;
+}
+
 void ChunkDemuxer::Initialize(
     DemuxerHost* host,
     const PipelineStatusCB& cb,
     bool enable_text_tracks) {
   DVLOG(1) << "Init()";
 
   base::AutoLock auto_lock(lock_);
 
   init_cb_ = BindToCurrentLoop(cb);
   if (state_ == SHUTDOWN) {
@@ skipping 188 matching lines @@
     TimeDelta* timestamp_offset,
     const InitSegmentReceivedCB& init_segment_received_cb) {
   DVLOG(1) << "AppendData(" << id << ", " << length << ")";
 
   DCHECK(!id.empty());
   DCHECK(timestamp_offset);
   DCHECK(!init_segment_received_cb.is_null());
 
   Ranges<TimeDelta> ranges;
 
+  if (!get_media_time_cb_.is_null()) {
+    DecodeTimestamp current_media_time =
+        DecodeTimestamp::FromPresentationTime(get_media_time_cb_.Run());
+    if (audio_)
+      audio_->NotifyMediaTimeUpdate(current_media_time);
+    if (video_)
+      video_->NotifyMediaTimeUpdate(current_media_time);
+  }
+
   {
     base::AutoLock auto_lock(lock_);
     DCHECK_NE(state_, ENDED);
 
     // Capture if any of the SourceBuffers are waiting for data before we start
     // parsing.
     bool old_waiting_for_data = IsSeekWaitingForData_Locked();
 
     if (length == 0u)
       return;
@@ skipping 507 matching lines @@
 }
 
 void ChunkDemuxer::ShutdownAllStreams() {
   for (SourceStateMap::iterator itr = source_state_map_.begin();
        itr != source_state_map_.end(); ++itr) {
     itr->second->Shutdown();
   }
 }
 
 }  // namespace media