// 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. // // The DownloadFileManager owns a set of DownloadFile objects, each of which // represent one in progress download and performs the disk IO for that // download. The DownloadFileManager itself is a singleton object owned by the // ResourceDispatcherHost. // // The DownloadFileManager uses the file_thread for performing file write // operations, in order to avoid disk activity on either the IO (network) thread // and the UI thread. It coordinates the notifications from the network and UI. // // A typical download operation involves multiple threads: // // Updating an in progress download // io_thread // |----> data ---->| // file_thread (writes to disk) // |----> stats ---->| // ui_thread (feedback for user and // updates to history) // // Cancel operations perform the inverse order when triggered by a user action: // ui_thread (user click) // |----> cancel command ---->| // file_thread (close file) // |----> cancel command ---->| // io_thread (stops net IO // for download) // // The DownloadFileManager tracks download requests, mapping from a download // ID (unique integer created in the IO thread) to the DownloadManager for the // tab (profile) where the download was initiated. In the event of a tab closure // during a download, the DownloadFileManager will continue to route data to the // appropriate DownloadManager. In progress downloads are cancelled for a // DownloadManager that exits (such as when closing a profile). #ifndef CHROME_BROWSER_DOWNLOAD_DOWNLOAD_FILE_MANAGER_H_ #define CHROME_BROWSER_DOWNLOAD_DOWNLOAD_FILE_MANAGER_H_ #pragma once #include <map> #include "base/basictypes.h" #include "base/gtest_prod_util.h" #include "base/hash_tables.h" #include "base/memory/ref_counted.h" #include "base/timer.h" #include "ui/gfx/native_widget_types.h" struct DownloadBuffer; struct DownloadCreateInfo; struct DownloadSaveInfo; class DownloadFile; class DownloadManager; class FilePath; class GURL; class ResourceDispatcherHost; namespace net { class URLRequestContextGetter; } // Manages all in progress downloads. class DownloadFileManager : public base::RefCountedThreadSafe<DownloadFileManager> { public: explicit DownloadFileManager(ResourceDispatcherHost* rdh); // Called on shutdown on the UI thread. void Shutdown(); // Called on the IO thread int GetNextId(); // Called on UI thread to make DownloadFileManager start the download. void StartDownload(DownloadCreateInfo* info); // Handlers for notifications sent from the IO thread and run on the // FILE thread. void UpdateDownload(int id, DownloadBuffer* buffer); // |os_error| is 0 for normal completions, and non-0 for errors. // |security_info| contains SSL information (cert_id, cert_status, // security_bits, ssl_connection_status), which can be used to // fine-tune the error message. It is empty if the transaction // was not performed securely. void OnResponseCompleted(int id, DownloadBuffer* buffer, int os_error, const std::string& security_info); // Handlers for notifications sent from the UI thread and run on the // FILE thread. These are both terminal actions with respect to the // download file, as far as the DownloadFileManager is concerned -- if // anything happens to the download file after they are called, it will // be ignored. void CancelDownload(int id); void CompleteDownload(int id); // Called on FILE thread by DownloadManager at the beginning of its shutdown. void OnDownloadManagerShutdown(DownloadManager* manager); // The DownloadManager in the UI thread has provided an intermediate // .crdownload name for the download specified by |id|. void RenameInProgressDownloadFile(int id, const FilePath& full_path); // The DownloadManager in the UI thread has provided a final name for the // download specified by |id|. // |overwrite_existing_file| prevents uniquification, and is used for SAFE // downloads, as the user may have decided to overwrite the file. // Sent from the UI thread and run on the FILE thread. void RenameCompletingDownloadFile(int id, const FilePath& full_path, bool overwrite_existing_file); // The number of downloads currently active on the DownloadFileManager. // Primarily for testing. int NumberOfActiveDownloads() const { return downloads_.size(); } private: friend class base::RefCountedThreadSafe<DownloadFileManager>; friend class DownloadManagerTest; FRIEND_TEST_ALL_PREFIXES(DownloadManagerTest, StartDownload); ~DownloadFileManager(); // Timer helpers for updating the UI about the current progress of a download. void StartUpdateTimer(); void StopUpdateTimer(); void UpdateInProgressDownloads(); // Clean up helper that runs on the download thread. void OnShutdown(); // Creates DownloadFile on FILE thread and continues starting the download // process. void CreateDownloadFile(DownloadCreateInfo* info, DownloadManager* download_manager, bool hash_needed); // Tells the ResourceDispatcherHost to resume a download request // that was paused to wait for the on-disk file to be created. void ResumeDownloadRequest(int child_id, int request_id); // Called only on the download thread. DownloadFile* GetDownloadFile(int id); // Called only from RenameInProgressDownloadFile and // RenameCompletingDownloadFile on the FILE thread. void CancelDownloadOnRename(int id); // Erases the download file with the given the download |id| and removes // it from the maps. void EraseDownload(int id); // Unique ID for each DownloadFile. int next_id_; typedef base::hash_map<int, DownloadFile*> DownloadFileMap; // A map of all in progress downloads. It owns the download files. DownloadFileMap downloads_; // Schedule periodic updates of the download progress. This timer // is controlled from the FILE thread, and posts updates to the UI thread. base::RepeatingTimer<DownloadFileManager> update_timer_; ResourceDispatcherHost* resource_dispatcher_host_; DISALLOW_COPY_AND_ASSIGN(DownloadFileManager); }; #endif // CHROME_BROWSER_DOWNLOAD_DOWNLOAD_FILE_MANAGER_H_