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 // This file declares a HttpTransactionFactory implementation that can be | 5 // This file declares a HttpTransactionFactory implementation that can be |
6 // layered on top of another HttpTransactionFactory to add HTTP caching. The | 6 // layered on top of another HttpTransactionFactory to add HTTP caching. The |
7 // caching logic follows RFC 2616 (any exceptions are called out in the code). | 7 // caching logic follows RFC 2616 (any exceptions are called out in the code). |
8 // | 8 // |
9 // The HttpCache takes a disk_cache::Backend as a parameter, and uses that for | 9 // The HttpCache takes a disk_cache::Backend as a parameter, and uses that for |
10 // the cache storage. | 10 // the cache storage. |
(...skipping 169 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
180 // Close all idle connections. Will close all sockets not in active use. | 180 // Close all idle connections. Will close all sockets not in active use. |
181 void CloseIdleConnections(); | 181 void CloseIdleConnections(); |
182 | 182 |
183 // Called whenever an external cache in the system reuses the resource | 183 // Called whenever an external cache in the system reuses the resource |
184 // referred to by |url| and |http_method|. | 184 // referred to by |url| and |http_method|. |
185 void OnExternalCacheHit(const GURL& url, const std::string& http_method); | 185 void OnExternalCacheHit(const GURL& url, const std::string& http_method); |
186 | 186 |
187 // Initializes the Infinite Cache, if selected by the field trial. | 187 // Initializes the Infinite Cache, if selected by the field trial. |
188 void InitializeInfiniteCache(const base::FilePath& path); | 188 void InitializeInfiniteCache(const base::FilePath& path); |
189 | 189 |
| 190 // Causes all transactions created after this point to effectively bypass |
| 191 // the cache lock whenever there is lock contention. |
| 192 void BypassLockForTest() { |
| 193 bypass_lock_for_test_ = true; |
| 194 } |
| 195 |
190 // HttpTransactionFactory implementation: | 196 // HttpTransactionFactory implementation: |
191 virtual int CreateTransaction(RequestPriority priority, | 197 virtual int CreateTransaction(RequestPriority priority, |
192 scoped_ptr<HttpTransaction>* trans) OVERRIDE; | 198 scoped_ptr<HttpTransaction>* trans) OVERRIDE; |
193 virtual HttpCache* GetCache() OVERRIDE; | 199 virtual HttpCache* GetCache() OVERRIDE; |
194 virtual HttpNetworkSession* GetSession() OVERRIDE; | 200 virtual HttpNetworkSession* GetSession() OVERRIDE; |
195 | 201 |
196 base::WeakPtr<HttpCache> GetWeakPtr() { return weak_factory_.GetWeakPtr(); } | 202 base::WeakPtr<HttpCache> GetWeakPtr() { return weak_factory_.GetWeakPtr(); } |
197 | 203 |
198 // Resets the network layer to allow for tests that probe | 204 // Resets the network layer to allow for tests that probe |
199 // network changes (e.g. host unreachable). The old network layer is | 205 // network changes (e.g. host unreachable). The old network layer is |
(...skipping 182 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
382 // Processes the backend creation notification. | 388 // Processes the backend creation notification. |
383 void OnBackendCreated(int result, PendingOp* pending_op); | 389 void OnBackendCreated(int result, PendingOp* pending_op); |
384 | 390 |
385 // Variables ---------------------------------------------------------------- | 391 // Variables ---------------------------------------------------------------- |
386 | 392 |
387 NetLog* net_log_; | 393 NetLog* net_log_; |
388 | 394 |
389 // Used when lazily constructing the disk_cache_. | 395 // Used when lazily constructing the disk_cache_. |
390 scoped_ptr<BackendFactory> backend_factory_; | 396 scoped_ptr<BackendFactory> backend_factory_; |
391 bool building_backend_; | 397 bool building_backend_; |
| 398 bool bypass_lock_for_test_; |
392 | 399 |
393 Mode mode_; | 400 Mode mode_; |
394 | 401 |
395 scoped_ptr<QuicServerInfoFactoryAdaptor> quic_server_info_factory_; | 402 scoped_ptr<QuicServerInfoFactoryAdaptor> quic_server_info_factory_; |
396 | 403 |
397 scoped_ptr<HttpTransactionFactory> network_layer_; | 404 scoped_ptr<HttpTransactionFactory> network_layer_; |
398 | 405 |
399 scoped_ptr<disk_cache::Backend> disk_cache_; | 406 scoped_ptr<disk_cache::Backend> disk_cache_; |
400 | 407 |
401 // The set of active entries indexed by cache key. | 408 // The set of active entries indexed by cache key. |
402 ActiveEntriesMap active_entries_; | 409 ActiveEntriesMap active_entries_; |
403 | 410 |
404 // The set of doomed entries. | 411 // The set of doomed entries. |
405 ActiveEntriesSet doomed_entries_; | 412 ActiveEntriesSet doomed_entries_; |
406 | 413 |
407 // The set of entries "under construction". | 414 // The set of entries "under construction". |
408 PendingOpsMap pending_ops_; | 415 PendingOpsMap pending_ops_; |
409 | 416 |
410 scoped_ptr<PlaybackCacheMap> playback_cache_map_; | 417 scoped_ptr<PlaybackCacheMap> playback_cache_map_; |
411 | 418 |
412 base::WeakPtrFactory<HttpCache> weak_factory_; | 419 base::WeakPtrFactory<HttpCache> weak_factory_; |
413 | 420 |
414 DISALLOW_COPY_AND_ASSIGN(HttpCache); | 421 DISALLOW_COPY_AND_ASSIGN(HttpCache); |
415 }; | 422 }; |
416 | 423 |
417 } // namespace net | 424 } // namespace net |
418 | 425 |
419 #endif // NET_HTTP_HTTP_CACHE_H_ | 426 #endif // NET_HTTP_HTTP_CACHE_H_ |
OLD | NEW |