Refcounting BufferedResourceLoader

webkit/glue/media/buffered_data_source.h

 // 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.
 
 #ifndef WEBKIT_GLUE_MEDIA_BUFFERED_DATA_SOURCE_H_
 #define WEBKIT_GLUE_MEDIA_BUFFERED_DATA_SOURCE_H_
 
 #include <string>
 
 #include "base/lock.h"
@@ skipping 11 matching lines @@
 #include "webkit/glue/media/media_resource_loader_bridge_factory.h"
 
 namespace webkit_glue {
 
 /////////////////////////////////////////////////////////////////////////////
 // BufferedResourceLoader
 // This class works inside demuxer thread and render thread. It contains a
 // resource loader bridge and does the actual resource loading. This object
 // does buffering internally, it defers the resource loading if buffer is
 // full and un-defers the resource loading if it is under buffered.
-class BufferedResourceLoader : public webkit_glue::ResourceLoaderBridge::Peer {
+class BufferedResourceLoader :
+    public base::RefCountedThreadSafe<BufferedResourceLoader>,
+    public webkit_glue::ResourceLoaderBridge::Peer {
  public:
   // |bridge_factory| - Factory to create a ResourceLoaderBridge.
   // |url| - URL for the resource to be loaded.
   // |first_byte_position| - First byte to start loading from, -1 for not
   // specified.
   // |last_byte_position| - Last byte to be loaded, -1 for not specified.
   BufferedResourceLoader(
       webkit_glue::MediaResourceLoaderBridgeFactory* bridge_factory,
       const GURL& url,
       int64 first_byte_position,
@@ skipping 184 matching lines @@
   // thread.
   void ReadTask(int64 position, int read_size,
                 uint8* read_buffer,
                 media::DataSource::ReadCallback* read_callback);
 
   // Task posted when Stop() is called.
   void StopTask();
 
   // Reset |loader_| with |loader| and starts it. This task is posted from
   // callback method from the current buffered resource loader.
-  void SwapLoaderTask(BufferedResourceLoader* loader);
+  void SwapLoaderTask(scoped_refptr<BufferedResourceLoader> loader);
 
   // This task monitors the current active read request. If the current read
   // request has timed out, this task will destroy the current loader and
   // creates a new to accomodate the read request.
   void WatchDogTask();
 
   // The method that performs actual read. This method can only be executed on
   // the render thread.
   void ReadInternal();
 
@@ skipping 34 matching lines @@
   int64 total_bytes_;
 
   // This value will be true if this data source can only support streaming.
   // i.e. range request is not supported.
   bool streaming_;
 
   // A factory object to produce ResourceLoaderBridge.
   scoped_ptr<webkit_glue::MediaResourceLoaderBridgeFactory> bridge_factory_;
 
   // A resource loader for the media resource.
-  scoped_ptr<BufferedResourceLoader> loader_;
+  scoped_refptr<BufferedResourceLoader> loader_;
 
   // A resource loader that probes the server's ability to serve range requests.
-  scoped_ptr<BufferedResourceLoader> probe_loader_;
+  scoped_refptr<BufferedResourceLoader> probe_loader_;
 
   // Callback method from the pipeline for initialization.
   scoped_ptr<media::FilterCallback> initialize_callback_;
 
   // Read parameters received from the Read() method call.
   scoped_ptr<media::DataSource::ReadCallback> read_callback_;
   int64 read_position_;
   int read_size_;
   uint8* read_buffer_;
   base::Time read_submitted_time_;
@@ skipping 37 matching lines @@
   // loop. The RepeatingTimer does PostDelayedTask() internally, by using it
   // the message loop doesn't hold a reference for the watch dog task.
   base::RepeatingTimer<BufferedDataSource> watch_dog_timer_;
 
   DISALLOW_COPY_AND_ASSIGN(BufferedDataSource);
 };
 
 }  // namespace webkit_glue
 
 #endif  // WEBKIT_GLUE_MEDIA_BUFFERED_DATA_SOURCE_H_