Chromium Code Reviews| Index: content/browser/loader/redirect_to_file_resource_handler.h |
| diff --git a/content/browser/loader/redirect_to_file_resource_handler.h b/content/browser/loader/redirect_to_file_resource_handler.h |
| index 3d62835e8888d734a8e144356177d6a1faa87ea2..6e51880c99478b7ddde047887c5e5e4f4b2c959e 100644 |
| --- a/content/browser/loader/redirect_to_file_resource_handler.h |
| +++ b/content/browser/loader/redirect_to_file_resource_handler.h |
| @@ -5,6 +5,7 @@ |
| #ifndef CONTENT_BROWSER_LOADER_REDIRECT_TO_FILE_RESOURCE_HANDLER_H_ |
| #define CONTENT_BROWSER_LOADER_REDIRECT_TO_FILE_RESOURCE_HANDLER_H_ |
| +#include "base/callback_forward.h" |
| #include "base/files/file_path.h" |
| #include "base/memory/ref_counted.h" |
| #include "base/memory/scoped_ptr.h" |
| @@ -24,19 +25,53 @@ class ShareableFileReference; |
| } |
| namespace content { |
| -class ResourceDispatcherHostImpl; |
| -// Redirects network data to a file. This is intended to be layered in front |
| -// of either the AsyncResourceHandler or the SyncResourceHandler. |
| -class RedirectToFileResourceHandler : public LayeredResourceHandler { |
| +// Redirects network data to a file. This is intended to be layered in front of |
| +// either the AsyncResourceHandler or the SyncResourceHandler. The downstream |
| +// resource handler does not see OnWillRead or OnReadCompleted calls. Instead, |
| +// the ResourceResponse contains the path to a temporary file and |
| +// OnDataDownloaded is called as the file downloads. |
| +// |
| +// The temporary is vended through a delegate interface. |
| +class CONTENT_EXPORT RedirectToFileResourceHandler |
|
mmenke
2013/12/05 21:34:03
Should include content_export.h
davidben
2013/12/05 22:43:20
Done.
|
| + : public LayeredResourceHandler { |
| public: |
| + typedef base::Callback< |
|
mmenke
2013/12/05 21:34:03
Should include callback.h or callback_forward.h.
davidben
2013/12/05 22:43:20
It's already there, but...
|
| + void(base::PlatformFileError, |
| + scoped_ptr<net::FileStream>, |
| + scoped_refptr<webkit_blob::ShareableFileReference>)> |
| + CreateTemporaryCallback; |
|
mmenke
2013/12/05 21:34:03
I'm unable to find anything that's quite this ugly
davidben
2013/12/05 22:43:20
Actually deleting it altogether. It's gone now and
|
| + |
| + |
|
mmenke
2013/12/05 21:34:03
nit: Remove extra blank line.
davidben
2013/12/05 22:43:20
Done.
|
| + // A delegate class for vending temporary files. |
| + class Delegate { |
| + public: |
| + virtual ~Delegate() {} |
| + |
| + // Creates a temporary file for a request. DidCreateTemporaryFile is called |
| + // on |handler| with a net::FileStream to read from and a |
| + // ShareableFileReference. The caller should retain a reference to the |
| + // ShareableFileReference until it is done writing to it. When all |
| + // references to the ShareableFileReference are released, the temporary is |
| + // deleted. The factory itself may retain its own reference to the file. |
| + // |
| + // If there is an error in creating the temporary, DidCreateTemporaryFile is |
| + // called with a base::PlatformFileError. |
| + virtual void CreateTemporary( |
| + int child_id, |
| + int request_id, |
| + base::WeakPtr<RedirectToFileResourceHandler> handler) = 0; |
| + }; |
| + |
| + // Create a RedirectToFileResourceHandler for |request| which wraps |
| + // |next_handler|. |delegate| must outlive the handler. |
| RedirectToFileResourceHandler( |
| scoped_ptr<ResourceHandler> next_handler, |
| net::URLRequest* request, |
| - ResourceDispatcherHostImpl* resource_dispatcher_host); |
| + Delegate* delegate); |
| virtual ~RedirectToFileResourceHandler(); |
| - // ResourceHandler implementation: |
| + // LayeredResourceHandler implementation: |
| virtual bool OnResponseStarted(int request_id, |
| ResourceResponse* response, |
| bool* defer) OVERRIDE; |
| @@ -55,18 +90,21 @@ class RedirectToFileResourceHandler : public LayeredResourceHandler { |
| const std::string& security_info, |
| bool* defer) OVERRIDE; |
| - private: |
| - void DidCreateTemporaryFile(base::PlatformFileError error_code, |
| - base::PassPlatformFile file_handle, |
| - const base::FilePath& file_path); |
| + // Called by RedirectToFileResourceHandler::Writer. |
| void DidWriteToFile(int result); |
|
mmenke
2013/12/05 21:34:03
This can be private, since inner classes are frien
davidben
2013/12/05 22:43:20
Done. Huh, I didn't actually know that. Handy.
|
| + |
| + // Called by the delegate. |
| + void DidCreateTemporaryFile( |
| + base::PlatformFileError error_code, |
| + scoped_ptr<net::FileStream> file_stream, |
| + webkit_blob::ShareableFileReference* deletable_file); |
| + |
| + private: |
| bool WriteMore(); |
| bool BufIsFull() const; |
| void ResumeIfDeferred(); |
| - base::WeakPtrFactory<RedirectToFileResourceHandler> weak_factory_; |
| - |
| - ResourceDispatcherHostImpl* host_; |
| + Delegate* delegate_; |
| // We allocate a single, fixed-size IO buffer (buf_) used to read from the |
| // network (buf_write_pending_ is true while the system is copying data into |
| @@ -79,8 +117,11 @@ class RedirectToFileResourceHandler : public LayeredResourceHandler { |
| bool buf_write_pending_; |
| int write_cursor_; |
| - scoped_ptr<net::FileStream> file_stream_; |
| - bool write_callback_pending_; |
| + // Helper writer object which maintains references to the net::FileStream and |
| + // webkit_blob::ShareableFileReference. This is maintained separately so that, |
| + // on Windows, the temporary file isn't deleted until after it is closed. |
| + class Writer; |
| + scoped_ptr<Writer> writer_; |
| // |next_buffer_size_| is the size of the buffer to be allocated on the next |
| // OnWillRead() call. We exponentially grow the size of the buffer allocated |
| @@ -89,16 +130,15 @@ class RedirectToFileResourceHandler : public LayeredResourceHandler { |
| // was filled, up to a maximum size of 512k. |
| int next_buffer_size_; |
| - // We create a ShareableFileReference that's deletable for the temp |
| - // file created as a result of the download. |
| - scoped_refptr<webkit_blob::ShareableFileReference> deletable_file_; |
| - |
| - bool did_defer_ ; |
| + bool did_defer_; |
| bool completed_during_write_; |
| + GURL will_start_url_; |
| net::URLRequestStatus completed_status_; |
| std::string completed_security_info_; |
| + base::WeakPtrFactory<RedirectToFileResourceHandler> weak_factory_; |
| + |
| DISALLOW_COPY_AND_ASSIGN(RedirectToFileResourceHandler); |
|
mmenke
2013/12/05 21:34:03
While you're fixing this file, should add includes
davidben
2013/12/05 22:43:20
Done. I kinda wonder if we should just have a sing
mmenke
2013/12/06 16:15:39
Indeed. Even just having one include the other wo
|
| }; |