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 "content/renderer/pepper/pepper_file_io_host.h" | 5 #include "content/renderer/pepper/pepper_file_io_host.h" |
6 | 6 |
7 #include "base/bind.h" | 7 #include "base/bind.h" |
8 #include "base/callback.h" | 8 #include "base/callback.h" |
9 #include "base/callback_helpers.h" | 9 #include "base/callback_helpers.h" |
10 #include "base/command_line.h" | 10 #include "base/command_line.h" |
(...skipping 268 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
279 | 279 |
280 int32_t PepperFileIOHost::OnHostMsgWrite( | 280 int32_t PepperFileIOHost::OnHostMsgWrite( |
281 ppapi::host::HostMessageContext* context, | 281 ppapi::host::HostMessageContext* context, |
282 int64_t offset, | 282 int64_t offset, |
283 const std::string& buffer) { | 283 const std::string& buffer) { |
284 int32_t rv = state_manager_.CheckOperationState( | 284 int32_t rv = state_manager_.CheckOperationState( |
285 FileIOStateManager::OPERATION_WRITE, true); | 285 FileIOStateManager::OPERATION_WRITE, true); |
286 if (rv != PP_OK) | 286 if (rv != PP_OK) |
287 return rv; | 287 return rv; |
288 | 288 |
289 if (quota_file_io_.get()) { | 289 if (quota_file_io_) { |
290 if (!quota_file_io_->Write( | 290 if (!quota_file_io_->Write( |
291 offset, buffer.c_str(), buffer.size(), | 291 offset, buffer.c_str(), buffer.size(), |
292 base::Bind(&PepperFileIOHost::ExecutePlatformWriteCallback, | 292 base::Bind(&PepperFileIOHost::ExecutePlatformWriteCallback, |
293 weak_factory_.GetWeakPtr(), | 293 weak_factory_.GetWeakPtr(), |
294 context->MakeReplyMessageContext()))) | 294 context->MakeReplyMessageContext()))) |
295 return PP_ERROR_FAILED; | 295 return PP_ERROR_FAILED; |
296 } else { | 296 } else { |
297 if (!plugin_delegate_) | 297 if (!plugin_delegate_) |
298 return PP_ERROR_FAILED; | 298 return PP_ERROR_FAILED; |
299 | 299 |
(...skipping 80 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
380 | 380 |
381 int32_t PepperFileIOHost::OnHostMsgWillWrite( | 381 int32_t PepperFileIOHost::OnHostMsgWillWrite( |
382 ppapi::host::HostMessageContext* context, | 382 ppapi::host::HostMessageContext* context, |
383 int64_t offset, | 383 int64_t offset, |
384 int32_t bytes_to_write) { | 384 int32_t bytes_to_write) { |
385 int32_t rv = state_manager_.CheckOperationState( | 385 int32_t rv = state_manager_.CheckOperationState( |
386 FileIOStateManager::OPERATION_EXCLUSIVE, true); | 386 FileIOStateManager::OPERATION_EXCLUSIVE, true); |
387 if (rv != PP_OK) | 387 if (rv != PP_OK) |
388 return rv; | 388 return rv; |
389 | 389 |
390 if (!quota_file_io_.get()) | 390 if (!quota_file_io_) |
391 return PP_OK; | 391 return PP_OK; |
392 | 392 |
393 if (!quota_file_io_->WillWrite( | 393 if (!quota_file_io_->WillWrite( |
394 offset, bytes_to_write, | 394 offset, bytes_to_write, |
395 base::Bind(&PepperFileIOHost::ExecutePlatformWriteCallback, | 395 base::Bind(&PepperFileIOHost::ExecutePlatformWriteCallback, |
396 weak_factory_.GetWeakPtr(), | 396 weak_factory_.GetWeakPtr(), |
397 context->MakeReplyMessageContext()))) | 397 context->MakeReplyMessageContext()))) |
398 return PP_ERROR_FAILED; | 398 return PP_ERROR_FAILED; |
399 | 399 |
400 state_manager_.SetPendingOperation(FileIOStateManager::OPERATION_EXCLUSIVE); | 400 state_manager_.SetPendingOperation(FileIOStateManager::OPERATION_EXCLUSIVE); |
401 return PP_OK_COMPLETIONPENDING; | 401 return PP_OK_COMPLETIONPENDING; |
402 } | 402 } |
403 | 403 |
404 int32_t PepperFileIOHost::OnHostMsgWillSetLength( | 404 int32_t PepperFileIOHost::OnHostMsgWillSetLength( |
405 ppapi::host::HostMessageContext* context, | 405 ppapi::host::HostMessageContext* context, |
406 int64_t length) { | 406 int64_t length) { |
407 int32_t rv = state_manager_.CheckOperationState( | 407 int32_t rv = state_manager_.CheckOperationState( |
408 FileIOStateManager::OPERATION_EXCLUSIVE, true); | 408 FileIOStateManager::OPERATION_EXCLUSIVE, true); |
409 if (rv != PP_OK) | 409 if (rv != PP_OK) |
410 return rv; | 410 return rv; |
411 | 411 |
412 if (!quota_file_io_.get()) | 412 if (!quota_file_io_) |
413 return PP_OK; | 413 return PP_OK; |
414 | 414 |
415 if (!quota_file_io_->WillSetLength( | 415 if (!quota_file_io_->WillSetLength( |
416 length, | 416 length, |
417 base::Bind(&PepperFileIOHost::ExecutePlatformGeneralCallback, | 417 base::Bind(&PepperFileIOHost::ExecutePlatformGeneralCallback, |
418 weak_factory_.GetWeakPtr(), | 418 weak_factory_.GetWeakPtr(), |
419 context->MakeReplyMessageContext()))) | 419 context->MakeReplyMessageContext()))) |
420 return PP_ERROR_FAILED; | 420 return PP_ERROR_FAILED; |
421 | 421 |
422 state_manager_.SetPendingOperation(FileIOStateManager::OPERATION_EXCLUSIVE); | 422 state_manager_.SetPendingOperation(FileIOStateManager::OPERATION_EXCLUSIVE); |
(...skipping 134 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
557 // On the plugin side, the callback expects a parameter with different meaning | 557 // On the plugin side, the callback expects a parameter with different meaning |
558 // depends on whether is negative or not. It is the result here. We translate | 558 // depends on whether is negative or not. It is the result here. We translate |
559 // for the callback. | 559 // for the callback. |
560 int32_t pp_error = ::ppapi::PlatformFileErrorToPepperError(error_code); | 560 int32_t pp_error = ::ppapi::PlatformFileErrorToPepperError(error_code); |
561 reply_context.params.set_result(ErrorOrByteNumber(pp_error, bytes_written)); | 561 reply_context.params.set_result(ErrorOrByteNumber(pp_error, bytes_written)); |
562 host()->SendReply(reply_context, PpapiPluginMsg_FileIO_GeneralReply()); | 562 host()->SendReply(reply_context, PpapiPluginMsg_FileIO_GeneralReply()); |
563 state_manager_.SetOperationFinished(); | 563 state_manager_.SetOperationFinished(); |
564 } | 564 } |
565 | 565 |
566 } // namespace content | 566 } // namespace content |
OLD | NEW |