OLD | NEW |
1 // Copyright (c) 2013 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2013 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 "ppapi/proxy/file_system_resource.h" | 5 #include "ppapi/proxy/file_system_resource.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/stl_util.h" | 8 #include "base/stl_util.h" |
9 #include "ipc/ipc_message.h" | 9 #include "ipc/ipc_message.h" |
10 #include "ppapi/c/pp_errors.h" | 10 #include "ppapi/c/pp_errors.h" |
(...skipping 157 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
168 callback_result_ = params.result(); | 168 callback_result_ = params.result(); |
169 // Received callback from browser and renderer. | 169 // Received callback from browser and renderer. |
170 if (callback_count_ == 2) | 170 if (callback_count_ == 2) |
171 callback.Run(callback_result_); | 171 callback.Run(callback_result_); |
172 } | 172 } |
173 | 173 |
174 void FileSystemResource::ReserveQuota(int64_t amount) { | 174 void FileSystemResource::ReserveQuota(int64_t amount) { |
175 DCHECK(!reserving_quota_); | 175 DCHECK(!reserving_quota_); |
176 reserving_quota_ = true; | 176 reserving_quota_ = true; |
177 | 177 |
178 // TODO(tzik): Use FileGrowthMap here after the IPC signature changed. | 178 FileGrowthMap file_growths; |
179 FileSizeMap file_sizes; | |
180 for (std::set<PP_Resource>::iterator it = files_.begin(); | 179 for (std::set<PP_Resource>::iterator it = files_.begin(); |
181 it != files_.end(); ++it) { | 180 it != files_.end(); ++it) { |
182 EnterResourceNoLock<PPB_FileIO_API> enter(*it, true); | 181 EnterResourceNoLock<PPB_FileIO_API> enter(*it, true); |
183 if (enter.failed()) | 182 if (enter.failed()) |
184 continue; | 183 continue; |
185 PPB_FileIO_API* file_io_api = enter.object(); | 184 PPB_FileIO_API* file_io_api = enter.object(); |
186 file_sizes[*it] = | 185 file_growths[*it] = FileGrowth( |
187 file_io_api->GetMaxWrittenOffset() + | 186 file_io_api->GetMaxWrittenOffset(), |
188 file_io_api->GetAppendModeWriteAmount(); | 187 file_io_api->GetAppendModeWriteAmount()); |
189 } | 188 } |
190 Call<PpapiPluginMsg_FileSystem_ReserveQuotaReply>(BROWSER, | 189 Call<PpapiPluginMsg_FileSystem_ReserveQuotaReply>(BROWSER, |
191 PpapiHostMsg_FileSystem_ReserveQuota(amount, file_sizes), | 190 PpapiHostMsg_FileSystem_ReserveQuota(amount, file_growths), |
192 base::Bind(&FileSystemResource::ReserveQuotaComplete, | 191 base::Bind(&FileSystemResource::ReserveQuotaComplete, |
193 this)); | 192 this)); |
194 } | 193 } |
195 | 194 |
196 void FileSystemResource::ReserveQuotaComplete( | 195 void FileSystemResource::ReserveQuotaComplete( |
197 const ResourceMessageReplyParams& params, | 196 const ResourceMessageReplyParams& params, |
198 int64_t amount, | 197 int64_t amount, |
199 const FileSizeMap& max_written_offsets) { | 198 const FileSizeMap& max_written_offsets) { |
200 DCHECK(reserving_quota_); | 199 DCHECK(reserving_quota_); |
201 reserving_quota_ = false; | 200 reserving_quota_ = false; |
(...skipping 26 matching lines...) Expand all Loading... |
228 // Refresh the quota reservation for the first pending request that we | 227 // Refresh the quota reservation for the first pending request that we |
229 // can't satisfy. | 228 // can't satisfy. |
230 ReserveQuota(request.amount); | 229 ReserveQuota(request.amount); |
231 break; | 230 break; |
232 } | 231 } |
233 } | 232 } |
234 } | 233 } |
235 | 234 |
236 } // namespace proxy | 235 } // namespace proxy |
237 } // namespace ppapi | 236 } // namespace ppapi |
OLD | NEW |