| OLD | NEW |
| 1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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_SIMPLE_SIMPLE_ENTRY_IMPL_H_ | 5 #ifndef NET_DISK_CACHE_SIMPLE_SIMPLE_ENTRY_IMPL_H_ |
| 6 #define NET_DISK_CACHE_SIMPLE_SIMPLE_ENTRY_IMPL_H_ | 6 #define NET_DISK_CACHE_SIMPLE_SIMPLE_ENTRY_IMPL_H_ |
| 7 | 7 |
| 8 #include <queue> | 8 #include <queue> |
| 9 #include <string> | 9 #include <string> |
| 10 | 10 |
| (...skipping 21 matching lines...) Expand all Loading... |
| 32 namespace disk_cache { | 32 namespace disk_cache { |
| 33 | 33 |
| 34 class SimpleBackendImpl; | 34 class SimpleBackendImpl; |
| 35 class SimpleSynchronousEntry; | 35 class SimpleSynchronousEntry; |
| 36 class SimpleEntryStat; | 36 class SimpleEntryStat; |
| 37 struct SimpleEntryCreationResults; | 37 struct SimpleEntryCreationResults; |
| 38 | 38 |
| 39 // SimpleEntryImpl is the IO thread interface to an entry in the very simple | 39 // SimpleEntryImpl is the IO thread interface to an entry in the very simple |
| 40 // disk cache. It proxies for the SimpleSynchronousEntry, which performs IO | 40 // disk cache. It proxies for the SimpleSynchronousEntry, which performs IO |
| 41 // on the worker thread. | 41 // on the worker thread. |
| 42 class NET_EXPORT_PRIVATE SimpleEntryImpl : public Entry, | 42 class NET_EXPORT_PRIVATE SimpleEntryImpl |
| 43 public base::RefCounted<SimpleEntryImpl>, | 43 : public Entry, |
| 44 public base::SupportsWeakPtr<SimpleEntryImpl> { | 44 public base::RefCounted<SimpleEntryImpl>, |
| 45 public base::SupportsWeakPtr<SimpleEntryImpl> { |
| 45 friend class base::RefCounted<SimpleEntryImpl>; | 46 friend class base::RefCounted<SimpleEntryImpl>; |
| 47 |
| 46 public: | 48 public: |
| 47 enum OperationsMode { | 49 enum OperationsMode { |
| 48 NON_OPTIMISTIC_OPERATIONS, | 50 NON_OPTIMISTIC_OPERATIONS, |
| 49 OPTIMISTIC_OPERATIONS, | 51 OPTIMISTIC_OPERATIONS, |
| 50 }; | 52 }; |
| 51 | 53 |
| 52 SimpleEntryImpl(net::CacheType cache_type, | 54 SimpleEntryImpl(net::CacheType cache_type, |
| 53 const base::FilePath& path, | 55 const base::FilePath& path, |
| 54 uint64 entry_hash, | 56 uint64 entry_hash, |
| 55 OperationsMode operations_mode, | 57 OperationsMode operations_mode, |
| (...skipping 200 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 256 scoped_ptr<int> result); | 258 scoped_ptr<int> result); |
| 257 | 259 |
| 258 // Called after an asynchronous doom completes. | 260 // Called after an asynchronous doom completes. |
| 259 void DoomOperationComplete(const CompletionCallback& callback, | 261 void DoomOperationComplete(const CompletionCallback& callback, |
| 260 State state_to_restore, | 262 State state_to_restore, |
| 261 int result); | 263 int result); |
| 262 | 264 |
| 263 // Called after validating the checksums on an entry. Passes through the | 265 // Called after validating the checksums on an entry. Passes through the |
| 264 // original result if successful, propogates the error if the checksum does | 266 // original result if successful, propogates the error if the checksum does |
| 265 // not validate. | 267 // not validate. |
| 266 void ChecksumOperationComplete( | 268 void ChecksumOperationComplete(int stream_index, |
| 267 int stream_index, | 269 int orig_result, |
| 268 int orig_result, | 270 const CompletionCallback& completion_callback, |
| 269 const CompletionCallback& completion_callback, | 271 scoped_ptr<int> result); |
| 270 scoped_ptr<int> result); | |
| 271 | 272 |
| 272 // Called after completion of asynchronous IO and receiving file metadata for | 273 // Called after completion of asynchronous IO and receiving file metadata for |
| 273 // the entry in |entry_stat|. Updates the metadata in the entry and in the | 274 // the entry in |entry_stat|. Updates the metadata in the entry and in the |
| 274 // index to make them available on next IO operations. | 275 // index to make them available on next IO operations. |
| 275 void UpdateDataFromEntryStat(const SimpleEntryStat& entry_stat); | 276 void UpdateDataFromEntryStat(const SimpleEntryStat& entry_stat); |
| 276 | 277 |
| 277 int64 GetDiskUsage() const; | 278 int64 GetDiskUsage() const; |
| 278 | 279 |
| 279 // Used to report histograms. | 280 // Used to report histograms. |
| 280 void RecordReadIsParallelizable(const SimpleEntryOperation& operation) const; | 281 void RecordReadIsParallelizable(const SimpleEntryOperation& operation) const; |
| 281 void RecordWriteDependencyType(const SimpleEntryOperation& operation) const; | 282 void RecordWriteDependencyType(const SimpleEntryOperation& operation) const; |
| 282 | 283 |
| 283 // Reads from the stream 0 data kept in memory. | 284 // Reads from the stream 0 data kept in memory. |
| 284 int ReadStream0Data(net::IOBuffer* buf, int offset, int buf_len); | 285 int ReadStream0Data(net::IOBuffer* buf, int offset, int buf_len); |
| 285 | 286 |
| 286 // Copies data from |buf| to the internal in-memory buffer for stream 0. If | 287 // Copies data from |buf| to the internal in-memory buffer for stream 0. If |
| 287 // |truncate| is set to true, the target buffer will be truncated at |offset| | 288 // |truncate| is set to true, the target buffer will be truncated at |offset| |
| 288 // + |buf_len| before being written. | 289 // + |buf_len| before being written. |
| 289 int SetStream0Data(net::IOBuffer* buf, | 290 int SetStream0Data(net::IOBuffer* buf, |
| 290 int offset, int buf_len, | 291 int offset, |
| 292 int buf_len, |
| 291 bool truncate); | 293 bool truncate); |
| 292 | 294 |
| 293 // Updates |crc32s_| and |crc32s_end_offset_| for a write of the data in | 295 // Updates |crc32s_| and |crc32s_end_offset_| for a write of the data in |
| 294 // |buffer| on |stream_index|, starting at |offset| and of length |length|. | 296 // |buffer| on |stream_index|, starting at |offset| and of length |length|. |
| 295 void AdvanceCrc(net::IOBuffer* buffer, | 297 void AdvanceCrc(net::IOBuffer* buffer, |
| 296 int offset, | 298 int offset, |
| 297 int length, | 299 int length, |
| 298 int stream_index); | 300 int stream_index); |
| 299 | 301 |
| 300 // All nonstatic SimpleEntryImpl methods should always be called on the IO | 302 // All nonstatic SimpleEntryImpl methods should always be called on the IO |
| (...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 363 // 1 on disk, to reduce the number of file descriptors and save disk space. | 365 // 1 on disk, to reduce the number of file descriptors and save disk space. |
| 364 // This strategy allows stream 1 to change size easily. Since stream 0 is only | 366 // This strategy allows stream 1 to change size easily. Since stream 0 is only |
| 365 // used to write HTTP headers, the memory consumption of keeping it in memory | 367 // used to write HTTP headers, the memory consumption of keeping it in memory |
| 366 // is acceptable. | 368 // is acceptable. |
| 367 scoped_refptr<net::GrowableIOBuffer> stream_0_data_; | 369 scoped_refptr<net::GrowableIOBuffer> stream_0_data_; |
| 368 }; | 370 }; |
| 369 | 371 |
| 370 } // namespace disk_cache | 372 } // namespace disk_cache |
| 371 | 373 |
| 372 #endif // NET_DISK_CACHE_SIMPLE_SIMPLE_ENTRY_IMPL_H_ | 374 #endif // NET_DISK_CACHE_SIMPLE_SIMPLE_ENTRY_IMPL_H_ |
| OLD | NEW |