PipelineError is dead. Long live PipelineStatus!

media/tools/player_wtl/movie.cc

 // Copyright (c) 2011 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/tools/player_wtl/movie.h"
 
 #include "base/singleton.h"
 #include "base/threading/platform_thread.h"
 #include "base/utf_string_conversions.h"
 #include "media/base/filter_collection.h"
@@ skipping 66 matching lines @@
       message_loop_factory_->GetMessageLoop("VideoDecoderThread"), NULL));
 
   if (enable_audio_) {
     collection->AddAudioRenderer(new AudioRendererImpl());
   } else {
     collection->AddAudioRenderer(new media::NullAudioRenderer());
   }
   collection->AddVideoRenderer(video_renderer);
 
   // Create and start our pipeline.
-  pipeline_->Start(collection.release(), WideToUTF8(std::wstring(url)), NULL);
-  while (true) {
-    base::PlatformThread::Sleep(100);
-    if (pipeline_->IsInitialized())
-      break;
-    if (pipeline_->GetError() != media::PIPELINE_OK)
-      return false;
-  }
+  media::PipelineStatusNotification note;
+  pipeline_->Start(collection.release(), WideToUTF8(std::wstring(url)),
+                   note.Callback());
+  // Wait until the pipeline is fully initialized.
+  note.Wait();
+  if (note.status() != PIPELINE_OK)
+    return false;
   pipeline_->SetPlaybackRate(play_rate_);
   return true;
 }
 
 void Movie::Play(float rate) {
   // Begin playback.
   if (pipeline_)
     pipeline_->SetPlaybackRate(enable_pause_ ? 0.0f : rate);
   if (rate > 0.0f)
     play_rate_ = rate;
@@ skipping 68 matching lines @@
 void Movie::Close() {
   if (pipeline_) {
     pipeline_->Stop(NULL);
     pipeline_ = NULL;
   }
 
   message_loop_factory_.reset();
 }
 
 }  // namespace media