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_helpers.h" | 8 #include "base/callback_helpers.h" |
9 #include "base/command_line.h" | 9 #include "base/command_line.h" |
10 #include "base/files/file_util_proxy.h" | 10 #include "base/files/file_util_proxy.h" |
(...skipping 71 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
82 } | 82 } |
83 | 83 |
84 virtual void DidFail(base::PlatformFileError error_code) OVERRIDE { | 84 virtual void DidFail(base::PlatformFileError error_code) OVERRIDE { |
85 callback_.Run(error_code); | 85 callback_.Run(error_code); |
86 } | 86 } |
87 | 87 |
88 virtual void DidWrite(int64 bytes, bool complete) OVERRIDE { | 88 virtual void DidWrite(int64 bytes, bool complete) OVERRIDE { |
89 NOTREACHED(); | 89 NOTREACHED(); |
90 } | 90 } |
91 | 91 |
92 virtual void DidOpenFile(base::PlatformFile file) OVERRIDE { | 92 virtual void DidOpenFile(base::PlatformFile file, |
| 93 quota::QuotaLimitType quota_policy) OVERRIDE { |
93 NOTREACHED(); | 94 NOTREACHED(); |
94 } | 95 } |
95 | 96 |
96 private: | 97 private: |
97 PlatformGeneralCallback callback_; | 98 PlatformGeneralCallback callback_; |
98 }; | 99 }; |
99 | 100 |
100 int32_t ErrorOrByteNumber(int32_t pp_error, int32_t byte_number) { | 101 int32_t ErrorOrByteNumber(int32_t pp_error, int32_t byte_number) { |
101 // On the plugin side, some callbacks expect a parameter that means different | 102 // On the plugin side, some callbacks expect a parameter that means different |
102 // things depending on whether is negative or not. We translate for those | 103 // things depending on whether is negative or not. We translate for those |
103 // callbacks here. | 104 // callbacks here. |
104 return pp_error == PP_OK ? byte_number : pp_error; | 105 return pp_error == PP_OK ? byte_number : pp_error; |
105 } | 106 } |
106 | 107 |
107 } // namespace | 108 } // namespace |
108 | 109 |
109 PepperFileIOHost::PepperFileIOHost(RendererPpapiHost* host, | 110 PepperFileIOHost::PepperFileIOHost(RendererPpapiHost* host, |
110 PP_Instance instance, | 111 PP_Instance instance, |
111 PP_Resource resource) | 112 PP_Resource resource) |
112 : ResourceHost(host->GetPpapiHost(), instance, resource), | 113 : ResourceHost(host->GetPpapiHost(), instance, resource), |
113 file_(base::kInvalidPlatformFileValue), | 114 file_(base::kInvalidPlatformFileValue), |
114 file_system_type_(PP_FILESYSTEMTYPE_INVALID), | 115 file_system_type_(PP_FILESYSTEMTYPE_INVALID), |
| 116 quota_policy_(quota::kQuotaLimitTypeUnknown), |
115 is_running_in_process_(host->IsRunningInProcess()), | 117 is_running_in_process_(host->IsRunningInProcess()), |
116 weak_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) { | 118 weak_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) { |
117 // TODO(victorhsieh): eliminate plugin_delegate_ as it's no longer needed. | 119 // TODO(victorhsieh): eliminate plugin_delegate_ as it's no longer needed. |
118 webkit::ppapi::PluginInstance* plugin_instance = | 120 webkit::ppapi::PluginInstance* plugin_instance = |
119 webkit::ppapi::HostGlobals::Get()->GetInstance(instance); | 121 webkit::ppapi::HostGlobals::Get()->GetInstance(instance); |
120 plugin_delegate_ = plugin_instance ? plugin_instance->delegate() : NULL; | 122 plugin_delegate_ = plugin_instance ? plugin_instance->delegate() : NULL; |
121 } | 123 } |
122 | 124 |
123 PepperFileIOHost::~PepperFileIOHost() { | 125 PepperFileIOHost::~PepperFileIOHost() { |
124 OnHostMsgClose(NULL); | 126 OnHostMsgClose(NULL); |
(...skipping 322 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
447 context->MakeReplyMessageContext()))) | 449 context->MakeReplyMessageContext()))) |
448 return PP_ERROR_FAILED; | 450 return PP_ERROR_FAILED; |
449 | 451 |
450 state_manager_.SetPendingOperation(FileIOStateManager::OPERATION_EXCLUSIVE); | 452 state_manager_.SetPendingOperation(FileIOStateManager::OPERATION_EXCLUSIVE); |
451 return PP_OK_COMPLETIONPENDING; | 453 return PP_OK_COMPLETIONPENDING; |
452 } | 454 } |
453 | 455 |
454 int32_t PepperFileIOHost::OnHostMsgRequestOSFileHandle( | 456 int32_t PepperFileIOHost::OnHostMsgRequestOSFileHandle( |
455 ppapi::host::HostMessageContext* context) { | 457 ppapi::host::HostMessageContext* context) { |
456 if (!is_running_in_process_ && | 458 if (!is_running_in_process_ && |
| 459 quota_policy_ != quota::kQuotaLimitTypeUnlimited && |
| 460 // TODO(hamaji): Remove the whitelist once it turned out the |
| 461 // quota check is sufficient. http://crbug.com/226386 |
457 !GetContentClient()->renderer()->IsRequestOSFileHandleAllowedForURL( | 462 !GetContentClient()->renderer()->IsRequestOSFileHandleAllowedForURL( |
458 file_system_url_)) | 463 file_system_url_)) |
459 return PP_ERROR_FAILED; | 464 return PP_ERROR_FAILED; |
460 | 465 |
461 // TODO(hamaji): Should fail if quota is not unlimited. | |
462 // http://crbug.com/224123 | |
463 | |
464 RendererPpapiHost* renderer_ppapi_host = | 466 RendererPpapiHost* renderer_ppapi_host = |
465 RendererPpapiHost::GetForPPInstance(pp_instance()); | 467 RendererPpapiHost::GetForPPInstance(pp_instance()); |
466 | 468 |
467 IPC::PlatformFileForTransit file = | 469 IPC::PlatformFileForTransit file = |
468 renderer_ppapi_host->ShareHandleWithRemote(file_, false); | 470 renderer_ppapi_host->ShareHandleWithRemote(file_, false); |
469 if (file == IPC::InvalidPlatformFileForTransit()) | 471 if (file == IPC::InvalidPlatformFileForTransit()) |
470 return PP_ERROR_FAILED; | 472 return PP_ERROR_FAILED; |
471 ppapi::host::ReplyMessageContext reply_context = | 473 ppapi::host::ReplyMessageContext reply_context = |
472 context->MakeReplyMessageContext(); | 474 context->MakeReplyMessageContext(); |
473 reply_context.params.AppendHandle(ppapi::proxy::SerializedHandle( | 475 reply_context.params.AppendHandle(ppapi::proxy::SerializedHandle( |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
526 | 528 |
527 reply_context.params.set_result(pp_error); | 529 reply_context.params.set_result(pp_error); |
528 host()->SendReply(reply_context, PpapiPluginMsg_FileIO_OpenReply()); | 530 host()->SendReply(reply_context, PpapiPluginMsg_FileIO_OpenReply()); |
529 state_manager_.SetOperationFinished(); | 531 state_manager_.SetOperationFinished(); |
530 } | 532 } |
531 | 533 |
532 void PepperFileIOHost::ExecutePlatformOpenFileSystemURLCallback( | 534 void PepperFileIOHost::ExecutePlatformOpenFileSystemURLCallback( |
533 ppapi::host::ReplyMessageContext reply_context, | 535 ppapi::host::ReplyMessageContext reply_context, |
534 base::PlatformFileError error_code, | 536 base::PlatformFileError error_code, |
535 base::PassPlatformFile file, | 537 base::PassPlatformFile file, |
| 538 quota::QuotaLimitType quota_policy, |
536 const PluginDelegate::NotifyCloseFileCallback& callback) { | 539 const PluginDelegate::NotifyCloseFileCallback& callback) { |
537 if (error_code == base::PLATFORM_FILE_OK) | 540 if (error_code == base::PLATFORM_FILE_OK) |
538 notify_close_file_callback_ = callback; | 541 notify_close_file_callback_ = callback; |
| 542 quota_policy_ = quota_policy; |
539 ExecutePlatformOpenFileCallback(reply_context, error_code, file); | 543 ExecutePlatformOpenFileCallback(reply_context, error_code, file); |
540 } | 544 } |
541 | 545 |
542 void PepperFileIOHost::ExecutePlatformQueryCallback( | 546 void PepperFileIOHost::ExecutePlatformQueryCallback( |
543 ppapi::host::ReplyMessageContext reply_context, | 547 ppapi::host::ReplyMessageContext reply_context, |
544 base::PlatformFileError error_code, | 548 base::PlatformFileError error_code, |
545 const base::PlatformFileInfo& file_info) { | 549 const base::PlatformFileInfo& file_info) { |
546 PP_FileInfo pp_info; | 550 PP_FileInfo pp_info; |
547 pp_info.size = file_info.size; | 551 pp_info.size = file_info.size; |
548 pp_info.creation_time = TimeToPPTime(file_info.creation_time); | 552 pp_info.creation_time = TimeToPPTime(file_info.creation_time); |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
593 // On the plugin side, the callback expects a parameter with different meaning | 597 // On the plugin side, the callback expects a parameter with different meaning |
594 // depends on whether is negative or not. It is the result here. We translate | 598 // depends on whether is negative or not. It is the result here. We translate |
595 // for the callback. | 599 // for the callback. |
596 int32_t pp_error = ::ppapi::PlatformFileErrorToPepperError(error_code); | 600 int32_t pp_error = ::ppapi::PlatformFileErrorToPepperError(error_code); |
597 reply_context.params.set_result(ErrorOrByteNumber(pp_error, bytes_written)); | 601 reply_context.params.set_result(ErrorOrByteNumber(pp_error, bytes_written)); |
598 host()->SendReply(reply_context, PpapiPluginMsg_FileIO_GeneralReply()); | 602 host()->SendReply(reply_context, PpapiPluginMsg_FileIO_GeneralReply()); |
599 state_manager_.SetOperationFinished(); | 603 state_manager_.SetOperationFinished(); |
600 } | 604 } |
601 | 605 |
602 } // namespace content | 606 } // namespace content |
OLD | NEW |