Asynchronous initialization of media::PipelineThread...

media/base/pipeline_impl_unittest.cc

 // Copyright (c) 2006-2009 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 <string>
 
 #include "base/waitable_event.h"
 #include "media/base/pipeline_impl.h"
 #include "media/base/media_format.h"
 #include "media/base/filters.h"
@@ skipping 182 matching lines @@
   // TODO(scherkus): implement whatever it takes so I can use EXPECT_EQ with
   // base::TimeDelta.
   EXPECT_TRUE(expected == filters_->data_source()->seek_time());
   EXPECT_TRUE(expected == filters_->demuxer()->seek_time());
   EXPECT_TRUE(expected == filters_->audio_decoder()->seek_time());
   EXPECT_TRUE(expected == filters_->audio_renderer()->seek_time());
   EXPECT_TRUE(expected == filters_->video_decoder()->seek_time());
   EXPECT_TRUE(expected == filters_->video_renderer()->seek_time());
 }
 
+// Try to execute Start()/Stop() on the Pipeline many times and very fast. This
+// test is trying to simulate the situation where the pipeline can get dead
+// locked very easily by quickly calling Start()/Stop().
+TEST_F(PipelineImplTest, StressTestPipelineStartStop) {
+  media::old_mocks::MockFilterConfig config;
+  const int kTimes = 1000;
+  for (int i = 0; i < kTimes; ++i) {
+    scoped_refptr<media::old_mocks::MockFilterFactory> factory =
+        new media::old_mocks::MockFilterFactory(&config);
+    media::PipelineImpl pipeline;
+    pipeline.Start(factory.get(), "", NULL);
+    pipeline.Stop();
+  }
+}
+
 // TODO(ralphl): Add a unit test that makes sure that the mock audio filter
 // is actually called on a SetVolume() call to the pipeline.  I almost checked
 // in code that broke this, but all unit tests were passing.
 
 }  // namespace