| 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_INDEX_FILE_H_ | 5 #ifndef NET_DISK_CACHE_SIMPLE_SIMPLE_INDEX_FILE_H_ |
| 6 #define NET_DISK_CACHE_SIMPLE_SIMPLE_INDEX_FILE_H_ | 6 #define NET_DISK_CACHE_SIMPLE_SIMPLE_INDEX_FILE_H_ |
| 7 | 7 |
| 8 #include <string> | 8 #include <string> |
| 9 #include <vector> | 9 #include <vector> |
| 10 | 10 |
| (...skipping 79 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 90 bool app_on_background); | 90 bool app_on_background); |
| 91 | 91 |
| 92 // Doom the entries specified in |entry_hashes|, calling |reply_callback| | 92 // Doom the entries specified in |entry_hashes|, calling |reply_callback| |
| 93 // with the result on the current thread when done. | 93 // with the result on the current thread when done. |
| 94 virtual void DoomEntrySet(scoped_ptr<std::vector<uint64> > entry_hashes, | 94 virtual void DoomEntrySet(scoped_ptr<std::vector<uint64> > entry_hashes, |
| 95 const base::Callback<void(int)>& reply_callback); | 95 const base::Callback<void(int)>& reply_callback); |
| 96 | 96 |
| 97 private: | 97 private: |
| 98 friend class WrappedSimpleIndexFile; | 98 friend class WrappedSimpleIndexFile; |
| 99 | 99 |
| 100 // Used for cache directory traversal. |
| 101 typedef base::Callback<void (const base::FilePath&)> EntryFileCallback; |
| 102 |
| 100 // When loading the entries from disk, add this many extra hash buckets to | 103 // When loading the entries from disk, add this many extra hash buckets to |
| 101 // prevent reallocation on the IO thread when merging in new live entries. | 104 // prevent reallocation on the IO thread when merging in new live entries. |
| 102 static const int kExtraSizeForMerge = 512; | 105 static const int kExtraSizeForMerge = 512; |
| 103 | 106 |
| 104 // Synchronous (IO performing) implementation of LoadIndexEntries. | 107 // Synchronous (IO performing) implementation of LoadIndexEntries. |
| 105 static void SyncLoadIndexEntries(base::Time cache_last_modified, | 108 static void SyncLoadIndexEntries(base::Time cache_last_modified, |
| 106 const base::FilePath& cache_directory, | 109 const base::FilePath& cache_directory, |
| 107 const base::FilePath& index_file_path, | 110 const base::FilePath& index_file_path, |
| 108 SimpleIndexLoadResult* out_result); | 111 SimpleIndexLoadResult* out_result); |
| 109 | 112 |
| 110 // Load the index file from disk returning an EntrySet. Upon failure, returns | 113 // Load the index file from disk returning an EntrySet. Upon failure, returns |
| 111 // NULL. | 114 // NULL. |
| 112 static void SyncLoadFromDisk(const base::FilePath& index_filename, | 115 static void SyncLoadFromDisk(const base::FilePath& index_filename, |
| 113 SimpleIndexLoadResult* out_result); | 116 SimpleIndexLoadResult* out_result); |
| 114 | 117 |
| 115 // Returns a scoped_ptr for a newly allocated Pickle containing the serialized | 118 // Returns a scoped_ptr for a newly allocated Pickle containing the serialized |
| 116 // data to be written to a file. | 119 // data to be written to a file. |
| 117 static scoped_ptr<Pickle> Serialize( | 120 static scoped_ptr<Pickle> Serialize( |
| 118 const SimpleIndexFile::IndexMetadata& index_metadata, | 121 const SimpleIndexFile::IndexMetadata& index_metadata, |
| 119 const SimpleIndex::EntrySet& entries); | 122 const SimpleIndex::EntrySet& entries); |
| 120 | 123 |
| 121 // Given the contents of an index file |data| of length |data_len|, returns | 124 // Given the contents of an index file |data| of length |data_len|, returns |
| 122 // the corresponding EntrySet. Returns NULL on error. | 125 // the corresponding EntrySet. Returns NULL on error. |
| 123 static void Deserialize(const char* data, int data_len, | 126 static void Deserialize(const char* data, int data_len, |
| 124 SimpleIndexLoadResult* out_result); | 127 SimpleIndexLoadResult* out_result); |
| 125 | 128 |
| 129 // Implemented either in simple_index_file_posix.cc or |
| 130 // simple_index_file_win.cc. base::FileEnumerator turned out to be very |
| 131 // expensive in terms of memory usage therefore it's used only on non-POSIX |
| 132 // environments for convenience (for now). Returns whether the traversal |
| 133 // succeeded. |
| 134 static bool TraverseCacheDirectory( |
| 135 const base::FilePath& cache_path, |
| 136 const EntryFileCallback& entry_file_callback); |
| 137 |
| 126 // Scan the index directory for entries, returning an EntrySet of all entries | 138 // Scan the index directory for entries, returning an EntrySet of all entries |
| 127 // found. | 139 // found. |
| 128 static void SyncRestoreFromDisk(const base::FilePath& cache_directory, | 140 static void SyncRestoreFromDisk(const base::FilePath& cache_directory, |
| 129 const base::FilePath& index_file_path, | 141 const base::FilePath& index_file_path, |
| 130 SimpleIndexLoadResult* out_result); | 142 SimpleIndexLoadResult* out_result); |
| 131 | 143 |
| 132 // Determines if an index file is stale relative to the time of last | 144 // Determines if an index file is stale relative to the time of last |
| 133 // modification of the cache directory. | 145 // modification of the cache directory. |
| 134 static bool IsIndexFileStale(base::Time cache_last_modified, | 146 static bool IsIndexFileStale(base::Time cache_last_modified, |
| 135 const base::FilePath& index_file_path); | 147 const base::FilePath& index_file_path); |
| 136 | 148 |
| 137 struct PickleHeader : public Pickle::Header { | 149 struct PickleHeader : public Pickle::Header { |
| 138 uint32 crc; | 150 uint32 crc; |
| 139 }; | 151 }; |
| 140 | 152 |
| 141 const scoped_refptr<base::SingleThreadTaskRunner> cache_thread_; | 153 const scoped_refptr<base::SingleThreadTaskRunner> cache_thread_; |
| 142 const scoped_refptr<base::TaskRunner> worker_pool_; | 154 const scoped_refptr<base::TaskRunner> worker_pool_; |
| 143 const base::FilePath cache_directory_; | 155 const base::FilePath cache_directory_; |
| 144 const base::FilePath index_file_; | 156 const base::FilePath index_file_; |
| 145 const base::FilePath temp_index_file_; | 157 const base::FilePath temp_index_file_; |
| 146 | 158 |
| 147 static const char kIndexFileName[]; | |
| 148 static const char kTempIndexFileName[]; | |
| 149 | |
| 150 DISALLOW_COPY_AND_ASSIGN(SimpleIndexFile); | 159 DISALLOW_COPY_AND_ASSIGN(SimpleIndexFile); |
| 151 }; | 160 }; |
| 152 | 161 |
| 153 | 162 |
| 154 } // namespace disk_cache | 163 } // namespace disk_cache |
| 155 | 164 |
| 156 #endif // NET_DISK_CACHE_SIMPLE_SIMPLE_INDEX_FILE_H_ | 165 #endif // NET_DISK_CACHE_SIMPLE_SIMPLE_INDEX_FILE_H_ |
| OLD | NEW |