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 "webkit/fileapi/quota_file_util.h" | 5 #include "webkit/fileapi/quota_file_util.h" |
6 | 6 |
7 #include "base/file_util.h" | 7 #include "base/file_util.h" |
8 #include "base/logging.h" | 8 #include "base/logging.h" |
9 #include "webkit/fileapi/file_system_context.h" | 9 #include "webkit/fileapi/file_system_context.h" |
10 #include "webkit/fileapi/file_system_operation_context.h" | 10 #include "webkit/fileapi/file_system_operation_context.h" |
11 #include "webkit/fileapi/file_system_path_manager.h" | 11 #include "webkit/fileapi/file_system_path_manager.h" |
12 #include "webkit/fileapi/file_system_quota_util.h" | 12 #include "webkit/fileapi/file_system_quota_util.h" |
| 13 #include "webkit/fileapi/native_file_util.h" |
13 #include "webkit/quota/quota_manager.h" | 14 #include "webkit/quota/quota_manager.h" |
14 | 15 |
15 using quota::QuotaManagerProxy; | 16 using quota::QuotaManagerProxy; |
16 | 17 |
17 namespace fileapi { | 18 namespace fileapi { |
18 | 19 |
19 const int64 QuotaFileUtil::kNoLimit = kint64max; | 20 const int64 QuotaFileUtil::kNoLimit = kint64max; |
20 | 21 |
21 namespace { | 22 namespace { |
22 | 23 |
(...skipping 61 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
84 FileSystemQuotaUtil* quota_util_; | 85 FileSystemQuotaUtil* quota_util_; |
85 QuotaManagerProxy* quota_manager_proxy_; | 86 QuotaManagerProxy* quota_manager_proxy_; |
86 const GURL& origin_url_; | 87 const GURL& origin_url_; |
87 FileSystemType type_; | 88 FileSystemType type_; |
88 DISALLOW_COPY_AND_ASSIGN(ScopedOriginUpdateHelper); | 89 DISALLOW_COPY_AND_ASSIGN(ScopedOriginUpdateHelper); |
89 }; | 90 }; |
90 | 91 |
91 } // namespace (anonymous) | 92 } // namespace (anonymous) |
92 | 93 |
93 QuotaFileUtil::QuotaFileUtil(FileSystemFileUtil* underlying_file_util) | 94 QuotaFileUtil::QuotaFileUtil(FileSystemFileUtil* underlying_file_util) |
94 : underlying_file_util_(underlying_file_util) { | 95 : FileSystemFileUtil(underlying_file_util) { |
95 } | 96 } |
96 | 97 |
97 QuotaFileUtil::~QuotaFileUtil() { | 98 QuotaFileUtil::~QuotaFileUtil() { |
98 } | 99 } |
99 | 100 |
100 // static | 101 // static |
101 QuotaFileUtil* QuotaFileUtil::CreateDefault() { | 102 QuotaFileUtil* QuotaFileUtil::CreateDefault() { |
102 return new QuotaFileUtil(new FileSystemFileUtil()); | 103 return new QuotaFileUtil(new NativeFileUtil()); |
| 104 } |
| 105 |
| 106 base::PlatformFileError QuotaFileUtil::Truncate( |
| 107 FileSystemOperationContext* fs_context, |
| 108 const FilePath& path, |
| 109 int64 length) { |
| 110 int64 allowed_bytes_growth = fs_context->allowed_bytes_growth(); |
| 111 ScopedOriginUpdateHelper helper( |
| 112 fs_context, |
| 113 fs_context->src_origin_url(), |
| 114 fs_context->src_type()); |
| 115 |
| 116 int64 growth = 0; |
| 117 base::PlatformFileInfo file_info; |
| 118 if (!file_util::GetFileInfo(path, &file_info)) |
| 119 return base::PLATFORM_FILE_ERROR_FAILED; |
| 120 |
| 121 growth = length - file_info.size; |
| 122 if (allowed_bytes_growth != kNoLimit && |
| 123 growth > 0 && growth > allowed_bytes_growth) |
| 124 return base::PLATFORM_FILE_ERROR_NO_SPACE; |
| 125 |
| 126 base::PlatformFileError error = underlying_file_util()->Truncate( |
| 127 fs_context, path, length); |
| 128 |
| 129 if (error == base::PLATFORM_FILE_OK) |
| 130 helper.NotifyUpdate(growth); |
| 131 |
| 132 return error; |
103 } | 133 } |
104 | 134 |
105 base::PlatformFileError QuotaFileUtil::CopyOrMoveFile( | 135 base::PlatformFileError QuotaFileUtil::CopyOrMoveFile( |
106 FileSystemOperationContext* fs_context, | 136 FileSystemOperationContext* fs_context, |
107 const FilePath& src_file_path, | 137 const FilePath& src_file_path, |
108 const FilePath& dest_file_path, | 138 const FilePath& dest_file_path, |
109 bool copy) { | 139 bool copy) { |
110 DCHECK(fs_context); | 140 DCHECK(fs_context); |
111 | 141 |
112 // TODO(kinuko): For cross-filesystem move case we need 2 helpers, one for | 142 // TODO(kinuko): For cross-filesystem move case we need 2 helpers, one for |
(...skipping 12 matching lines...) Expand all Loading... |
125 // The third argument (growth) is not used for now. | 155 // The third argument (growth) is not used for now. |
126 if (!CanCopy(src_file_path, dest_file_path, allowed_bytes_growth, &growth)) | 156 if (!CanCopy(src_file_path, dest_file_path, allowed_bytes_growth, &growth)) |
127 return base::PLATFORM_FILE_ERROR_NO_SPACE; | 157 return base::PLATFORM_FILE_ERROR_NO_SPACE; |
128 } else { | 158 } else { |
129 base::PlatformFileInfo dest_file_info; | 159 base::PlatformFileInfo dest_file_info; |
130 if (!file_util::GetFileInfo(dest_file_path, &dest_file_info)) | 160 if (!file_util::GetFileInfo(dest_file_path, &dest_file_info)) |
131 dest_file_info.size = 0; | 161 dest_file_info.size = 0; |
132 growth = -dest_file_info.size; | 162 growth = -dest_file_info.size; |
133 } | 163 } |
134 | 164 |
135 base::PlatformFileError error = underlying_file_util_->CopyOrMoveFile( | 165 base::PlatformFileError error = underlying_file_util()->CopyOrMoveFile( |
136 fs_context, src_file_path, dest_file_path, copy); | 166 fs_context, src_file_path, dest_file_path, copy); |
137 | 167 |
138 if (error == base::PLATFORM_FILE_OK) { | 168 if (error == base::PLATFORM_FILE_OK) { |
139 // TODO(kinuko): For cross-filesystem move case, call this with -growth | 169 // TODO(kinuko): For cross-filesystem move case, call this with -growth |
140 // for source and growth for dest. | 170 // for source and growth for dest. |
141 helper.NotifyUpdate(growth); | 171 helper.NotifyUpdate(growth); |
142 } | 172 } |
143 | 173 |
144 return error; | 174 return error; |
145 } | 175 } |
146 | 176 |
147 base::PlatformFileError QuotaFileUtil::DeleteFile( | 177 base::PlatformFileError QuotaFileUtil::DeleteFile( |
148 FileSystemOperationContext* fs_context, | 178 FileSystemOperationContext* fs_context, |
149 const FilePath& file_path) { | 179 const FilePath& file_path) { |
150 DCHECK(fs_context); | 180 DCHECK(fs_context); |
151 ScopedOriginUpdateHelper helper( | 181 ScopedOriginUpdateHelper helper( |
152 fs_context, | 182 fs_context, |
153 fs_context->src_origin_url(), | 183 fs_context->src_origin_url(), |
154 fs_context->src_type()); | 184 fs_context->src_type()); |
155 | 185 |
156 int64 growth = 0; | 186 int64 growth = 0; |
157 base::PlatformFileInfo file_info; | 187 base::PlatformFileInfo file_info; |
158 if (!file_util::GetFileInfo(file_path, &file_info)) | 188 if (!file_util::GetFileInfo(file_path, &file_info)) |
159 file_info.size = 0; | 189 file_info.size = 0; |
160 growth = -file_info.size; | 190 growth = -file_info.size; |
161 | 191 |
162 base::PlatformFileError error = underlying_file_util_->DeleteFile( | 192 base::PlatformFileError error = underlying_file_util()->DeleteFile( |
163 fs_context, file_path); | 193 fs_context, file_path); |
164 | 194 |
165 if (error == base::PLATFORM_FILE_OK) | 195 if (error == base::PLATFORM_FILE_OK) |
166 helper.NotifyUpdate(growth); | 196 helper.NotifyUpdate(growth); |
167 | 197 |
168 return error; | 198 return error; |
169 } | 199 } |
170 | 200 |
171 base::PlatformFileError QuotaFileUtil::Truncate( | |
172 FileSystemOperationContext* fs_context, | |
173 const FilePath& path, | |
174 int64 length) { | |
175 int64 allowed_bytes_growth = fs_context->allowed_bytes_growth(); | |
176 ScopedOriginUpdateHelper helper( | |
177 fs_context, | |
178 fs_context->src_origin_url(), | |
179 fs_context->src_type()); | |
180 | |
181 int64 growth = 0; | |
182 base::PlatformFileInfo file_info; | |
183 if (!file_util::GetFileInfo(path, &file_info)) | |
184 return base::PLATFORM_FILE_ERROR_FAILED; | |
185 | |
186 growth = length - file_info.size; | |
187 if (allowed_bytes_growth != kNoLimit && | |
188 growth > 0 && growth > allowed_bytes_growth) | |
189 return base::PLATFORM_FILE_ERROR_NO_SPACE; | |
190 | |
191 base::PlatformFileError error = underlying_file_util_->Truncate( | |
192 fs_context, path, length); | |
193 | |
194 if (error == base::PLATFORM_FILE_OK) | |
195 helper.NotifyUpdate(growth); | |
196 | |
197 return error; | |
198 } | |
199 | |
200 } // namespace fileapi | 201 } // namespace fileapi |
OLD | NEW |