| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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/ppb_file_ref_proxy.h" | 5 #include "ppapi/proxy/ppb_file_ref_proxy.h" |
| 6 | 6 |
| 7 #include "ppapi/c/pp_errors.h" | 7 #include "ppapi/c/pp_errors.h" |
| 8 #include "ppapi/c/ppb_file_ref.h" | 8 #include "ppapi/c/ppb_file_ref.h" |
| 9 #include "ppapi/c/private/ppb_proxy_private.h" | 9 #include "ppapi/c/private/ppb_proxy_private.h" |
| 10 #include "ppapi/proxy/enter_proxy.h" | 10 #include "ppapi/proxy/enter_proxy.h" |
| 11 #include "ppapi/proxy/host_dispatcher.h" | 11 #include "ppapi/proxy/host_dispatcher.h" |
| 12 #include "ppapi/proxy/plugin_dispatcher.h" | 12 #include "ppapi/proxy/plugin_dispatcher.h" |
| 13 #include "ppapi/proxy/ppapi_messages.h" | 13 #include "ppapi/proxy/ppapi_messages.h" |
| 14 #include "ppapi/proxy/serialized_var.h" | 14 #include "ppapi/proxy/serialized_var.h" |
| 15 #include "ppapi/thunk/ppb_file_ref_api.h" | 15 #include "ppapi/shared_impl/file_ref_impl.h" |
| 16 #include "ppapi/thunk/resource_creation_api.h" | 16 #include "ppapi/thunk/resource_creation_api.h" |
| 17 #include "ppapi/thunk/thunk.h" | 17 #include "ppapi/thunk/thunk.h" |
| 18 | 18 |
| 19 using ppapi::thunk::EnterFunctionNoLock; | 19 using ppapi::thunk::EnterFunctionNoLock; |
| 20 using ppapi::thunk::EnterResourceNoLock; | 20 using ppapi::thunk::EnterResourceNoLock; |
| 21 using ppapi::thunk::PPB_FileRef_API; | 21 using ppapi::thunk::PPB_FileRef_API; |
| 22 using ppapi::thunk::ResourceCreationAPI; | 22 using ppapi::thunk::ResourceCreationAPI; |
| 23 | 23 |
| 24 namespace ppapi { | 24 namespace ppapi { |
| 25 namespace proxy { | 25 namespace proxy { |
| 26 | 26 |
| 27 namespace { | 27 namespace { |
| 28 | 28 |
| 29 InterfaceProxy* CreateFileRefProxy(Dispatcher* dispatcher, | 29 InterfaceProxy* CreateFileRefProxy(Dispatcher* dispatcher, |
| 30 const void* target_interface) { | 30 const void* target_interface) { |
| 31 return new PPB_FileRef_Proxy(dispatcher, target_interface); | 31 return new PPB_FileRef_Proxy(dispatcher, target_interface); |
| 32 } | 32 } |
| 33 | 33 |
| 34 } // namespace | 34 } // namespace |
| 35 | 35 |
| 36 class FileRef : public Resource, public PPB_FileRef_API { | 36 class FileRef : public FileRefImpl { |
| 37 public: | 37 public: |
| 38 explicit FileRef(const PPBFileRef_CreateInfo& info); | 38 explicit FileRef(const PPB_FileRef_CreateInfo& info); |
| 39 virtual ~FileRef(); | 39 virtual ~FileRef(); |
| 40 | 40 |
| 41 // Resource overrides. | 41 // PPB_FileRef_API implementation (not provided by FileRefImpl). |
| 42 virtual PPB_FileRef_API* AsPPB_FileRef_API() OVERRIDE; | |
| 43 | |
| 44 // PPB_FileRef_API implementation. | |
| 45 virtual PP_FileSystemType GetFileSystemType() const OVERRIDE; | |
| 46 virtual PP_Var GetName() const OVERRIDE; | |
| 47 virtual PP_Var GetPath() const OVERRIDE; | |
| 48 virtual PP_Resource GetParent() OVERRIDE; | 42 virtual PP_Resource GetParent() OVERRIDE; |
| 49 virtual int32_t MakeDirectory(PP_Bool make_ancestors, | 43 virtual int32_t MakeDirectory(PP_Bool make_ancestors, |
| 50 PP_CompletionCallback callback) OVERRIDE; | 44 PP_CompletionCallback callback) OVERRIDE; |
| 51 virtual int32_t Touch(PP_Time last_access_time, | 45 virtual int32_t Touch(PP_Time last_access_time, |
| 52 PP_Time last_modified_time, | 46 PP_Time last_modified_time, |
| 53 PP_CompletionCallback callback) OVERRIDE; | 47 PP_CompletionCallback callback) OVERRIDE; |
| 54 virtual int32_t Delete(PP_CompletionCallback callback) OVERRIDE; | 48 virtual int32_t Delete(PP_CompletionCallback callback) OVERRIDE; |
| 55 virtual int32_t Rename(PP_Resource new_file_ref, | 49 virtual int32_t Rename(PP_Resource new_file_ref, |
| 56 PP_CompletionCallback callback) OVERRIDE; | 50 PP_CompletionCallback callback) OVERRIDE; |
| 57 | 51 |
| 58 private: | 52 private: |
| 59 PluginDispatcher* GetDispatcher() const { | 53 PluginDispatcher* GetDispatcher() const { |
| 60 return PluginDispatcher::GetForResource(this); | 54 return PluginDispatcher::GetForResource(this); |
| 61 } | 55 } |
| 62 | 56 |
| 63 PP_FileSystemType file_system_type_; | 57 DISALLOW_IMPLICIT_CONSTRUCTORS(FileRef); |
| 64 PP_Var path_; | |
| 65 PP_Var name_; | |
| 66 | |
| 67 DISALLOW_COPY_AND_ASSIGN(FileRef); | |
| 68 }; | 58 }; |
| 69 | 59 |
| 70 FileRef::FileRef(const PPBFileRef_CreateInfo& info) | 60 FileRef::FileRef(const PPB_FileRef_CreateInfo& info) |
| 71 : Resource(info.resource) { | 61 : FileRefImpl(FileRefImpl::InitAsProxy(), info) { |
| 72 Dispatcher* dispatcher = PluginDispatcher::GetForResource(this); | |
| 73 | |
| 74 file_system_type_ = static_cast<PP_FileSystemType>(info.file_system_type); | |
| 75 | |
| 76 name_ = ReceiveSerializedVarReturnValue(info.name).Return(dispatcher); | |
| 77 path_ = ReceiveSerializedVarReturnValue(info.path).Return(dispatcher); | |
| 78 } | 62 } |
| 79 | 63 |
| 80 FileRef::~FileRef() { | 64 FileRef::~FileRef() { |
| 81 PluginVarTracker& var_tracker = | |
| 82 PluginResourceTracker::GetInstance()->var_tracker(); | |
| 83 var_tracker.ReleaseVar(path_); | |
| 84 var_tracker.ReleaseVar(name_); | |
| 85 } | |
| 86 | |
| 87 PPB_FileRef_API* FileRef::AsPPB_FileRef_API() { | |
| 88 return this; | |
| 89 } | |
| 90 | |
| 91 PP_FileSystemType FileRef::GetFileSystemType() const { | |
| 92 return file_system_type_; | |
| 93 } | |
| 94 | |
| 95 PP_Var FileRef::GetName() const { | |
| 96 PluginResourceTracker::GetInstance()->var_tracker().AddRefVar(name_); | |
| 97 return name_; | |
| 98 } | |
| 99 | |
| 100 PP_Var FileRef::GetPath() const { | |
| 101 PluginResourceTracker::GetInstance()->var_tracker().AddRefVar(path_); | |
| 102 return path_; | |
| 103 } | 65 } |
| 104 | 66 |
| 105 PP_Resource FileRef::GetParent() { | 67 PP_Resource FileRef::GetParent() { |
| 106 PPBFileRef_CreateInfo create_info; | 68 PPB_FileRef_CreateInfo create_info; |
| 107 GetDispatcher()->Send(new PpapiHostMsg_PPBFileRef_GetParent( | 69 GetDispatcher()->Send(new PpapiHostMsg_PPBFileRef_GetParent( |
| 108 INTERFACE_ID_PPB_FILE_REF, host_resource(), &create_info)); | 70 INTERFACE_ID_PPB_FILE_REF, host_resource(), &create_info)); |
| 109 return PPB_FileRef_Proxy::DeserializeFileRef(create_info); | 71 return PPB_FileRef_Proxy::DeserializeFileRef(create_info); |
| 110 } | 72 } |
| 111 | 73 |
| 112 int32_t FileRef::MakeDirectory(PP_Bool make_ancestors, | 74 int32_t FileRef::MakeDirectory(PP_Bool make_ancestors, |
| 113 PP_CompletionCallback callback) { | 75 PP_CompletionCallback callback) { |
| 114 GetDispatcher()->Send(new PpapiHostMsg_PPBFileRef_MakeDirectory( | 76 GetDispatcher()->Send(new PpapiHostMsg_PPBFileRef_MakeDirectory( |
| 115 INTERFACE_ID_PPB_FILE_REF, host_resource(), make_ancestors, | 77 INTERFACE_ID_PPB_FILE_REF, host_resource(), make_ancestors, |
| 116 GetDispatcher()->callback_tracker().SendCallback(callback))); | 78 GetDispatcher()->callback_tracker().SendCallback(callback))); |
| (...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 169 } | 131 } |
| 170 | 132 |
| 171 // static | 133 // static |
| 172 PP_Resource PPB_FileRef_Proxy::CreateProxyResource(PP_Resource file_system, | 134 PP_Resource PPB_FileRef_Proxy::CreateProxyResource(PP_Resource file_system, |
| 173 const char* path) { | 135 const char* path) { |
| 174 Resource* file_system_object = | 136 Resource* file_system_object = |
| 175 PluginResourceTracker::GetInstance()->GetResource(file_system); | 137 PluginResourceTracker::GetInstance()->GetResource(file_system); |
| 176 if (!file_system_object) | 138 if (!file_system_object) |
| 177 return 0; | 139 return 0; |
| 178 | 140 |
| 179 PPBFileRef_CreateInfo create_info; | 141 PPB_FileRef_CreateInfo create_info; |
| 180 PluginDispatcher::GetForResource(file_system_object)->Send( | 142 PluginDispatcher::GetForResource(file_system_object)->Send( |
| 181 new PpapiHostMsg_PPBFileRef_Create( | 143 new PpapiHostMsg_PPBFileRef_Create( |
| 182 INTERFACE_ID_PPB_FILE_REF, file_system_object->host_resource(), | 144 INTERFACE_ID_PPB_FILE_REF, file_system_object->host_resource(), |
| 183 path, &create_info)); | 145 path, &create_info)); |
| 184 return PPB_FileRef_Proxy::DeserializeFileRef(create_info); | 146 return PPB_FileRef_Proxy::DeserializeFileRef(create_info); |
| 185 } | 147 } |
| 186 | 148 |
| 187 bool PPB_FileRef_Proxy::OnMessageReceived(const IPC::Message& msg) { | 149 bool PPB_FileRef_Proxy::OnMessageReceived(const IPC::Message& msg) { |
| 188 bool handled = true; | 150 bool handled = true; |
| 189 IPC_BEGIN_MESSAGE_MAP(PPB_FileRef_Proxy, msg) | 151 IPC_BEGIN_MESSAGE_MAP(PPB_FileRef_Proxy, msg) |
| 190 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Create, OnMsgCreate) | 152 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Create, OnMsgCreate) |
| 191 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_GetParent, OnMsgGetParent) | 153 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_GetParent, OnMsgGetParent) |
| 192 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_MakeDirectory, | 154 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_MakeDirectory, |
| 193 OnMsgMakeDirectory) | 155 OnMsgMakeDirectory) |
| 194 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Touch, OnMsgTouch) | 156 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Touch, OnMsgTouch) |
| 195 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Delete, OnMsgDelete) | 157 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Delete, OnMsgDelete) |
| 196 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Rename, OnMsgRename) | 158 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileRef_Rename, OnMsgRename) |
| 197 IPC_MESSAGE_UNHANDLED(handled = false) | 159 IPC_MESSAGE_UNHANDLED(handled = false) |
| 198 IPC_END_MESSAGE_MAP() | 160 IPC_END_MESSAGE_MAP() |
| 199 return handled; | 161 return handled; |
| 200 } | 162 } |
| 201 | 163 |
| 202 void PPB_FileRef_Proxy::SerializeFileRef(PP_Resource file_ref, | 164 void PPB_FileRef_Proxy::SerializeFileRef(PP_Resource file_ref, |
| 203 PPBFileRef_CreateInfo* result) { | 165 PPB_FileRef_CreateInfo* result) { |
| 204 EnterResourceNoLock<PPB_FileRef_API> enter(file_ref, false); | 166 EnterResourceNoLock<PPB_FileRef_API> enter(file_ref, false); |
| 205 if (enter.failed()) { | 167 if (enter.succeeded()) |
| 206 NOTREACHED(); | 168 *result = enter.object()->GetCreateInfo(); |
| 207 return; | |
| 208 } | |
| 209 | |
| 210 // We need the instance out of the resource for serializing back to the | |
| 211 // plugin. This code can only run in the host. | |
| 212 if (dispatcher()->IsPlugin()) { | |
| 213 NOTREACHED(); | |
| 214 return; | |
| 215 } | |
| 216 HostDispatcher* host_dispatcher = static_cast<HostDispatcher*>(dispatcher()); | |
| 217 PP_Instance instance = | |
| 218 host_dispatcher->ppb_proxy()->GetInstanceForResource(file_ref); | |
| 219 | |
| 220 result->resource.SetHostResource(instance, file_ref); | |
| 221 result->file_system_type = | |
| 222 static_cast<int>(enter.object()->GetFileSystemType()); | |
| 223 result->path = SerializedVarReturnValue::Convert(dispatcher(), | |
| 224 enter.object()->GetPath()); | |
| 225 result->name = SerializedVarReturnValue::Convert(dispatcher(), | |
| 226 enter.object()->GetName()); | |
| 227 } | 169 } |
| 228 | 170 |
| 229 // static | 171 // static |
| 230 PP_Resource PPB_FileRef_Proxy::DeserializeFileRef( | 172 PP_Resource PPB_FileRef_Proxy::DeserializeFileRef( |
| 231 const PPBFileRef_CreateInfo& serialized) { | 173 const PPB_FileRef_CreateInfo& serialized) { |
| 232 if (serialized.resource.is_null()) | 174 if (serialized.resource.is_null()) |
| 233 return 0; // Resource invalid. | 175 return 0; // Resource invalid. |
| 234 return (new FileRef(serialized))->GetReference(); | 176 return (new FileRef(serialized))->GetReference(); |
| 235 } | 177 } |
| 236 | 178 |
| 237 void PPB_FileRef_Proxy::OnMsgCreate(const HostResource& file_system, | 179 void PPB_FileRef_Proxy::OnMsgCreate(const HostResource& file_system, |
| 238 const std::string& path, | 180 const std::string& path, |
| 239 PPBFileRef_CreateInfo* result) { | 181 PPB_FileRef_CreateInfo* result) { |
| 240 EnterFunctionNoLock<ResourceCreationAPI> enter(file_system.instance(), true); | 182 EnterFunctionNoLock<ResourceCreationAPI> enter(file_system.instance(), true); |
| 241 if (enter.failed()) | 183 if (enter.failed()) |
| 242 return; | 184 return; |
| 243 PP_Resource resource = enter.functions()->CreateFileRef( | 185 PP_Resource resource = enter.functions()->CreateFileRef( |
| 244 file_system.host_resource(), path.c_str()); | 186 file_system.host_resource(), path.c_str()); |
| 245 if (!resource) | 187 if (!resource) |
| 246 return; // CreateInfo default constructor initializes to 0. | 188 return; // CreateInfo default constructor initializes to 0. |
| 247 SerializeFileRef(resource, result); | 189 SerializeFileRef(resource, result); |
| 248 } | 190 } |
| 249 | 191 |
| 250 void PPB_FileRef_Proxy::OnMsgGetParent(const HostResource& host_resource, | 192 void PPB_FileRef_Proxy::OnMsgGetParent(const HostResource& host_resource, |
| 251 PPBFileRef_CreateInfo* result) { | 193 PPB_FileRef_CreateInfo* result) { |
| 252 EnterHostFromHostResource<PPB_FileRef_API> enter(host_resource); | 194 EnterHostFromHostResource<PPB_FileRef_API> enter(host_resource); |
| 253 if (enter.succeeded()) | 195 if (enter.succeeded()) |
| 254 SerializeFileRef(enter.object()->GetParent(), result); | 196 SerializeFileRef(enter.object()->GetParent(), result); |
| 255 } | 197 } |
| 256 | 198 |
| 257 void PPB_FileRef_Proxy::OnMsgMakeDirectory(const HostResource& host_resource, | 199 void PPB_FileRef_Proxy::OnMsgMakeDirectory(const HostResource& host_resource, |
| 258 PP_Bool make_ancestors, | 200 PP_Bool make_ancestors, |
| 259 uint32_t serialized_callback) { | 201 uint32_t serialized_callback) { |
| 260 EnterHostFromHostResource<PPB_FileRef_API> enter(host_resource); | 202 EnterHostFromHostResource<PPB_FileRef_API> enter(host_resource); |
| 261 if (enter.failed()) | 203 if (enter.failed()) |
| (...skipping 36 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 298 return; | 240 return; |
| 299 PP_CompletionCallback callback = ReceiveCallback(serialized_callback); | 241 PP_CompletionCallback callback = ReceiveCallback(serialized_callback); |
| 300 int32_t result = enter.object()->Rename(new_file_ref.host_resource(), | 242 int32_t result = enter.object()->Rename(new_file_ref.host_resource(), |
| 301 callback); | 243 callback); |
| 302 if (result != PP_OK_COMPLETIONPENDING) | 244 if (result != PP_OK_COMPLETIONPENDING) |
| 303 PP_RunCompletionCallback(&callback, result); | 245 PP_RunCompletionCallback(&callback, result); |
| 304 } | 246 } |
| 305 | 247 |
| 306 } // namespace proxy | 248 } // namespace proxy |
| 307 } // namespace ppapi | 249 } // namespace ppapi |
| OLD | NEW |