Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(114)

Side by Side Diff: webkit/fileapi/sandbox_quota_observer.cc

Issue 12163003: Add FilePath to base namespace. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 7 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
OLDNEW
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 #include "webkit/fileapi/sandbox_quota_observer.h" 5 #include "webkit/fileapi/sandbox_quota_observer.h"
6 6
7 #include "base/sequenced_task_runner.h" 7 #include "base/sequenced_task_runner.h"
8 #include "webkit/fileapi/file_system_url.h" 8 #include "webkit/fileapi/file_system_url.h"
9 #include "webkit/fileapi/file_system_usage_cache.h" 9 #include "webkit/fileapi/file_system_usage_cache.h"
10 #include "webkit/fileapi/file_system_util.h" 10 #include "webkit/fileapi/file_system_util.h"
(...skipping 11 matching lines...) Expand all
22 update_notify_runner_(update_notify_runner), 22 update_notify_runner_(update_notify_runner),
23 sandbox_file_util_(sandbox_file_util), 23 sandbox_file_util_(sandbox_file_util),
24 running_delayed_cache_update_(false), 24 running_delayed_cache_update_(false),
25 weak_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) {} 25 weak_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) {}
26 26
27 SandboxQuotaObserver::~SandboxQuotaObserver() {} 27 SandboxQuotaObserver::~SandboxQuotaObserver() {}
28 28
29 void SandboxQuotaObserver::OnStartUpdate(const FileSystemURL& url) { 29 void SandboxQuotaObserver::OnStartUpdate(const FileSystemURL& url) {
30 DCHECK(SandboxMountPointProvider::CanHandleType(url.type())); 30 DCHECK(SandboxMountPointProvider::CanHandleType(url.type()));
31 DCHECK(update_notify_runner_->RunsTasksOnCurrentThread()); 31 DCHECK(update_notify_runner_->RunsTasksOnCurrentThread());
32 FilePath usage_file_path = GetUsageCachePath(url); 32 base::FilePath usage_file_path = GetUsageCachePath(url);
33 if (usage_file_path.empty()) 33 if (usage_file_path.empty())
34 return; 34 return;
35 FileSystemUsageCache::IncrementDirty(usage_file_path); 35 FileSystemUsageCache::IncrementDirty(usage_file_path);
36 } 36 }
37 37
38 void SandboxQuotaObserver::OnUpdate(const FileSystemURL& url, 38 void SandboxQuotaObserver::OnUpdate(const FileSystemURL& url,
39 int64 delta) { 39 int64 delta) {
40 DCHECK(SandboxMountPointProvider::CanHandleType(url.type())); 40 DCHECK(SandboxMountPointProvider::CanHandleType(url.type()));
41 DCHECK(update_notify_runner_->RunsTasksOnCurrentThread()); 41 DCHECK(update_notify_runner_->RunsTasksOnCurrentThread());
42 42
43 if (quota_manager_proxy_) { 43 if (quota_manager_proxy_) {
44 quota_manager_proxy_->NotifyStorageModified( 44 quota_manager_proxy_->NotifyStorageModified(
45 quota::QuotaClient::kFileSystem, 45 quota::QuotaClient::kFileSystem,
46 url.origin(), 46 url.origin(),
47 FileSystemTypeToQuotaStorageType(url.type()), 47 FileSystemTypeToQuotaStorageType(url.type()),
48 delta); 48 delta);
49 } 49 }
50 50
51 FilePath usage_file_path = GetUsageCachePath(url); 51 base::FilePath usage_file_path = GetUsageCachePath(url);
52 if (usage_file_path.empty()) 52 if (usage_file_path.empty())
53 return; 53 return;
54 54
55 pending_update_notification_[usage_file_path] += delta; 55 pending_update_notification_[usage_file_path] += delta;
56 if (!running_delayed_cache_update_) { 56 if (!running_delayed_cache_update_) {
57 update_notify_runner_->PostTask(FROM_HERE, base::Bind( 57 update_notify_runner_->PostTask(FROM_HERE, base::Bind(
58 &SandboxQuotaObserver::ApplyPendingUsageUpdate, 58 &SandboxQuotaObserver::ApplyPendingUsageUpdate,
59 weak_factory_.GetWeakPtr())); 59 weak_factory_.GetWeakPtr()));
60 running_delayed_cache_update_ = true; 60 running_delayed_cache_update_ = true;
61 } 61 }
62 } 62 }
63 63
64 void SandboxQuotaObserver::OnEndUpdate(const FileSystemURL& url) { 64 void SandboxQuotaObserver::OnEndUpdate(const FileSystemURL& url) {
65 DCHECK(SandboxMountPointProvider::CanHandleType(url.type())); 65 DCHECK(SandboxMountPointProvider::CanHandleType(url.type()));
66 DCHECK(update_notify_runner_->RunsTasksOnCurrentThread()); 66 DCHECK(update_notify_runner_->RunsTasksOnCurrentThread());
67 67
68 FilePath usage_file_path = GetUsageCachePath(url); 68 base::FilePath usage_file_path = GetUsageCachePath(url);
69 if (usage_file_path.empty()) 69 if (usage_file_path.empty())
70 return; 70 return;
71 71
72 PendingUpdateNotificationMap::iterator found = 72 PendingUpdateNotificationMap::iterator found =
73 pending_update_notification_.find(usage_file_path); 73 pending_update_notification_.find(usage_file_path);
74 if (found != pending_update_notification_.end()) { 74 if (found != pending_update_notification_.end()) {
75 UpdateUsageCacheFile(found->first, found->second); 75 UpdateUsageCacheFile(found->first, found->second);
76 pending_update_notification_.erase(found); 76 pending_update_notification_.erase(found);
77 } 77 }
78 78
79 FileSystemUsageCache::DecrementDirty(usage_file_path); 79 FileSystemUsageCache::DecrementDirty(usage_file_path);
80 } 80 }
81 81
82 void SandboxQuotaObserver::OnAccess(const FileSystemURL& url) { 82 void SandboxQuotaObserver::OnAccess(const FileSystemURL& url) {
83 DCHECK(SandboxMountPointProvider::CanHandleType(url.type())); 83 DCHECK(SandboxMountPointProvider::CanHandleType(url.type()));
84 if (quota_manager_proxy_) { 84 if (quota_manager_proxy_) {
85 quota_manager_proxy_->NotifyStorageAccessed( 85 quota_manager_proxy_->NotifyStorageAccessed(
86 quota::QuotaClient::kFileSystem, 86 quota::QuotaClient::kFileSystem,
87 url.origin(), 87 url.origin(),
88 FileSystemTypeToQuotaStorageType(url.type())); 88 FileSystemTypeToQuotaStorageType(url.type()));
89 } 89 }
90 } 90 }
91 91
92 FilePath SandboxQuotaObserver::GetUsageCachePath(const FileSystemURL& url) { 92 base::FilePath SandboxQuotaObserver::GetUsageCachePath(const FileSystemURL& url) {
93 DCHECK(sandbox_file_util_); 93 DCHECK(sandbox_file_util_);
94 base::PlatformFileError error = base::PLATFORM_FILE_OK; 94 base::PlatformFileError error = base::PLATFORM_FILE_OK;
95 FilePath path = SandboxMountPointProvider::GetUsageCachePathForOriginAndType( 95 base::FilePath path = SandboxMountPointProvider::GetUsageCachePathForOriginAnd Type(
96 sandbox_file_util_, url.origin(), url.type(), &error); 96 sandbox_file_util_, url.origin(), url.type(), &error);
97 if (error != base::PLATFORM_FILE_OK) { 97 if (error != base::PLATFORM_FILE_OK) {
98 LOG(WARNING) << "Could not get usage cache path for: " 98 LOG(WARNING) << "Could not get usage cache path for: "
99 << url.DebugString(); 99 << url.DebugString();
100 return FilePath(); 100 return base::FilePath();
101 } 101 }
102 return path; 102 return path;
103 } 103 }
104 104
105 void SandboxQuotaObserver::ApplyPendingUsageUpdate() { 105 void SandboxQuotaObserver::ApplyPendingUsageUpdate() {
106 for (PendingUpdateNotificationMap::iterator itr = 106 for (PendingUpdateNotificationMap::iterator itr =
107 pending_update_notification_.begin(); 107 pending_update_notification_.begin();
108 itr != pending_update_notification_.end(); 108 itr != pending_update_notification_.end();
109 ++itr) { 109 ++itr) {
110 UpdateUsageCacheFile(itr->first, itr->second); 110 UpdateUsageCacheFile(itr->first, itr->second);
111 } 111 }
112 pending_update_notification_.clear(); 112 pending_update_notification_.clear();
113 running_delayed_cache_update_ = false; 113 running_delayed_cache_update_ = false;
114 } 114 }
115 115
116 void SandboxQuotaObserver::UpdateUsageCacheFile( 116 void SandboxQuotaObserver::UpdateUsageCacheFile(
117 const FilePath& usage_file_path, 117 const base::FilePath& usage_file_path,
118 int64 delta) { 118 int64 delta) {
119 DCHECK(!usage_file_path.empty()); 119 DCHECK(!usage_file_path.empty());
120 if (!usage_file_path.empty() && delta != 0) 120 if (!usage_file_path.empty() && delta != 0)
121 FileSystemUsageCache::AtomicUpdateUsageByDelta(usage_file_path, delta); 121 FileSystemUsageCache::AtomicUpdateUsageByDelta(usage_file_path, delta);
122 } 122 }
123 123
124 } // namespace fileapi 124 } // namespace fileapi
OLDNEW
« no previous file with comments | « webkit/fileapi/sandbox_quota_observer.h ('k') | webkit/fileapi/syncable/canned_syncable_file_system.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698