Fixes FFmpegDemuxerTest.ReadAndSeek test flakiness by using a WaitableEvent.

Turns out it was the test code that was flaky and not a threading bug in our actual code.  Under heavy load it was possible for a thread holding onto a reference to get time sliced long enough that the unit test continued executing until it asserted that the object was deleted when in fact it was not.

BUG=10653

Review URL: http://codereview.chromium.org/88010

git-svn-id: svn://svn.chromium.org/chrome/trunk/src@14113 0039d316-1c4b-4281-b951-d872f2087c98

1 files changed, 4 insertions, 10 deletions

diff --git a/media/base/mock_pipeline.h b/media/base/mock_pipeline.h
index d320301..e317a5d 100644
--- a/media/base/mock_pipeline.h
+++ b/media/base/mock_pipeline.h
@@ -14,6 +14,7 @@
 #include <deque>
 #include <string>
 
+#include "base/message_loop.h"
 #include "media/base/media_format.h"
 #include "media/base/pipeline.h"
 #include "testing/gtest/include/gtest/gtest.h"
@@ -135,17 +136,11 @@ class MockPipeline : public media::Pipeline {
   // pipeline is request/pull-based, only enough tasks to satisfy the request
   // should ever be executed.
   void RunAllTasks() {
-    while (!task_queue_.empty()) {
-      Task* task = task_queue_.front();
-      task_queue_.pop_front();
-      task->Run();
-      delete task;
-    }
+    message_loop_.RunAllPending();
   }
 
   void PostTask(Task* task) {
-    EXPECT_TRUE(task);
-    task_queue_.push_back(task);
+    message_loop_.PostTask(FROM_HERE, task);
   }
 
   void Error(media::PipelineError error) {
@@ -191,8 +186,7 @@ class MockPipeline : public media::Pipeline {
   int64 buffered_bytes_;
   int64 total_bytes_;
 
-  typedef std::deque<Task*> TaskQueue;
-  TaskQueue task_queue_;
+  MessageLoop message_loop_;
 
   DISALLOW_COPY_AND_ASSIGN(MockPipeline);
 };