Fire canplaythrough event at the proper time for audio/video

media/base/pipeline_impl.h

 // 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.
 
 // Implementation of Pipeline & PipelineStatusNotification (an async-to-sync
 // callback adapter).
 
 #ifndef MEDIA_BASE_PIPELINE_IMPL_H_
 #define MEDIA_BASE_PIPELINE_IMPL_H_
 
 #include <set>
 #include <string>
 #include <vector>
 
 #include "base/gtest_prod_util.h"
 #include "base/memory/ref_counted.h"
 #include "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "base/synchronization/condition_variable.h"
 #include "base/synchronization/lock.h"
 #include "base/threading/thread.h"
 #include "base/time.h"
 #include "media/base/clock.h"
 #include "media/base/composite_filter.h"
 #include "media/base/demuxer.h"
+#include "media/base/download_rate_monitor.h"
 #include "media/base/filter_host.h"
 #include "media/base/pipeline.h"
 #include "ui/gfx/size.h"
 
 namespace media {
 
 class MediaLog;
 
 // Adapter for using asynchronous Pipeline methods in code that wants to run
 // synchronously.  To use, construct an instance of this class and pass the
@@ skipping 218 matching lines @@
   // Carries out notifying filters that the preload value has changed.
   void PreloadChangedTask(Preload preload);
 
   // Carries out notifying filters that we are seeking to a new timestamp.
   void SeekTask(base::TimeDelta time, const PipelineStatusCB& seek_callback);
 
   // Carries out handling a notification from a filter that it has ended.
   void NotifyEndedTask();
 
   // Carries out handling a notification of network event.
-  void NotifyNetworkEventTask(bool is_downloading_data);
+  void NotifyNetworkEventTask(NetworkEvent type, bool is_downloading_data);

[acolwell GONE FROM CHROMIUM, 2011/11/09 00:50:22]

Do we still need the bool?

[vrk (LEFT CHROMIUM), 2011/11/11 02:51:06]

Nope! Removed.

 
   // Carries out disabling the audio renderer.
   void DisableAudioRendererTask();
 
   // Carries out advancing to the next filter during Play()/Pause()/Seek().
   void FilterStateTransitionTask();
 
   // Carries out advancing to the next teardown operation.
   void TeardownStateTransitionTask();
 
@@ skipping 52 matching lines @@
   // Initiates a Seek() on the |demuxer_| & |pipeline_filter_|.
   void DoSeek(base::TimeDelta seek_timestamp);
 
   // Called when |demuxer_| finishes seeking. If seeking was successful,
   // then Seek() is called on |pipeline_filter_|.
   void OnDemuxerSeekDone(base::TimeDelta seek_timestamp,
                          PipelineStatus status);
 
   void OnAudioUnderflow();
 
+  // Called when |download_rate_monitor_| believes that the media can
+  // be played through without needing to pause to buffer.
+  void OnCanPlayThrough();
+
+  // Carries out the notification that the media can be played through without
+  // needing to pause to buffer.
+  void NotifyCanPlayThrough();
+
   // Message loop used to execute pipeline tasks.
   MessageLoop* message_loop_;
 
   // MediaLog to which to log events.
   scoped_refptr<MediaLog> media_log_;
 
   // Lock used to serialize access for the following data members.
   mutable base::Lock lock_;
 
   // Whether or not the pipeline is running.
@@ skipping 125 matching lines @@
   // initialization.
   class PipelineInitState;
   scoped_ptr<PipelineInitState> pipeline_init_state_;
 
   // Statistics.
   PipelineStatistics statistics_;
   // Time of pipeline creation; is non-zero only until the pipeline first
   // reaches "kStarted", at which point it is used & zeroed out.
   base::Time creation_time_;
 
+  // Approximates the rate at which the media is being downloaded.
+  DownloadRateMonitor download_rate_monitor_;
+
+  // True if the pipeline is actively downloading bytes, false otherwise.
+  bool is_downloading_data_;
+
   FRIEND_TEST_ALL_PREFIXES(PipelineImplTest, GetBufferedTime);
 
   DISALLOW_COPY_AND_ASSIGN(PipelineImpl);
 };
 
 }  // namespace media
 
 #endif  // MEDIA_BASE_PIPELINE_IMPL_H_