OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 NET_DISK_CACHE_BLOCKFILE_ENTRY_IMPL_V3_H_ | 5 #ifndef NET_DISK_CACHE_BLOCKFILE_ENTRY_IMPL_V3_H_ |
6 #define NET_DISK_CACHE_BLOCKFILE_ENTRY_IMPL_V3_H_ | 6 #define NET_DISK_CACHE_BLOCKFILE_ENTRY_IMPL_V3_H_ |
7 | 7 |
8 #include <string> | 8 #include <string> |
9 | 9 |
10 #include "base/memory/scoped_ptr.h" | 10 #include "base/memory/scoped_ptr.h" |
11 #include "net/base/net_log.h" | 11 #include "net/base/net_log.h" |
12 #include "net/disk_cache/blockfile/disk_format_v3.h" | 12 #include "net/disk_cache/blockfile/disk_format_v3.h" |
13 #include "net/disk_cache/blockfile/storage_block.h" | 13 #include "net/disk_cache/blockfile/storage_block.h" |
14 #include "net/disk_cache/disk_cache.h" | 14 #include "net/disk_cache/disk_cache.h" |
15 | 15 |
16 namespace disk_cache { | 16 namespace disk_cache { |
17 | 17 |
18 class BackendImplV3; | 18 class BackendImplV3; |
19 class SparseControlV3; | 19 class SparseControlV3; |
20 | 20 |
21 // This class implements the Entry interface. An object of this | 21 // This class implements the Entry interface. An object of this |
22 // class represents a single entry on the cache. | 22 // class represents a single entry on the cache. |
23 class NET_EXPORT_PRIVATE EntryImplV3 | 23 class NET_EXPORT_PRIVATE EntryImplV3 : public Entry, |
24 : public Entry, | 24 public base::RefCounted<EntryImplV3> { |
25 public base::RefCounted<EntryImplV3> { | |
26 friend class base::RefCounted<EntryImplV3>; | 25 friend class base::RefCounted<EntryImplV3>; |
27 // friend class SparseControlV3; | 26 // friend class SparseControlV3; |
28 public: | 27 public: |
29 enum Operation { | 28 enum Operation { |
30 kRead, | 29 kRead, |
31 kWrite, | 30 kWrite, |
32 kSparseRead, | 31 kSparseRead, |
33 kSparseWrite, | 32 kSparseWrite, |
34 kAsyncIO, | 33 kAsyncIO, |
35 kReadAsync1, | 34 kReadAsync1, |
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
76 | 75 |
77 const net::BoundNetLog& net_log() const; | 76 const net::BoundNetLog& net_log() const; |
78 | 77 |
79 // Entry interface. | 78 // Entry interface. |
80 virtual void Doom() OVERRIDE; | 79 virtual void Doom() OVERRIDE; |
81 virtual void Close() OVERRIDE; | 80 virtual void Close() OVERRIDE; |
82 virtual std::string GetKey() const OVERRIDE; | 81 virtual std::string GetKey() const OVERRIDE; |
83 virtual base::Time GetLastUsed() const OVERRIDE; | 82 virtual base::Time GetLastUsed() const OVERRIDE; |
84 virtual base::Time GetLastModified() const OVERRIDE; | 83 virtual base::Time GetLastModified() const OVERRIDE; |
85 virtual int32 GetDataSize(int index) const OVERRIDE; | 84 virtual int32 GetDataSize(int index) const OVERRIDE; |
86 virtual int ReadData(int index, int offset, IOBuffer* buf, int buf_len, | 85 virtual int ReadData(int index, |
| 86 int offset, |
| 87 IOBuffer* buf, |
| 88 int buf_len, |
87 const CompletionCallback& callback) OVERRIDE; | 89 const CompletionCallback& callback) OVERRIDE; |
88 virtual int WriteData(int index, int offset, IOBuffer* buf, int buf_len, | 90 virtual int WriteData(int index, |
| 91 int offset, |
| 92 IOBuffer* buf, |
| 93 int buf_len, |
89 const CompletionCallback& callback, | 94 const CompletionCallback& callback, |
90 bool truncate) OVERRIDE; | 95 bool truncate) OVERRIDE; |
91 virtual int ReadSparseData(int64 offset, IOBuffer* buf, int buf_len, | 96 virtual int ReadSparseData(int64 offset, |
| 97 IOBuffer* buf, |
| 98 int buf_len, |
92 const CompletionCallback& callback) OVERRIDE; | 99 const CompletionCallback& callback) OVERRIDE; |
93 virtual int WriteSparseData(int64 offset, IOBuffer* buf, int buf_len, | 100 virtual int WriteSparseData(int64 offset, |
| 101 IOBuffer* buf, |
| 102 int buf_len, |
94 const CompletionCallback& callback) OVERRIDE; | 103 const CompletionCallback& callback) OVERRIDE; |
95 virtual int GetAvailableRange(int64 offset, int len, int64* start, | 104 virtual int GetAvailableRange(int64 offset, |
| 105 int len, |
| 106 int64* start, |
96 const CompletionCallback& callback) OVERRIDE; | 107 const CompletionCallback& callback) OVERRIDE; |
97 virtual bool CouldBeSparse() const OVERRIDE; | 108 virtual bool CouldBeSparse() const OVERRIDE; |
98 virtual void CancelSparseIO() OVERRIDE; | 109 virtual void CancelSparseIO() OVERRIDE; |
99 virtual int ReadyForSparseIO(const CompletionCallback& callback) OVERRIDE; | 110 virtual int ReadyForSparseIO(const CompletionCallback& callback) OVERRIDE; |
100 | 111 |
101 private: | 112 private: |
102 enum { | 113 enum { kNumStreams = 3 }; |
103 kNumStreams = 3 | |
104 }; | |
105 class UserBuffer; | 114 class UserBuffer; |
106 | 115 |
107 virtual ~EntryImplV3(); | 116 virtual ~EntryImplV3(); |
108 | 117 |
109 // Do all the work for ReadDataImpl and WriteDataImpl. Implemented as | 118 // Do all the work for ReadDataImpl and WriteDataImpl. Implemented as |
110 // separate functions to make logging of results simpler. | 119 // separate functions to make logging of results simpler. |
111 int InternalReadData(int index, int offset, IOBuffer* buf, | 120 int InternalReadData(int index, |
112 int buf_len, const CompletionCallback& callback); | 121 int offset, |
113 int InternalWriteData(int index, int offset, IOBuffer* buf, int buf_len, | 122 IOBuffer* buf, |
114 const CompletionCallback& callback, bool truncate); | 123 int buf_len, |
| 124 const CompletionCallback& callback); |
| 125 int InternalWriteData(int index, |
| 126 int offset, |
| 127 IOBuffer* buf, |
| 128 int buf_len, |
| 129 const CompletionCallback& callback, |
| 130 bool truncate); |
115 | 131 |
116 // Initializes the storage for an internal or external data block. | 132 // Initializes the storage for an internal or external data block. |
117 bool CreateDataBlock(int index, int size); | 133 bool CreateDataBlock(int index, int size); |
118 | 134 |
119 // Initializes the storage for an internal or external generic block. | 135 // Initializes the storage for an internal or external generic block. |
120 bool CreateBlock(int size, Addr* address); | 136 bool CreateBlock(int size, Addr* address); |
121 | 137 |
122 // Deletes the data pointed by address, maybe backed by files_[index]. | 138 // Deletes the data pointed by address, maybe backed by files_[index]. |
123 // Note that most likely the caller should delete (and store) the reference to | 139 // Note that most likely the caller should delete (and store) the reference to |
124 // |address| *before* calling this method because we don't want to have an | 140 // |address| *before* calling this method because we don't want to have an |
(...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
178 // point; there is no need to report any storage-size change, only to do the | 194 // point; there is no need to report any storage-size change, only to do the |
179 // actual cleanup. | 195 // actual cleanup. |
180 void GetData(int index, char** buffer, Addr* address); | 196 void GetData(int index, char** buffer, Addr* address); |
181 | 197 |
182 // Generates a histogram for the time spent working on this operation. | 198 // Generates a histogram for the time spent working on this operation. |
183 void ReportIOTime(Operation op, const base::TimeTicks& start); | 199 void ReportIOTime(Operation op, const base::TimeTicks& start); |
184 | 200 |
185 // Logs this entry to the internal trace buffer. | 201 // Logs this entry to the internal trace buffer. |
186 void Log(const char* msg); | 202 void Log(const char* msg); |
187 | 203 |
188 scoped_ptr<EntryRecord> entry_; // Basic record for this entry. | 204 scoped_ptr<EntryRecord> entry_; // Basic record for this entry. |
189 scoped_ptr<ShortEntryRecord> short_entry_; // Valid for evicted entries. | 205 scoped_ptr<ShortEntryRecord> short_entry_; // Valid for evicted entries. |
190 base::WeakPtr<BackendImplV3> backend_; // Back pointer to the cache. | 206 base::WeakPtr<BackendImplV3> backend_; // Back pointer to the cache. |
191 scoped_ptr<UserBuffer> user_buffers_[kNumStreams]; // Stores user data. | 207 scoped_ptr<UserBuffer> user_buffers_[kNumStreams]; // Stores user data. |
192 mutable std::string key_; // Copy of the key. | 208 mutable std::string key_; // Copy of the key. |
193 Addr address_; | 209 Addr address_; |
194 int unreported_size_[kNumStreams]; // Bytes not reported yet to the backend. | 210 int unreported_size_[kNumStreams]; // Bytes not reported yet to the backend. |
195 bool doomed_; // True if this entry was removed from the cache. | 211 bool doomed_; // True if this entry was removed from the cache. |
196 bool read_only_; | 212 bool read_only_; |
197 bool dirty_; // True if there is something to write. | 213 bool dirty_; // True if there is something to write. |
198 bool modified_; | 214 bool modified_; |
199 // scoped_ptr<SparseControlV3> sparse_; // Support for sparse entries. | 215 // scoped_ptr<SparseControlV3> sparse_; // Support for sparse entries. |
200 | 216 |
201 net::BoundNetLog net_log_; | 217 net::BoundNetLog net_log_; |
202 | 218 |
203 DISALLOW_COPY_AND_ASSIGN(EntryImplV3); | 219 DISALLOW_COPY_AND_ASSIGN(EntryImplV3); |
204 }; | 220 }; |
205 | 221 |
206 } // namespace disk_cache | 222 } // namespace disk_cache |
207 | 223 |
208 #endif // NET_DISK_CACHE_BLOCKFILE_ENTRY_IMPL_V3_H_ | 224 #endif // NET_DISK_CACHE_BLOCKFILE_ENTRY_IMPL_V3_H_ |
OLD | NEW |