Home | History | Annotate | Download | only in appcache 
      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
      3 // found in the LICENSE file.
      4 
      5 #ifndef WEBKIT_BROWSER_APPCACHE_APPCACHE_DISK_CACHE_H_
      6 #define WEBKIT_BROWSER_APPCACHE_APPCACHE_DISK_CACHE_H_
      7 
      8 #include <set>
      9 #include <vector>
     10 
     11 #include "base/memory/scoped_ptr.h"
     12 #include "net/disk_cache/disk_cache.h"
     13 #include "webkit/browser/appcache/appcache_response.h"
     14 #include "webkit/browser/webkit_storage_browser_export.h"
     15 
     16 namespace appcache {
     17 
     18 // An implementation of AppCacheDiskCacheInterface that
     19 // uses net::DiskCache as the backing store.
     20 class WEBKIT_STORAGE_BROWSER_EXPORT AppCacheDiskCache
     21     : public AppCacheDiskCacheInterface {
     22  public:
     23   AppCacheDiskCache();
     24   virtual ~AppCacheDiskCache();
     25 
     26   // Initializes the object to use disk backed storage.
     27   int InitWithDiskBackend(const base::FilePath& disk_cache_directory,
     28                           int disk_cache_size, bool force,
     29                           base::MessageLoopProxy* cache_thread,
     30                           const net::CompletionCallback& callback);
     31 
     32   // Initializes the object to use memory only storage.
     33   // This is used for Chrome's incognito browsing.
     34   int InitWithMemBackend(int disk_cache_size,
     35                          const net::CompletionCallback& callback);
     36 
     37   void Disable();
     38   bool is_disabled() const { return is_disabled_; }
     39 
     40   virtual int CreateEntry(int64 key, Entry** entry,
     41                           const net::CompletionCallback& callback) OVERRIDE;
     42   virtual int OpenEntry(int64 key, Entry** entry,
     43                         const net::CompletionCallback& callback) OVERRIDE;
     44   virtual int DoomEntry(int64 key,
     45                         const net::CompletionCallback& callback) OVERRIDE;
     46 
     47  private:
     48   class CreateBackendCallbackShim;
     49   class EntryImpl;
     50 
     51   // PendingCalls allow CreateEntry, OpenEntry, and DoomEntry to be called
     52   // immediately after construction, without waiting for the
     53   // underlying disk_cache::Backend to be fully constructed. Early
     54   // calls are queued up and serviced once the disk_cache::Backend is
     55   // really ready to go.
     56   enum PendingCallType {
     57     CREATE,
     58     OPEN,
     59     DOOM
     60   };
     61   struct PendingCall {
     62     PendingCallType call_type;
     63     int64 key;
     64     Entry** entry;
     65     net::CompletionCallback callback;
     66 
     67     PendingCall();
     68 
     69     PendingCall(PendingCallType call_type, int64 key,
     70                 Entry** entry, const net::CompletionCallback& callback);
     71 
     72     ~PendingCall();
     73   };
     74   typedef std::vector<PendingCall> PendingCalls;
     75 
     76   class ActiveCall;
     77   typedef std::set<ActiveCall*> ActiveCalls;
     78 
     79   bool is_initializing() const {
     80     return create_backend_callback_.get() != NULL;
     81   }
     82   disk_cache::Backend* disk_cache() { return disk_cache_.get(); }
     83   int Init(net::CacheType cache_type, const base::FilePath& directory,
     84            int cache_size, bool force, base::MessageLoopProxy* cache_thread,
     85            const net::CompletionCallback& callback);
     86   void OnCreateBackendComplete(int rv);
     87   void AddActiveCall(ActiveCall* call) { active_calls_.insert(call); }
     88   void RemoveActiveCall(ActiveCall* call) { active_calls_.erase(call); }
     89 
     90   bool is_disabled_;
     91   net::CompletionCallback init_callback_;
     92   scoped_refptr<CreateBackendCallbackShim> create_backend_callback_;
     93   PendingCalls pending_calls_;
     94   ActiveCalls active_calls_;
     95   scoped_ptr<disk_cache::Backend> disk_cache_;
     96 };
     97 
     98 }  // namespace appcache
     99 
    100 #endif  // WEBKIT_BROWSER_APPCACHE_APPCACHE_DISK_CACHE_H_
    101