Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(1)

Side by Side Diff: storage/browser/blob/blob_entry.h

Issue 2550113003: Revert of [BlobStorage] Implementing disk. (Closed)
Patch Set: Created 4 years ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
« no previous file with comments | « content/test/data/blob_storage/common.js ('k') | storage/browser/blob/blob_entry.cc » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
1 // Copyright 2015 The Chromium Authors. All rights reserved. 1 // Copyright 2015 The Chromium Authors. All rights reserved.
2 // Use of this source code is governed by a BSD-style license that can be 2 // Use of this source code is governed by a BSD-style license that can be
3 // found in the LICENSE file. 3 // found in the LICENSE file.
4 4
5 #ifndef STORAGE_BROWSER_BLOB_BLOB_ENTRY_H_ 5 #ifndef STORAGE_BROWSER_BLOB_BLOB_ENTRY_H_
6 #define STORAGE_BROWSER_BLOB_BLOB_ENTRY_H_ 6 #define STORAGE_BROWSER_BLOB_BLOB_ENTRY_H_
7 7
8 #include <stddef.h> 8 #include <stddef.h>
9 9
10 #include <memory> 10 #include <memory>
11 #include <string> 11 #include <string>
12 #include <vector> 12 #include <vector>
13 13
14 #include "base/callback_forward.h" 14 #include "base/callback_forward.h"
15 #include "base/macros.h" 15 #include "base/macros.h"
16 #include "base/memory/ref_counted.h" 16 #include "base/memory/ref_counted.h"
17 #include "base/memory/weak_ptr.h" 17 #include "base/memory/weak_ptr.h"
18 #include "base/optional.h" 18 #include "base/optional.h"
19 #include "storage/browser/blob/blob_memory_controller.h" 19 #include "storage/browser/blob/blob_memory_controller.h"
20 #include "storage/browser/storage_browser_export.h" 20 #include "storage/browser/storage_browser_export.h"
21 21
22 namespace storage { 22 namespace storage {
23 class BlobDataHandle; 23 class BlobDataHandle;
24 class ShareableBlobDataItem; 24 class ShareableBlobDataItem;
25 class ViewBlobInternalsJob; 25 class ViewBlobInternalsJob;
26 26
27 // Represents a blob in BlobStorageRegistry. Exported only for unit tests. 27 // This class represents a blob in BlobStorageRegistry. We export this only for
28 // unit tests.
28 class STORAGE_EXPORT BlobEntry { 29 class STORAGE_EXPORT BlobEntry {
29 public: 30 public:
30 using TransportAllowedCallback = 31 using TransportAllowedCallback =
31 base::Callback<void(BlobStatus, 32 base::Callback<void(BlobStatus,
32 std::vector<BlobMemoryController::FileCreationInfo>)>; 33 std::vector<BlobMemoryController::FileCreationInfo>)>;
33 34
34 // Records a copy from a referenced blob. Copies happen after referenced blobs 35 // This records a copy from a referenced blob. When we finish building our
35 // are complete & quota for the copies is granted. 36 // blob we perform all of these copies.
36 struct STORAGE_EXPORT ItemCopyEntry { 37 struct STORAGE_EXPORT ItemCopyEntry {
37 ItemCopyEntry(scoped_refptr<ShareableBlobDataItem> source_item, 38 ItemCopyEntry(scoped_refptr<ShareableBlobDataItem> source_item,
38 size_t source_item_offset, 39 size_t source_item_offset,
39 scoped_refptr<ShareableBlobDataItem> dest_item); 40 scoped_refptr<ShareableBlobDataItem> dest_item);
40 ~ItemCopyEntry(); 41 ~ItemCopyEntry();
41 ItemCopyEntry(ItemCopyEntry&& other); 42 ItemCopyEntry(ItemCopyEntry&& other);
42 BlobEntry::ItemCopyEntry& operator=(BlobEntry::ItemCopyEntry&& rhs); 43 BlobEntry::ItemCopyEntry& operator=(BlobEntry::ItemCopyEntry&& rhs);
43 44
44 scoped_refptr<ShareableBlobDataItem> source_item; 45 scoped_refptr<ShareableBlobDataItem> source_item;
45 size_t source_item_offset = 0; 46 size_t source_item_offset = 0;
46 scoped_refptr<ShareableBlobDataItem> dest_item; 47 scoped_refptr<ShareableBlobDataItem> dest_item;
47 48
48 private: 49 private:
49 DISALLOW_COPY_AND_ASSIGN(ItemCopyEntry); 50 DISALLOW_COPY_AND_ASSIGN(ItemCopyEntry);
50 }; 51 };
51 52
52 // Building state for pending blobs. State can include: 53 // This keeps track of our building state for our blob. While building, four
53 // 1. Waiting for quota to be granted for transport data (PENDING_QUOTA) 54 // things can be happening mostly simultaneously:
55 // 1. Waiting for quota to be reserved for memory needed (PENDING_QUOTA)
54 // 2. Waiting for user population of data after quota (PENDING_TRANSPORT) 56 // 2. Waiting for user population of data after quota (PENDING_TRANSPORT)
55 // 3. Waiting for blobs we reference to complete & quota granted for possible 57 // 3. Waiting for blobs we reference to complete (PENDING_INTERNALS)
56 // copies. (PENDING_INTERNALS)
57 struct STORAGE_EXPORT BuildingState { 58 struct STORAGE_EXPORT BuildingState {
58 // |transport_allowed_callback| is not null when data needs population. See 59 // |transport_allowed_callback| is not null when data needs population. See
59 // BlobStorageContext::BuildBlob for when the callback is called. 60 // BlobStorageContext::BuildBlob for when the callback is called.
60 BuildingState(bool transport_items_present, 61 BuildingState(bool transport_items_present,
61 TransportAllowedCallback transport_allowed_callback, 62 TransportAllowedCallback transport_allowed_callback,
62 size_t num_building_dependent_blobs); 63 size_t num_building_dependent_blobs);
63 ~BuildingState(); 64 ~BuildingState();
64 65
65 // Cancels pending memory or file requests.
66 void CancelRequests();
67
68 const bool transport_items_present; 66 const bool transport_items_present;
69 // We can have trasnport data that's either populated or unpopulated. If we 67 // We can have trasnport data that's either populated or unpopulated. If we
70 // need population, this is populated. 68 // need population, this is populated.
71 TransportAllowedCallback transport_allowed_callback; 69 TransportAllowedCallback transport_allowed_callback;
72 std::vector<ShareableBlobDataItem*> transport_items; 70 std::vector<ShareableBlobDataItem*> transport_items;
73 71
74 // Stores all blobs that we're depending on for building. This keeps the 72 // Stores all blobs that we're depending on for building. This keeps the
75 // blobs alive while we build our blob. 73 // blobs alive while we build our blob.
76 std::vector<std::unique_ptr<BlobDataHandle>> dependent_blobs; 74 std::vector<std::unique_ptr<BlobDataHandle>> dependent_blobs;
77 size_t num_building_dependent_blobs; 75 size_t num_building_dependent_blobs;
78 76
79 base::WeakPtr<BlobMemoryController::QuotaAllocationTask> 77 base::WeakPtr<BlobMemoryController::QuotaAllocationTask>
80 transport_quota_request; 78 memory_quota_request;
81
82 // Copy quota is always memory.
83 base::WeakPtr<BlobMemoryController::QuotaAllocationTask> copy_quota_request;
84 79
85 // These are copies from a referenced blob item to our blob items. Some of 80 // These are copies from a referenced blob item to our blob items. Some of
86 // these entries may have changed from bytes to files if they were paged. 81 // these entries may have changed from bytes to files if they were paged.
87 std::vector<ItemCopyEntry> copies; 82 std::vector<ItemCopyEntry> copies;
88 83
89 // When our blob finishes building these callbacks are called. 84 // When our blob finishes building these callbacks are called.
90 std::vector<BlobStatusCallback> build_completion_callbacks; 85 std::vector<BlobStatusCallback> build_completion_callbacks;
91 86
92 private: 87 private:
93 DISALLOW_COPY_AND_ASSIGN(BuildingState); 88 DISALLOW_COPY_AND_ASSIGN(BuildingState);
94 }; 89 };
95 90
96 BlobEntry(const std::string& content_type, 91 BlobEntry(const std::string& content_type,
97 const std::string& content_disposition); 92 const std::string& content_disposition);
98 ~BlobEntry(); 93 ~BlobEntry();
99 94
100 // Appends the given shared blob data item to this object. 95 // Appends the given shared blob data item to this object.
101 void AppendSharedBlobItem(scoped_refptr<ShareableBlobDataItem> item); 96 void AppendSharedBlobItem(scoped_refptr<ShareableBlobDataItem> item);
102 97
103 // Returns if we're a pending blob that can finish building. 98 // Returns if we're a pending blob that can finish building.
104 bool CanFinishBuilding() const { 99 bool CanFinishBuilding() const {
105 // PENDING_INTERNALS means transport is finished. 100 return status_ == BlobStatus::PENDING_INTERNALS &&
106 return status_ == BlobStatus::PENDING_INTERNALS && building_state_ &&
107 !building_state_->copy_quota_request &&
108 building_state_->num_building_dependent_blobs == 0; 101 building_state_->num_building_dependent_blobs == 0;
109 } 102 }
110 103
111 BlobStatus status() const { return status_; } 104 BlobStatus status() const { return status_; }
112 105
113 size_t refcount() const { return refcount_; } 106 size_t refcount() const { return refcount_; }
114 107
115 const std::string& content_type() const { return content_type_; } 108 const std::string& content_type() const { return content_type_; }
116 109
117 const std::string& content_disposition() const { 110 const std::string& content_disposition() const {
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after
162 std::vector<uint64_t> offsets_; 155 std::vector<uint64_t> offsets_;
163 156
164 // Only populated if our status is PENDING_*. 157 // Only populated if our status is PENDING_*.
165 std::unique_ptr<BuildingState> building_state_; 158 std::unique_ptr<BuildingState> building_state_;
166 159
167 DISALLOW_COPY_AND_ASSIGN(BlobEntry); 160 DISALLOW_COPY_AND_ASSIGN(BlobEntry);
168 }; 161 };
169 162
170 } // namespace storage 163 } // namespace storage
171 #endif // STORAGE_BROWSER_BLOB_BLOB_ENTRY_H_ 164 #endif // STORAGE_BROWSER_BLOB_BLOB_ENTRY_H_
OLDNEW
« no previous file with comments | « content/test/data/blob_storage/common.js ('k') | storage/browser/blob/blob_entry.cc » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698