Update duration when demuxed packets exceed known duration.

media/test/pipeline_integration_test_base.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/test/pipeline_integration_test_base.h"
 
 #include <utility>
 
 #include "base/bind.h"
 #include "base/memory/ptr_util.h"
@@ skipping 126 matching lines @@
   hashing_enabled_ = test_type & kHashed;
   clockless_playback_ = test_type & kClockless;
 
   EXPECT_CALL(*this, OnMetadata(_))
       .Times(AtMost(1))
       .WillRepeatedly(SaveArg<0>(&metadata_));
   EXPECT_CALL(*this, OnBufferingStateChange(BUFFERING_HAVE_ENOUGH))
       .Times(AnyNumber());
   EXPECT_CALL(*this, OnBufferingStateChange(BUFFERING_HAVE_NOTHING))
       .Times(AnyNumber());
-  // Permit at most two calls to OnDurationChange.  CheckDuration will make sure
-  // that no more than one of them is a finite duration.  This allows the
-  // pipeline to call back at the end of the media with the known duration.
-  EXPECT_CALL(*this, OnDurationChange())
-      .Times(AtMost(2))
-      .WillRepeatedly(
-          Invoke(this, &PipelineIntegrationTestBase::CheckDuration));
+  // If the test is expected to have reliable duration information, permit at
+  // most two calls to OnDurationChange.  CheckDuration will make sure that no
+  // more than one of them is a finite duration.  This allows the pipeline to
+  // call back at the end of the media with the known duration.
+  //
+  // In the event of unreliable duration information, just set the expectation
+  // that it's called at least once. Such streams may repeatedly update their
+  // duration as new packets are demuxed.
+  if (test_type & kUnreliableDuration) {
+    EXPECT_CALL(*this, OnDurationChange()).Times(AtLeast(1));
+  } else {
+    EXPECT_CALL(*this, OnDurationChange())
+        .Times(AtMost(2))
+        .WillRepeatedly(
+            Invoke(this, &PipelineIntegrationTestBase::CheckDuration));
+  }
   EXPECT_CALL(*this, OnVideoNaturalSizeChange(_)).Times(AtMost(1));
   EXPECT_CALL(*this, OnVideoOpacityChange(_)).WillRepeatedly(Return());
   CreateDemuxer(std::move(data_source));
 
   if (cdm_context) {
     EXPECT_CALL(*this, DecryptorAttached(true));
     pipeline_->SetCdm(
         cdm_context, base::Bind(&PipelineIntegrationTestBase::DecryptorAttached,
                                 base::Unretained(this)));
   }
@@ skipping 269 matching lines @@
   DCHECK(clockless_playback_);
   return clockless_audio_sink_->render_time();
 }
 
 base::TimeTicks DummyTickClock::NowTicks() {
   now_ += base::TimeDelta::FromSeconds(60);
   return now_;
 }
 
 }  // namespace media