TextRenderer only pushes new cues downstream

media/base/text_renderer.cc

 // Copyright 2013 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/base/text_renderer.h"
 
 #include "base/bind.h"
 #include "base/callback_helpers.h"
 #include "base/logging.h"
 #include "base/single_thread_task_runner.h"
@@ skipping 72 matching lines @@
 }
 
 void TextRenderer::Flush(const base::Closure& callback) {
   DCHECK(task_runner_->BelongsToCurrentThread());
   DCHECK_EQ(pending_read_count_, 0);
   DCHECK(state_ == kPaused) << "state_ " << state_;
 
   for (TextTrackStateMap::iterator itr = text_track_state_map_.begin();
        itr != text_track_state_map_.end(); ++itr) {
     pending_eos_set_.insert(itr->first);
+    itr->second->text_ranges_.Flush();
   }
   DCHECK_EQ(pending_eos_set_.size(), text_track_state_map_.size());
   callback.Run();
 }
 
 void TextRenderer::Stop(const base::Closure& cb) {
   DCHECK(task_runner_->BelongsToCurrentThread());
   DCHECK(!cb.is_null());
   DCHECK(state_ == kPlaying ||
          state_ == kPausePending ||
@@ skipping 196 matching lines @@
 
     case kPaused:
     case kStopped:
     case kUninitialized:
     case kEnded:
       NOTREACHED();
       return;
   }
 
   base::TimeDelta start = text_cue->timestamp();
-  base::TimeDelta end = start + text_cue->duration();
 
-  state->text_track->addWebVTTCue(start, end,
-                                  text_cue->id(),
-                                  text_cue->text(),
-                                  text_cue->settings());
+  if (state->text_ranges_.AddCue(start)) {
+    base::TimeDelta end = start + text_cue->duration();
+
+    state->text_track->addWebVTTCue(start, end,
+                                    text_cue->id(),
+                                    text_cue->text(),
+                                    text_cue->settings());
+  }
 
   if (state_ == kPlaying) {
     Read(state, text_stream);
     return;
   }
 
   if (pending_read_count_ == 0) {
       DCHECK_EQ(state_, kPausePending) << "state_ " << state_;
       state_ = kPaused;
       base::ResetAndReturn(&pause_cb_).Run();
@@ skipping 32 matching lines @@
 
 TextRenderer::TextTrackState::TextTrackState(scoped_ptr<TextTrack> tt)
     : read_state(kReadIdle),
       text_track(tt.Pass()) {
 }
 
 TextRenderer::TextTrackState::~TextTrackState() {
 }
 
 }  // namespace media