Implemented injected message loops for PipelineImpl.

media/player/movie.cc

 // Copyright (c) 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.
 
 #ifdef _OPENMP
 #include <omp.h>
 #endif
 
 #include "base/at_exit.h"
 #include "base/string_util.h"
@@ skipping 61 matching lines @@
   factories->AddFactory(FFmpegVideoDecoder::CreateFactory());
 
   if (enable_audio_) {
     factories->AddFactory(AudioRendererImpl::CreateFilterFactory());
   } else {
     factories->AddFactory(media::NullAudioRenderer::CreateFilterFactory());
   }
   factories->AddFactory(
       new media::InstanceFilterFactory<WtlVideoRenderer>(video_renderer));
 
-  pipeline_.reset(new PipelineImpl());
+  thread_.reset(new base::Thread("PipelineThread"));
+  thread_->Start();
+  pipeline_.reset(new PipelineImpl(thread_->message_loop()));
 
   // Create and start our pipeline.
   pipeline_->Start(factories.get(), WideToUTF8(std::wstring(url)), NULL);
   while (true) {
     PlatformThread::Sleep(100);
     if (pipeline_->IsInitialized())
       break;
     if (pipeline_->GetError() != media::PIPELINE_OK)
       return false;
   }
@@ skipping 94 matching lines @@
 }
 
 // Get Enable/Disable OpenMP state.
 bool Movie::GetOpenMpEnable() {
   return enable_openmp_;
 }
 
 // Teardown.
 void Movie::Close() {
   if (pipeline_.get()) {
-    pipeline_->Stop();
+    pipeline_->Stop(NULL);
+    thread_->Stop();
     pipeline_.reset();
+    thread_.reset();
   }
 }
 
 }  // namespace media