Index: ppapi/proxy/ppb_file_ref_proxy.cc |
=================================================================== |
--- ppapi/proxy/ppb_file_ref_proxy.cc (revision 0) |
+++ ppapi/proxy/ppb_file_ref_proxy.cc (revision 0) |
@@ -0,0 +1,350 @@ |
+// Copyright (c) 2011 The Chromium Authors. All rights reserved. |
+// Use of this source code is governed by a BSD-style license that can be |
+// found in the LICENSE file. |
+ |
+#include "ppapi/proxy/ppb_file_ref_proxy.h" |
+ |
+#include "ppapi/c/dev/ppb_file_ref_dev.h" |
+#include "ppapi/c/pp_errors.h" |
+#include "ppapi/c/private/ppb_proxy_private.h" |
+#include "ppapi/proxy/host_dispatcher.h" |
+#include "ppapi/proxy/plugin_dispatcher.h" |
+#include "ppapi/proxy/plugin_resource.h" |
+#include "ppapi/proxy/ppapi_messages.h" |
+#include "ppapi/proxy/serialized_var.h" |
+ |
+namespace pp { |
+namespace proxy { |
+ |
+// This object maintains most of the state of the ref in the plugin for fast |
+// querying. It's all set in the constructor from the "create info" sent from |
+// the host. |
+class FileRef : public PluginResource { |
+ public: |
+ FileRef(const PPBFileRef_CreateInfo& info); |
+ virtual ~FileRef(); |
+ |
+ virtual FileRef* AsFileRef(); |
+ |
+ PP_FileSystemType_Dev file_system_type() const { return file_system_type_; } |
+ const PP_Var& path() const { return path_; } |
+ const PP_Var& name() const { return name_; } |
+ |
+ private: |
+ PP_FileSystemType_Dev file_system_type_; |
+ PP_Var path_; |
+ PP_Var name_; |
+ |
+ DISALLOW_COPY_AND_ASSIGN(FileRef); |
+}; |
+ |
+FileRef::FileRef(const PPBFileRef_CreateInfo& info) |
+ : PluginResource(info.resource) { |
+ Dispatcher* dispatcher = PluginDispatcher::GetForInstance(instance()); |
+ |
+ file_system_type_ = static_cast<PP_FileSystemType_Dev>(info.file_system_type); |
+ |
+ name_ = ReceiveSerializedVarReturnValue::Convert(dispatcher, info.name); |
+ path_ = ReceiveSerializedVarReturnValue::Convert(dispatcher, info.path); |
+} |
+ |
+FileRef::~FileRef() { |
+ PluginVarTracker::GetInstance()->Release(path_); |
+ PluginVarTracker::GetInstance()->Release(name_); |
+} |
+ |
+FileRef* FileRef::AsFileRef() { |
+ return this; |
+} |
+ |
+namespace { |
+ |
+bool FileRefAndDispatcherForResource(PP_Resource resource, |
+ FileRef** file_ref, |
+ Dispatcher** dispatcher) { |
+ *file_ref = PluginResource::GetAs<FileRef>(resource); |
+ if (!file_ref) |
+ return false; |
+ *dispatcher = PluginDispatcher::GetForInstance((*file_ref)->instance()); |
+ return !!(*dispatcher); |
+} |
+ |
+PP_Resource Create(PP_Resource file_system, const char* path) { |
+ PluginResource* file_system_object = |
+ PluginResourceTracker::GetInstance()->GetResourceObject(file_system); |
+ if (!file_system_object) |
+ return 0; |
+ |
+ Dispatcher* dispatcher = |
+ PluginDispatcher::GetForInstance(file_system_object->instance()); |
+ if (!dispatcher) |
+ return 0; |
+ |
+ PPBFileRef_CreateInfo create_info; |
+ dispatcher->Send(new PpapiHostMsg_PPBFileRef_Create( |
+ INTERFACE_ID_PPB_FILE_REF, file_system_object->host_resource(), |
+ path, &create_info)); |
+ return PPB_FileRef_Proxy::DeserializeFileRef(create_info); |
+} |
+ |
+PP_Bool IsFileRef(PP_Resource resource) { |
+ FileRef* object = PluginResource::GetAs<FileRef>(resource); |
+ return BoolToPPBool(!!object); |
+} |
+ |
+PP_FileSystemType_Dev GetFileSystemType(PP_Resource file_ref) { |
+ FileRef* object = PluginResource::GetAs<FileRef>(file_ref); |
+ if (!object) |
+ return PP_FILESYSTEMTYPE_EXTERNAL; |
+ return object->file_system_type(); |
+} |
+ |
+PP_Var GetName(PP_Resource file_ref) { |
+ FileRef* object = PluginResource::GetAs<FileRef>(file_ref); |
+ if (!object) |
+ return PP_MakeUndefined(); |
+ |
+ PluginVarTracker::GetInstance()->AddRef(object->name()); |
+ return object->name(); |
+} |
+ |
+PP_Var GetPath(PP_Resource file_ref) { |
+ FileRef* object = PluginResource::GetAs<FileRef>(file_ref); |
+ if (!object) |
+ return PP_MakeUndefined(); |
+ |
+ PluginVarTracker::GetInstance()->AddRef(object->path()); |
+ return object->path(); |
+} |
+ |
+PP_Resource GetParent(PP_Resource file_ref) { |
+ FileRef* object; |
+ Dispatcher* dispatcher; |
+ if (!FileRefAndDispatcherForResource(file_ref, &object, &dispatcher)) |
+ return 0; |
+ |
+ PPBFileRef_CreateInfo create_info; |
+ dispatcher->Send(new PpapiHostMsg_PPBFileRef_GetParent( |
+ INTERFACE_ID_PPB_FILE_REF, object->host_resource(), &create_info)); |
+ return PPB_FileRef_Proxy::DeserializeFileRef(create_info); |
+} |
+ |
+int32_t MakeDirectory(PP_Resource directory_ref, |
+ PP_Bool make_ancestors, |
+ struct PP_CompletionCallback callback) { |
+ FileRef* object; |
+ Dispatcher* dispatcher; |
+ if (!FileRefAndDispatcherForResource(directory_ref, &object, &dispatcher)) |
+ return PP_ERROR_BADRESOURCE; |
+ |
+ dispatcher->Send(new PpapiHostMsg_PPBFileRef_MakeDirectory( |
+ INTERFACE_ID_PPB_FILE_REF, object->host_resource(), make_ancestors, |
+ dispatcher->callback_tracker().SendCallback(callback))); |
+ return PP_ERROR_WOULDBLOCK; |
+} |
+ |
+int32_t Touch(PP_Resource file_ref, |
+ PP_Time last_access_time, |
+ PP_Time last_modified_time, |
+ struct PP_CompletionCallback callback) { |
+ FileRef* object; |
+ Dispatcher* dispatcher; |
+ if (!FileRefAndDispatcherForResource(file_ref, &object, &dispatcher)) |
+ return PP_ERROR_BADRESOURCE; |
+ |
+ dispatcher->Send(new PpapiHostMsg_PPBFileRef_Touch( |
+ INTERFACE_ID_PPB_FILE_REF, object->host_resource(), |
+ last_access_time, last_modified_time, |
+ dispatcher->callback_tracker().SendCallback(callback))); |
+ return PP_ERROR_WOULDBLOCK; |
+} |
+ |
+int32_t Delete(PP_Resource file_ref, |
+ struct PP_CompletionCallback callback) { |
+ FileRef* object; |
+ Dispatcher* dispatcher; |
+ if (!FileRefAndDispatcherForResource(file_ref, &object, &dispatcher)) |
+ return PP_ERROR_BADRESOURCE; |
+ |
+ dispatcher->Send(new PpapiHostMsg_PPBFileRef_Delete( |
+ INTERFACE_ID_PPB_FILE_REF, object->host_resource(), |
+ dispatcher->callback_tracker().SendCallback(callback))); |
+ return PP_ERROR_WOULDBLOCK; |
+} |
+ |
+int32_t Rename(PP_Resource file_ref, |
+ PP_Resource new_file_ref, |
+ struct PP_CompletionCallback callback) { |
+ FileRef* obj1; |
+ Dispatcher* dispatcher1; |
+ if (!FileRefAndDispatcherForResource(file_ref, &obj1, &dispatcher1)) |
+ return PP_ERROR_BADRESOURCE; |
+ |
+ FileRef* obj2; |
+ Dispatcher* dispatcher2; |
+ if (!FileRefAndDispatcherForResource(new_file_ref, &obj2, &dispatcher2)) |
+ return PP_ERROR_BADRESOURCE; |
+ |
+ if (obj1->instance() != obj2->instance()) |
+ return PP_ERROR_BADRESOURCE; |
+ |
+ dispatcher1->Send(new PpapiHostMsg_PPBFileRef_Rename( |
+ INTERFACE_ID_PPB_FILE_REF, obj1->host_resource(), |
+ obj2->host_resource(), |
+ dispatcher1->callback_tracker().SendCallback(callback))); |
+ return PP_ERROR_WOULDBLOCK; |
+} |
+ |
+const PPB_FileRef_Dev file_ref_interface = { |
+ &Create, |
+ &IsFileRef, |
+ &GetFileSystemType, |
+ &GetName, |
+ &GetPath, |
+ &GetParent, |
+ &MakeDirectory, |
+ &Touch, |
+ &Delete, |
+ &Rename |
+}; |
+ |
+InterfaceProxy* CreateFileRefProxy(Dispatcher* dispatcher, |
+ const void* target_interface) { |
+ return new PPB_FileRef_Proxy(dispatcher, target_interface); |
+} |
+ |
+} // namespace |
+ |
+PPB_FileRef_Proxy::PPB_FileRef_Proxy(Dispatcher* dispatcher, |
+ const void* target_interface) |
+ : InterfaceProxy(dispatcher, target_interface) { |
+} |
+ |
+PPB_FileRef_Proxy::~PPB_FileRef_Proxy() { |
+} |
+ |
+const InterfaceProxy::Info* PPB_FileRef_Proxy::GetInfo() { |
+ static const Info info = { |
+ &file_ref_interface, |
+ PPB_FILEREF_DEV_INTERFACE, |
+ INTERFACE_ID_PPB_FILE_REF, |
+ false, |
+ &CreateFileRefProxy, |
+ }; |
+ return &info; |
+} |
+ |
+bool PPB_FileRef_Proxy::OnMessageReceived(const IPC::Message& msg) { |
+ bool handled = true; |
+ IPC_BEGIN_MESSAGE_MAP(PPB_FileRef_Proxy, msg) |
+ IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Create, OnMsgCreate) |
+ IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_GetParent, OnMsgGetParent) |
+ IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_MakeDirectory, |
+ OnMsgMakeDirectory) |
+ IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Touch, OnMsgTouch) |
+ IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Delete, OnMsgDelete) |
+ IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Rename, OnMsgRename) |
+ IPC_MESSAGE_UNHANDLED(handled = false) |
+ IPC_END_MESSAGE_MAP() |
+ return handled; |
+} |
+ |
+void PPB_FileRef_Proxy::SerializeFileRef(PP_Resource file_ref, |
+ PPBFileRef_CreateInfo* result) { |
+ // We need the instance out of the resource for serializing back to the |
+ // plugin. This code can only run in the host. |
+ if (dispatcher()->IsPlugin()) { |
+ NOTREACHED(); |
+ return; |
+ } |
+ HostDispatcher* host_dispatcher = static_cast<HostDispatcher*>(dispatcher()); |
+ PP_Instance instance = |
+ host_dispatcher->GetPPBProxy()->GetInstanceForResource(file_ref); |
+ |
+ result->resource.SetHostResource(instance, file_ref); |
+ result->file_system_type = |
+ static_cast<int>(ppb_file_ref_target()->GetFileSystemType(file_ref)); |
+ result->path = SerializedVarReturnValue::Convert( |
+ dispatcher(), |
+ ppb_file_ref_target()->GetPath(file_ref)); |
+ result->name = SerializedVarReturnValue::Convert( |
+ dispatcher(), |
+ ppb_file_ref_target()->GetName(file_ref)); |
+} |
+ |
+// static |
+PP_Resource PPB_FileRef_Proxy::DeserializeFileRef( |
+ const PPBFileRef_CreateInfo& serialized) { |
+ if (serialized.resource.is_null()) |
+ return 0; // Resource invalid. |
+ |
+ linked_ptr<FileRef> object(new FileRef(serialized)); |
+ return PluginResourceTracker::GetInstance()->AddResource(object); |
+} |
+ |
+void PPB_FileRef_Proxy::OnMsgCreate(const HostResource& file_system, |
+ const std::string& path, |
+ PPBFileRef_CreateInfo* result) { |
+ |
+ PP_Resource resource = ppb_file_ref_target()->Create( |
+ file_system.host_resource(), path.c_str()); |
+ if (!resource) |
+ return; // CreateInfo default constructor initializes to 0. |
+ SerializeFileRef(resource, result); |
+} |
+ |
+void PPB_FileRef_Proxy::OnMsgGetParent(const HostResource& host_resource, |
+ PPBFileRef_CreateInfo* result) { |
+ PP_Resource resource = ppb_file_ref_target()->GetParent( |
+ host_resource.host_resource()); |
+ if (!resource) |
+ return; // CreateInfo default constructor initializes to 0. |
+ SerializeFileRef(resource, result); |
+} |
+ |
+void PPB_FileRef_Proxy::OnMsgMakeDirectory(const HostResource& host_resource, |
+ PP_Bool make_ancestors, |
+ uint32_t serialized_callback) { |
+ PP_CompletionCallback callback = ReceiveCallback(serialized_callback); |
+ int32_t result = |
+ ppb_file_ref_target()->MakeDirectory(host_resource.host_resource(), |
+ make_ancestors, callback); |
+ if (result != PP_ERROR_WOULDBLOCK) |
+ PP_RunCompletionCallback(&callback, result); |
+} |
+ |
+void PPB_FileRef_Proxy::OnMsgTouch(const HostResource& host_resource, |
+ PP_Time last_access, |
+ PP_Time last_modified, |
+ uint32_t serialized_callback) { |
+ PP_CompletionCallback callback = ReceiveCallback(serialized_callback); |
+ int32_t result = |
+ ppb_file_ref_target()->Touch(host_resource.host_resource(), |
+ last_access, last_modified, callback); |
+ if (result != PP_ERROR_WOULDBLOCK) |
+ PP_RunCompletionCallback(&callback, result); |
+} |
+ |
+void PPB_FileRef_Proxy::OnMsgDelete(const HostResource& host_resource, |
+ uint32_t serialized_callback) { |
+ PP_CompletionCallback callback = ReceiveCallback(serialized_callback); |
+ int32_t result = |
+ ppb_file_ref_target()->Delete(host_resource.host_resource(), callback); |
+ if (result != PP_ERROR_WOULDBLOCK) |
+ PP_RunCompletionCallback(&callback, result); |
+} |
+ |
+void PPB_FileRef_Proxy::OnMsgRename(const HostResource& file_ref, |
+ const HostResource& new_file_ref, |
+ uint32_t serialized_callback) { |
+ PP_CompletionCallback callback = ReceiveCallback(serialized_callback); |
+ int32_t result = |
+ ppb_file_ref_target()->Rename(file_ref.host_resource(), |
+ new_file_ref.host_resource(), |
+ callback); |
+ if (result != PP_ERROR_WOULDBLOCK) |
+ PP_RunCompletionCallback(&callback, result); |
+} |
+ |
+} // namespace proxy |
+} // namespace pp |
Property changes on: ppapi/proxy/ppb_file_ref_proxy.cc |
___________________________________________________________________ |
Added: svn:eol-style |
+ LF |