Index: content/browser/background_fetch/background_fetch_data_manager.h |
diff --git a/content/browser/background_fetch/background_fetch_data_manager.h b/content/browser/background_fetch/background_fetch_data_manager.h |
index 7c38c8e37e2389982336f89151d84a01ddf7ec98..c59f77c793819680686322eddd633abc73bdae31 100644 |
--- a/content/browser/background_fetch/background_fetch_data_manager.h |
+++ b/content/browser/background_fetch/background_fetch_data_manager.h |
@@ -13,8 +13,6 @@ |
#include "base/callback_forward.h" |
#include "base/macros.h" |
#include "base/optional.h" |
-#include "content/browser/background_fetch/background_fetch_job_info.h" |
-#include "content/browser/background_fetch/background_fetch_job_response_data.h" |
#include "content/browser/background_fetch/background_fetch_registration_id.h" |
#include "content/browser/background_fetch/background_fetch_request_info.h" |
#include "content/common/content_export.h" |
@@ -23,6 +21,8 @@ |
namespace content { |
+struct BackgroundFetchSettledFetch; |
+class BlobHandle; |
class BrowserContext; |
class ChromeBlobStorageContext; |
@@ -39,6 +39,10 @@ class CONTENT_EXPORT BackgroundFetchDataManager { |
base::OnceCallback<void(blink::mojom::BackgroundFetchError)>; |
using NextRequestCallback = base::OnceCallback<void( |
const base::Optional<BackgroundFetchRequestInfo>&)>; |
+ using SettledFetchesCallback = |
+ base::OnceCallback<void(blink::mojom::BackgroundFetchError, |
+ std::vector<BackgroundFetchSettledFetch>, |
+ std::vector<std::unique_ptr<BlobHandle>>)>; |
explicit BackgroundFetchDataManager(BrowserContext* browser_context); |
~BackgroundFetchDataManager(); |
@@ -67,78 +71,30 @@ class CONTENT_EXPORT BackgroundFetchDataManager { |
const BackgroundFetchRequestInfo& request, |
NextRequestCallback callback); |
+ // Reads all settled fetches for the given |registration_id|. Both the Request |
+ // and Response objects will be initialised based on the stored data. Will |
+ // invoke the |callback| when the list of fetches has been compiled. |
+ void GetSettledFetchesForRegistration( |
+ const BackgroundFetchRegistrationId& registration_id, |
+ SettledFetchesCallback callback); |
+ |
// Deletes the registration identified by |registration_id|. Will invoke the |
// |callback| when the registration has been deleted from storage. |
void DeleteRegistration(const BackgroundFetchRegistrationId& registration_id, |
DeleteRegistrationCallback callback); |
- // TODO(harkness): Replace the OnceClosure with a callback to return the |
- // response object once it is decided whether lifetime should be passed to the |
- // caller or stay here. |
- void GetJobResponse(const std::string& job_guid, |
- const BackgroundFetchResponseCompleteCallback& callback); |
- |
- // The following methods are called by the JobController to update job state. |
- // Returns a boolean indicating whether there are more requests to process. |
- bool UpdateRequestState(const std::string& job_guid, |
- const std::string& request_guid, |
- DownloadItem::DownloadState state, |
- DownloadInterruptReason interrupt_reason); |
- void UpdateRequestStorageState(const std::string& job_guid, |
- const std::string& request_guid, |
- const base::FilePath& file_path, |
- int64_t received_bytes); |
- void UpdateRequestDownloadGuid(const std::string& job_guid, |
- const std::string& request_guid, |
- const std::string& download_guid); |
- |
- // Called by the JobController to get a BackgroundFetchRequestInfo to |
- // process. |
- const BackgroundFetchRequestInfo& GetNextBackgroundFetchRequestInfo( |
- const std::string& job_guid); |
- |
- // Indicates whether all requests have been handed to the JobController. |
- bool HasRequestsRemaining(const std::string& job_guid) const; |
- |
- // Indicates whether all requests have been handed out and completed. |
- bool IsComplete(const std::string& job_guid) const; |
- |
private: |
friend class BackgroundFetchDataManagerTest; |
class RegistrationData; |
- // Storage interface. |
- void WriteJobToStorage( |
- std::unique_ptr<BackgroundFetchJobInfo> job_info, |
- std::vector<std::unique_ptr<BackgroundFetchRequestInfo>> request_infos); |
- void WriteRequestToStorage(const std::string& job_guid, |
- BackgroundFetchRequestInfo* request_info); |
- std::unique_ptr<BackgroundFetchRequestInfo> GetRequestInfo( |
- const std::string& job_guid, |
- size_t request_index); |
- |
- void DidGetBlobStorageContext( |
- const std::string& job_guid, |
- const BackgroundFetchResponseCompleteCallback& callback, |
- ChromeBlobStorageContext* blob_context); |
- |
- // Indirectly, this is owned by the BrowserContext. |
- BrowserContext* browser_context_; |
+ // The blob storage request with which response information will be stored. |
+ scoped_refptr<ChromeBlobStorageContext> blob_storage_context_; |
// Map of known background fetch registration ids to their associated data. |
std::map<BackgroundFetchRegistrationId, std::unique_ptr<RegistrationData>> |
registrations_; |
- // Map from job_guid to JobInfo. |
- std::unordered_map<std::string, std::unique_ptr<BackgroundFetchJobInfo>> |
- job_map_; |
- |
- // Temporary map to hold data which will be written to storage. |
- // Map from job_guid to RequestInfos. |
- std::unordered_map<std::string, std::vector<BackgroundFetchRequestInfo>> |
- request_map_; |
- |
base::WeakPtrFactory<BackgroundFetchDataManager> weak_ptr_factory_; |
DISALLOW_COPY_AND_ASSIGN(BackgroundFetchDataManager); |