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 #include "webkit/browser/fileapi/sandbox_file_stream_writer.h" | 5 #include "webkit/browser/fileapi/sandbox_file_stream_writer.h" |
6 | 6 |
7 #include "base/files/file_util_proxy.h" | 7 #include "base/files/file_util_proxy.h" |
8 #include "base/sequenced_task_runner.h" | 8 #include "base/sequenced_task_runner.h" |
9 #include "net/base/io_buffer.h" | 9 #include "net/base/io_buffer.h" |
10 #include "net/base/net_errors.h" | 10 #include "net/base/net_errors.h" |
11 #include "webkit/browser/blob/file_stream_reader.h" | 11 #include "webkit/browser/blob/file_stream_reader.h" |
12 #include "webkit/browser/fileapi/file_observers.h" | 12 #include "webkit/browser/fileapi/file_observers.h" |
13 #include "webkit/browser/fileapi/file_stream_writer.h" | 13 #include "webkit/browser/fileapi/file_stream_writer.h" |
14 #include "webkit/browser/fileapi/file_system_context.h" | 14 #include "webkit/browser/fileapi/file_system_context.h" |
15 #include "webkit/browser/fileapi/file_system_operation_runner.h" | 15 #include "webkit/browser/fileapi/file_system_operation_runner.h" |
16 #include "webkit/browser/quota/quota_manager_proxy.h" | 16 #include "webkit/browser/quota/quota_manager_proxy.h" |
17 #include "webkit/common/fileapi/file_system_util.h" | 17 #include "webkit/common/fileapi/file_system_util.h" |
18 | 18 |
19 namespace fileapi { | 19 namespace storage { |
20 | 20 |
21 namespace { | 21 namespace { |
22 | 22 |
23 // Adjust the |quota| value in overwriting case (i.e. |file_size| > 0 and | 23 // Adjust the |quota| value in overwriting case (i.e. |file_size| > 0 and |
24 // |file_offset| < |file_size|) to make the remaining quota calculation easier. | 24 // |file_offset| < |file_size|) to make the remaining quota calculation easier. |
25 // Specifically this widens the quota for overlapping range (so that we can | 25 // Specifically this widens the quota for overlapping range (so that we can |
26 // simply compare written bytes against the adjusted quota). | 26 // simply compare written bytes against the adjusted quota). |
27 int64 AdjustQuotaForOverlap(int64 quota, | 27 int64 AdjustQuotaForOverlap(int64 quota, |
28 int64 file_offset, | 28 int64 file_offset, |
29 int64 file_size) { | 29 int64 file_size) { |
(...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
107 if (result != net::ERR_IO_PENDING) | 107 if (result != net::ERR_IO_PENDING) |
108 has_pending_operation_ = false; | 108 has_pending_operation_ = false; |
109 return result; | 109 return result; |
110 } | 110 } |
111 | 111 |
112 void SandboxFileStreamWriter::DidCreateSnapshotFile( | 112 void SandboxFileStreamWriter::DidCreateSnapshotFile( |
113 const net::CompletionCallback& callback, | 113 const net::CompletionCallback& callback, |
114 base::File::Error file_error, | 114 base::File::Error file_error, |
115 const base::File::Info& file_info, | 115 const base::File::Info& file_info, |
116 const base::FilePath& platform_path, | 116 const base::FilePath& platform_path, |
117 const scoped_refptr<webkit_blob::ShareableFileReference>& file_ref) { | 117 const scoped_refptr<storage::ShareableFileReference>& file_ref) { |
118 DCHECK(!file_ref.get()); | 118 DCHECK(!file_ref.get()); |
119 | 119 |
120 if (CancelIfRequested()) | 120 if (CancelIfRequested()) |
121 return; | 121 return; |
122 if (file_error != base::File::FILE_OK) { | 122 if (file_error != base::File::FILE_OK) { |
123 callback.Run(net::FileErrorToNetError(file_error)); | 123 callback.Run(net::FileErrorToNetError(file_error)); |
124 return; | 124 return; |
125 } | 125 } |
126 if (file_info.is_directory) { | 126 if (file_info.is_directory) { |
127 // We should not be writing to a directory. | 127 // We should not be writing to a directory. |
128 callback.Run(net::ERR_ACCESS_DENIED); | 128 callback.Run(net::ERR_ACCESS_DENIED); |
129 return; | 129 return; |
130 } | 130 } |
131 file_size_ = file_info.size; | 131 file_size_ = file_info.size; |
132 if (initial_offset_ > file_size_) { | 132 if (initial_offset_ > file_size_) { |
133 LOG(ERROR) << initial_offset_ << ", " << file_size_; | 133 LOG(ERROR) << initial_offset_ << ", " << file_size_; |
134 // This shouldn't happen as long as we check offset in the renderer. | 134 // This shouldn't happen as long as we check offset in the renderer. |
135 NOTREACHED(); | 135 NOTREACHED(); |
136 initial_offset_ = file_size_; | 136 initial_offset_ = file_size_; |
137 } | 137 } |
138 DCHECK(!local_file_writer_.get()); | 138 DCHECK(!local_file_writer_.get()); |
139 local_file_writer_.reset(FileStreamWriter::CreateForLocalFile( | 139 local_file_writer_.reset(FileStreamWriter::CreateForLocalFile( |
140 file_system_context_->default_file_task_runner(), | 140 file_system_context_->default_file_task_runner(), |
141 platform_path, | 141 platform_path, |
142 initial_offset_, | 142 initial_offset_, |
143 FileStreamWriter::OPEN_EXISTING_FILE)); | 143 FileStreamWriter::OPEN_EXISTING_FILE)); |
144 | 144 |
145 quota::QuotaManagerProxy* quota_manager_proxy = | 145 storage::QuotaManagerProxy* quota_manager_proxy = |
146 file_system_context_->quota_manager_proxy(); | 146 file_system_context_->quota_manager_proxy(); |
147 if (!quota_manager_proxy) { | 147 if (!quota_manager_proxy) { |
148 // If we don't have the quota manager or the requested filesystem type | 148 // If we don't have the quota manager or the requested filesystem type |
149 // does not support quota, we should be able to let it go. | 149 // does not support quota, we should be able to let it go. |
150 allowed_bytes_to_write_ = default_quota_; | 150 allowed_bytes_to_write_ = default_quota_; |
151 callback.Run(net::OK); | 151 callback.Run(net::OK); |
152 return; | 152 return; |
153 } | 153 } |
154 | 154 |
155 DCHECK(quota_manager_proxy->quota_manager()); | 155 DCHECK(quota_manager_proxy->quota_manager()); |
156 quota_manager_proxy->quota_manager()->GetUsageAndQuota( | 156 quota_manager_proxy->quota_manager()->GetUsageAndQuota( |
157 url_.origin(), | 157 url_.origin(), |
158 FileSystemTypeToQuotaStorageType(url_.type()), | 158 FileSystemTypeToQuotaStorageType(url_.type()), |
159 base::Bind(&SandboxFileStreamWriter::DidGetUsageAndQuota, | 159 base::Bind(&SandboxFileStreamWriter::DidGetUsageAndQuota, |
160 weak_factory_.GetWeakPtr(), callback)); | 160 weak_factory_.GetWeakPtr(), callback)); |
161 } | 161 } |
162 | 162 |
163 void SandboxFileStreamWriter::DidGetUsageAndQuota( | 163 void SandboxFileStreamWriter::DidGetUsageAndQuota( |
164 const net::CompletionCallback& callback, | 164 const net::CompletionCallback& callback, |
165 quota::QuotaStatusCode status, | 165 storage::QuotaStatusCode status, |
166 int64 usage, int64 quota) { | 166 int64 usage, |
| 167 int64 quota) { |
167 if (CancelIfRequested()) | 168 if (CancelIfRequested()) |
168 return; | 169 return; |
169 if (status != quota::kQuotaStatusOk) { | 170 if (status != storage::kQuotaStatusOk) { |
170 LOG(WARNING) << "Got unexpected quota error : " << status; | 171 LOG(WARNING) << "Got unexpected quota error : " << status; |
171 callback.Run(net::ERR_FAILED); | 172 callback.Run(net::ERR_FAILED); |
172 return; | 173 return; |
173 } | 174 } |
174 | 175 |
175 allowed_bytes_to_write_ = quota - usage; | 176 allowed_bytes_to_write_ = quota - usage; |
176 callback.Run(net::OK); | 177 callback.Run(net::OK); |
177 } | 178 } |
178 | 179 |
179 void SandboxFileStreamWriter::DidInitializeForWrite( | 180 void SandboxFileStreamWriter::DidInitializeForWrite( |
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
236 DCHECK(!has_pending_operation_); | 237 DCHECK(!has_pending_operation_); |
237 DCHECK(cancel_callback_.is_null()); | 238 DCHECK(cancel_callback_.is_null()); |
238 | 239 |
239 // Write() is not called yet, so there's nothing to flush. | 240 // Write() is not called yet, so there's nothing to flush. |
240 if (!local_file_writer_) | 241 if (!local_file_writer_) |
241 return net::OK; | 242 return net::OK; |
242 | 243 |
243 return local_file_writer_->Flush(callback); | 244 return local_file_writer_->Flush(callback); |
244 } | 245 } |
245 | 246 |
246 } // namespace fileapi | 247 } // namespace storage |
OLD | NEW |