OLD | NEW |
1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 #include "content/browser/appcache/chrome_appcache_service.h" | 5 #include "content/browser/appcache/chrome_appcache_service.h" |
6 | 6 |
7 #include "base/file_path.h" | 7 #include "base/file_path.h" |
8 #include "base/file_util.h" | 8 #include "base/file_util.h" |
9 #include "content/browser/content_browser_client.h" | 9 #include "content/browser/content_browser_client.h" |
10 #include "content/common/notification_service.h" | 10 #include "content/common/notification_service.h" |
11 #include "net/base/net_errors.h" | 11 #include "net/base/net_errors.h" |
12 #include "webkit/appcache/appcache_thread.h" | 12 #include "webkit/appcache/appcache_thread.h" |
13 #include "webkit/quota/quota_manager.h" | 13 #include "webkit/quota/quota_manager.h" |
14 | 14 |
15 static bool has_initialized_thread_ids; | 15 static bool has_initialized_thread_ids; |
16 | 16 |
17 namespace { | |
18 | |
19 // Used to defer deleting of local storage until the destructor has finished. | |
20 void DeleteLocalStateOnIOThread(FilePath cache_path) { | |
21 // Post the actual deletion to the DB thread to ensure it happens after the | |
22 // database file has been closed. | |
23 BrowserThread::PostTask( | |
24 BrowserThread::DB, FROM_HERE, | |
25 NewRunnableFunction<bool(*)(const FilePath&, bool), FilePath, bool>( | |
26 &file_util::Delete, cache_path, true)); | |
27 } | |
28 | |
29 } // namespace | |
30 | |
31 // ---------------------------------------------------------------------------- | 17 // ---------------------------------------------------------------------------- |
32 | 18 |
33 ChromeAppCacheService::ChromeAppCacheService( | 19 ChromeAppCacheService::ChromeAppCacheService( |
34 quota::QuotaManagerProxy* quota_manager_proxy) | 20 quota::QuotaManagerProxy* quota_manager_proxy) |
35 : AppCacheService(quota_manager_proxy), | 21 : AppCacheService(quota_manager_proxy), |
36 resource_context_(NULL), clear_local_state_on_exit_(false) { | 22 resource_context_(NULL) { |
37 } | 23 } |
38 | 24 |
39 void ChromeAppCacheService::InitializeOnIOThread( | 25 void ChromeAppCacheService::InitializeOnIOThread( |
40 const FilePath& cache_path, | 26 const FilePath& cache_path, |
41 const content::ResourceContext* resource_context, | 27 const content::ResourceContext* resource_context, |
42 scoped_refptr<quota::SpecialStoragePolicy> special_storage_policy, | 28 scoped_refptr<quota::SpecialStoragePolicy> special_storage_policy) { |
43 bool clear_local_state_on_exit) { | |
44 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 29 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
45 | 30 |
46 if (!has_initialized_thread_ids) { | 31 if (!has_initialized_thread_ids) { |
47 has_initialized_thread_ids = true; | 32 has_initialized_thread_ids = true; |
48 appcache::AppCacheThread::Init(BrowserThread::DB, BrowserThread::IO); | 33 appcache::AppCacheThread::Init(BrowserThread::DB, BrowserThread::IO); |
49 } | 34 } |
50 | 35 |
51 cache_path_ = cache_path; | 36 cache_path_ = cache_path; |
52 resource_context_ = resource_context; | 37 resource_context_ = resource_context; |
53 registrar_.Add( | 38 registrar_.Add( |
54 this, content::NOTIFICATION_PURGE_MEMORY, | 39 this, content::NOTIFICATION_PURGE_MEMORY, |
55 NotificationService::AllSources()); | 40 NotificationService::AllSources()); |
56 SetClearLocalStateOnExit(clear_local_state_on_exit); | |
57 | 41 |
58 // Init our base class. | 42 // Init our base class. |
59 Initialize(cache_path_, | 43 Initialize(cache_path_, |
60 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::CACHE)); | 44 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::CACHE)); |
61 set_appcache_policy(this); | 45 set_appcache_policy(this); |
62 set_special_storage_policy(special_storage_policy); | 46 set_special_storage_policy(special_storage_policy); |
63 } | 47 } |
64 | 48 |
65 ChromeAppCacheService::~ChromeAppCacheService() { | 49 ChromeAppCacheService::~ChromeAppCacheService() { |
66 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | |
67 | |
68 if (clear_local_state_on_exit_ && !cache_path_.empty()) { | |
69 BrowserThread::PostTask( | |
70 BrowserThread::IO, FROM_HERE, | |
71 NewRunnableFunction(DeleteLocalStateOnIOThread, cache_path_)); | |
72 } | |
73 } | |
74 | |
75 void ChromeAppCacheService::SetClearLocalStateOnExit(bool clear_local_state) { | |
76 // TODO(michaeln): How is 'protected' status granted to apps in this case? | |
77 if (!BrowserThread::CurrentlyOn(BrowserThread::IO)) { | |
78 BrowserThread::PostTask( | |
79 BrowserThread::IO, FROM_HERE, | |
80 NewRunnableMethod(this, | |
81 &ChromeAppCacheService::SetClearLocalStateOnExit, | |
82 clear_local_state)); | |
83 return; | |
84 } | |
85 clear_local_state_on_exit_ = clear_local_state; | |
86 } | 50 } |
87 | 51 |
88 bool ChromeAppCacheService::CanLoadAppCache(const GURL& manifest_url) { | 52 bool ChromeAppCacheService::CanLoadAppCache(const GURL& manifest_url) { |
89 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); | 53 DCHECK(BrowserThread::CurrentlyOn(BrowserThread::IO)); |
90 // We don't prompt for read access. | 54 // We don't prompt for read access. |
91 return content::GetContentClient()->browser()->AllowAppCache( | 55 return content::GetContentClient()->browser()->AllowAppCache( |
92 manifest_url, *resource_context_); | 56 manifest_url, *resource_context_); |
93 } | 57 } |
94 | 58 |
95 int ChromeAppCacheService::CanCreateAppCache( | 59 int ChromeAppCacheService::CanCreateAppCache( |
(...skipping 28 matching lines...) Expand all Loading... |
124 const tracked_objects::Location& from_here, | 88 const tracked_objects::Location& from_here, |
125 Task* task) { | 89 Task* task) { |
126 return BrowserThread::PostTask(ToBrowserThreadID(id), from_here, task); | 90 return BrowserThread::PostTask(ToBrowserThreadID(id), from_here, task); |
127 } | 91 } |
128 | 92 |
129 bool AppCacheThread::CurrentlyOn(int id) { | 93 bool AppCacheThread::CurrentlyOn(int id) { |
130 return BrowserThread::CurrentlyOn(ToBrowserThreadID(id)); | 94 return BrowserThread::CurrentlyOn(ToBrowserThreadID(id)); |
131 } | 95 } |
132 | 96 |
133 } // namespace appcache | 97 } // namespace appcache |
OLD | NEW |