| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 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_ref_resource.h" | 5 #include "ppapi/proxy/file_ref_resource.h" |
| 6 | 6 |
| 7 #include "ppapi/c/pp_directory_entry.h" | 7 #include "ppapi/c/pp_directory_entry.h" |
| 8 #include "ppapi/c/pp_instance.h" | 8 #include "ppapi/c/pp_instance.h" |
| 9 #include "ppapi/c/pp_resource.h" | 9 #include "ppapi/c/pp_resource.h" |
| 10 #include "ppapi/proxy/ppapi_messages.h" | 10 #include "ppapi/proxy/ppapi_messages.h" |
| 11 #include "ppapi/shared_impl/array_writer.h" | 11 #include "ppapi/shared_impl/array_writer.h" |
| 12 #include "ppapi/shared_impl/file_ref_util.h" | 12 #include "ppapi/shared_impl/file_ref_util.h" |
| 13 #include "ppapi/shared_impl/resource.h" | 13 #include "ppapi/shared_impl/resource.h" |
| 14 #include "ppapi/shared_impl/resource_tracker.h" | 14 #include "ppapi/shared_impl/resource_tracker.h" |
| 15 #include "ppapi/shared_impl/var.h" | 15 #include "ppapi/shared_impl/var.h" |
| 16 #include "ppapi/thunk/enter.h" | 16 #include "ppapi/thunk/enter.h" |
| 17 #include "ppapi/thunk/ppb_file_system_api.h" | 17 #include "ppapi/thunk/ppb_file_system_api.h" |
| 18 | 18 |
| 19 namespace ppapi { | 19 namespace ppapi { |
| 20 namespace proxy { | 20 namespace proxy { |
| 21 | 21 |
| 22 FileRefResource::FileRefResource( | 22 FileRefResource::FileRefResource( |
| 23 Connection connection, | 23 Connection connection, |
| 24 PP_Instance instance, | 24 PP_Instance instance, |
| 25 const FileRef_CreateInfo& create_info) | 25 const FileRefCreateInfo& create_info) |
| 26 : PluginResource(connection, instance), | 26 : PluginResource(connection, instance), |
| 27 create_info_(create_info), | 27 create_info_(create_info), |
| 28 file_system_resource_(create_info.file_system_plugin_resource) { | 28 file_system_resource_(create_info.file_system_plugin_resource) { |
| 29 if (create_info_.file_system_type != PP_FILESYSTEMTYPE_EXTERNAL) { | 29 if (create_info_.file_system_type != PP_FILESYSTEMTYPE_EXTERNAL) { |
| 30 // If path ends with a slash, then normalize it away unless path is | 30 // If path ends with a slash, then normalize it away unless path is |
| 31 // the root path. | 31 // the root path. |
| 32 int path_size = create_info_.internal_path.size(); | 32 int path_size = create_info_.internal_path.size(); |
| 33 if (path_size > 1 && create_info_.internal_path.at(path_size - 1) == '/') | 33 if (path_size > 1 && create_info_.internal_path.at(path_size - 1) == '/') |
| 34 create_info_.internal_path.erase(path_size - 1, 1); | 34 create_info_.internal_path.erase(path_size - 1, 1); |
| 35 | 35 |
| 36 path_var_ = new StringVar(create_info_.internal_path); | 36 path_var_ = new StringVar(create_info_.internal_path); |
| 37 | |
| 38 create_info_.display_name = GetNameForInternalFilePath( | 37 create_info_.display_name = GetNameForInternalFilePath( |
| 39 create_info_.internal_path); | 38 create_info_.internal_path); |
| 40 } | 39 } |
| 41 name_var_ = new StringVar(create_info_.display_name); | 40 name_var_ = new StringVar(create_info_.display_name); |
| 42 | 41 |
| 43 if (create_info_.pending_host_resource_id != 0) { | 42 if (create_info_.pending_host_resource_id != 0) { |
| 44 AttachToPendingHost(BROWSER, create_info_.pending_host_resource_id); | 43 AttachToPendingHost(BROWSER, create_info_.pending_host_resource_id); |
| 45 } else { | 44 } else { |
| 46 CHECK(create_info_.file_system_type != PP_FILESYSTEMTYPE_EXTERNAL); | 45 CHECK(create_info_.file_system_type != PP_FILESYSTEMTYPE_EXTERNAL); |
| 47 SendCreate(BROWSER, PpapiHostMsg_FileRef_CreateInternal( | 46 SendCreate(BROWSER, PpapiHostMsg_FileRef_CreateInternal( |
| 48 create_info.file_system_plugin_resource, | 47 create_info.file_system_plugin_resource, |
| 49 create_info.internal_path)); | 48 create_info.internal_path)); |
| 50 } | 49 } |
| 51 } | 50 } |
| 52 | 51 |
| 53 FileRefResource::~FileRefResource() { | 52 FileRefResource::~FileRefResource() { |
| 54 } | 53 } |
| 55 | 54 |
| 56 //static | 55 //static |
| 57 PP_Resource FileRefResource::CreateFileRef( | 56 PP_Resource FileRefResource::CreateFileRef( |
| 58 Connection connection, | 57 Connection connection, |
| 59 PP_Instance instance, | 58 PP_Instance instance, |
| 60 const FileRef_CreateInfo& create_info) { | 59 const FileRefCreateInfo& create_info) { |
| 61 // If we have a valid file_system resource, ensure that its type matches that | 60 // If we have a valid file_system resource, ensure that its type matches that |
| 62 // of the fs_type parameter. | 61 // of the fs_type parameter. |
| 63 if (create_info.file_system_plugin_resource != 0) { | 62 if (create_info.file_system_plugin_resource != 0) { |
| 64 thunk::EnterResourceNoLock<thunk::PPB_FileSystem_API> enter( | 63 thunk::EnterResourceNoLock<thunk::PPB_FileSystem_API> enter( |
| 65 create_info.file_system_plugin_resource, true); | 64 create_info.file_system_plugin_resource, true); |
| 66 if (enter.failed()) | 65 if (enter.failed()) |
| 67 return 0; | 66 return 0; |
| 68 if (enter.object()->GetType() != create_info.file_system_type) { | 67 if (enter.object()->GetType() != create_info.file_system_type) { |
| 69 NOTREACHED() << "file system type mismatch with resource"; | 68 NOTREACHED() << "file system type mismatch with resource"; |
| 70 return 0; | 69 return 0; |
| 71 } | 70 } |
| 72 } | 71 } |
| 73 | 72 |
| 74 if (create_info.file_system_type == PP_FILESYSTEMTYPE_LOCALPERSISTENT || | 73 if (create_info.file_system_type == PP_FILESYSTEMTYPE_LOCALPERSISTENT || |
| 75 create_info.file_system_type == PP_FILESYSTEMTYPE_LOCALTEMPORARY) { | 74 create_info.file_system_type == PP_FILESYSTEMTYPE_LOCALTEMPORARY) { |
| 76 if (!IsValidInternalPath(create_info.internal_path)) | 75 if (!IsValidInternalPath(create_info.internal_path)) |
| 77 return 0; | 76 return 0; |
| 78 } | 77 } |
| 79 return (new FileRefResource(connection, | 78 return (new FileRefResource(connection, |
| 80 instance, | 79 instance, |
| 81 create_info))->GetReference(); | 80 create_info))->GetReference(); |
| 82 } | 81 } |
| 83 | 82 |
| 84 thunk::PPB_FileRef_API* FileRefResource::AsPPB_FileRef_API() { | 83 thunk::PPB_FileRef_API* FileRefResource::AsPPB_FileRef_API() { |
| 85 // TODO: return "this" once we update PPB_FileRef_API. | 84 return this; |
| 86 NOTREACHED(); | |
| 87 return NULL; | |
| 88 } | 85 } |
| 89 | 86 |
| 90 PP_FileSystemType FileRefResource::GetFileSystemType() const { | 87 PP_FileSystemType FileRefResource::GetFileSystemType() const { |
| 91 return create_info_.file_system_type; | 88 return create_info_.file_system_type; |
| 92 } | 89 } |
| 93 | 90 |
| 94 PP_Var FileRefResource::GetName() const { | 91 PP_Var FileRefResource::GetName() const { |
| 95 return name_var_->GetPPVar(); | 92 return name_var_->GetPPVar(); |
| 96 } | 93 } |
| 97 | 94 |
| 98 PP_Var FileRefResource::GetPath() const { | 95 PP_Var FileRefResource::GetPath() const { |
| 99 if (create_info_.file_system_type == PP_FILESYSTEMTYPE_EXTERNAL) | 96 if (create_info_.file_system_type == PP_FILESYSTEMTYPE_EXTERNAL) |
| 100 return PP_MakeUndefined(); | 97 return PP_MakeUndefined(); |
| 101 return path_var_->GetPPVar(); | 98 return path_var_->GetPPVar(); |
| 102 } | 99 } |
| 103 | 100 |
| 104 PP_Resource FileRefResource::GetParent() { | 101 PP_Resource FileRefResource::GetParent() { |
| 105 if (create_info_.file_system_type == PP_FILESYSTEMTYPE_EXTERNAL) | 102 if (create_info_.file_system_type == PP_FILESYSTEMTYPE_EXTERNAL) |
| 106 return 0; | 103 return 0; |
| 107 | 104 |
| 108 size_t pos = create_info_.internal_path.rfind('/'); | 105 size_t pos = create_info_.internal_path.rfind('/'); |
| 109 CHECK(pos != std::string::npos); | 106 CHECK(pos != std::string::npos); |
| 110 if (pos == 0) | 107 if (pos == 0) |
| 111 pos++; | 108 pos++; |
| 112 std::string parent_path = create_info_.internal_path.substr(0, pos); | 109 std::string parent_path = create_info_.internal_path.substr(0, pos); |
| 113 | 110 |
| 114 ppapi::FileRef_CreateInfo parent_info; | 111 ppapi::FileRefCreateInfo parent_info; |
| 115 parent_info.file_system_type = create_info_.file_system_type; | 112 parent_info.file_system_type = create_info_.file_system_type; |
| 116 parent_info.internal_path = parent_path; | 113 parent_info.internal_path = parent_path; |
| 117 parent_info.display_name = GetNameForInternalFilePath(parent_path); | 114 parent_info.display_name = GetNameForInternalFilePath(parent_path); |
| 118 parent_info.file_system_plugin_resource = | 115 parent_info.file_system_plugin_resource = |
| 119 create_info_.file_system_plugin_resource; | 116 create_info_.file_system_plugin_resource; |
| 120 | 117 |
| 121 return (new FileRefResource(connection(), | 118 return (new FileRefResource(connection(), |
| 122 pp_instance(), | 119 pp_instance(), |
| 123 parent_info))->GetReference(); | 120 parent_info))->GetReference(); |
| 124 } | 121 } |
| (...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 177 const PP_ArrayOutput& output, | 174 const PP_ArrayOutput& output, |
| 178 scoped_refptr<TrackedCallback> callback) { | 175 scoped_refptr<TrackedCallback> callback) { |
| 179 Call<PpapiPluginMsg_FileRef_ReadDirectoryEntriesReply>( | 176 Call<PpapiPluginMsg_FileRef_ReadDirectoryEntriesReply>( |
| 180 BROWSER, | 177 BROWSER, |
| 181 PpapiHostMsg_FileRef_ReadDirectoryEntries(), | 178 PpapiHostMsg_FileRef_ReadDirectoryEntries(), |
| 182 base::Bind(&FileRefResource::OnDirectoryEntriesReply, | 179 base::Bind(&FileRefResource::OnDirectoryEntriesReply, |
| 183 this, output, callback)); | 180 this, output, callback)); |
| 184 return PP_OK_COMPLETIONPENDING; | 181 return PP_OK_COMPLETIONPENDING; |
| 185 } | 182 } |
| 186 | 183 |
| 187 /* | 184 const FileRefCreateInfo& FileRefResource::GetCreateInfo() const { |
| 188 const FileRef_CreateInfo& FileRefResource::GetCreateInfo() const { | |
| 189 return create_info_; | 185 return create_info_; |
| 190 } | 186 } |
| 191 */ | |
| 192 const PPB_FileRef_CreateInfo& FileRefResource::GetCreateInfo() const { | |
| 193 // FIXME | |
| 194 NOTREACHED(); | |
| 195 PPB_FileRef_CreateInfo *info = new PPB_FileRef_CreateInfo(); | |
| 196 return *info; | |
| 197 } | |
| 198 | |
| 199 // TODO(teravest): Remove this when we are finished moving to the new proxy. | |
| 200 int32_t FileRefResource::QueryInHost(linked_ptr<PP_FileInfo> info, | |
| 201 scoped_refptr<TrackedCallback> callback) { | |
| 202 NOTREACHED(); | |
| 203 return PP_ERROR_FAILED; | |
| 204 } | |
| 205 | |
| 206 // TODO(teravest): Remove this when we are finished moving to the new proxy. | |
| 207 int32_t FileRefResource::ReadDirectoryEntriesInHost( | |
| 208 linked_ptr<std::vector<ppapi::PPB_FileRef_CreateInfo> > files, | |
| 209 linked_ptr<std::vector<PP_FileType> > file_types, | |
| 210 scoped_refptr<TrackedCallback> callback) { | |
| 211 NOTREACHED(); | |
| 212 return PP_ERROR_FAILED; | |
| 213 } | |
| 214 | 187 |
| 215 PP_Var FileRefResource::GetAbsolutePath() { | 188 PP_Var FileRefResource::GetAbsolutePath() { |
| 216 if (!absolute_path_var_.get()) { | 189 if (!absolute_path_var_.get()) { |
| 217 std::string absolute_path; | 190 std::string absolute_path; |
| 218 int32_t result = SyncCall<PpapiPluginMsg_FileRef_GetAbsolutePathReply>( | 191 int32_t result = SyncCall<PpapiPluginMsg_FileRef_GetAbsolutePathReply>( |
| 219 BROWSER, PpapiHostMsg_FileRef_GetAbsolutePath(), &absolute_path); | 192 BROWSER, PpapiHostMsg_FileRef_GetAbsolutePath(), &absolute_path); |
| 220 if (result != PP_OK) | 193 if (result != PP_OK) |
| 221 return PP_MakeUndefined(); | 194 return PP_MakeUndefined(); |
| 222 absolute_path_var_ = new StringVar(absolute_path); | 195 absolute_path_var_ = new StringVar(absolute_path); |
| 223 } | 196 } |
| (...skipping 17 matching lines...) Expand all Loading... |
| 241 | 214 |
| 242 if (params.result() == PP_OK) | 215 if (params.result() == PP_OK) |
| 243 *out_info = info; | 216 *out_info = info; |
| 244 callback->Run(params.result()); | 217 callback->Run(params.result()); |
| 245 } | 218 } |
| 246 | 219 |
| 247 void FileRefResource::OnDirectoryEntriesReply( | 220 void FileRefResource::OnDirectoryEntriesReply( |
| 248 const PP_ArrayOutput& output, | 221 const PP_ArrayOutput& output, |
| 249 scoped_refptr<TrackedCallback> callback, | 222 scoped_refptr<TrackedCallback> callback, |
| 250 const ResourceMessageReplyParams& params, | 223 const ResourceMessageReplyParams& params, |
| 251 const std::vector<ppapi::FileRef_CreateInfo>& infos, | 224 const std::vector<ppapi::FileRefCreateInfo>& infos, |
| 252 const std::vector<PP_FileType>& file_types) { | 225 const std::vector<PP_FileType>& file_types) { |
| 253 if (!TrackedCallback::IsPending(callback)) | 226 if (!TrackedCallback::IsPending(callback)) |
| 254 return; | 227 return; |
| 255 | 228 |
| 256 if (params.result() == PP_OK) { | 229 if (params.result() == PP_OK) { |
| 257 ArrayWriter writer(output); | 230 ArrayWriter writer(output); |
| 258 if (!writer.is_valid()) { | 231 if (!writer.is_valid()) { |
| 259 callback->Run(PP_ERROR_BADARGUMENT); | 232 callback->Run(PP_ERROR_BADARGUMENT); |
| 260 return; | 233 return; |
| 261 } | 234 } |
| 262 | 235 |
| 263 std::vector<PP_DirectoryEntry> entries; | 236 std::vector<PP_DirectoryEntry> entries; |
| 264 for (size_t i = 0; i < infos.size(); ++i) { | 237 for (size_t i = 0; i < infos.size(); ++i) { |
| 265 PP_DirectoryEntry entry; | 238 PP_DirectoryEntry entry; |
| 266 entry.file_ref = FileRefResource::CreateFileRef(connection(), | 239 entry.file_ref = FileRefResource::CreateFileRef(connection(), |
| 267 pp_instance(), | 240 pp_instance(), |
| 268 infos[i]); | 241 infos[i]); |
| 269 entry.file_type = file_types[i]; | 242 entry.file_type = file_types[i]; |
| 270 entries.push_back(entry); | 243 entries.push_back(entry); |
| 271 } | 244 } |
| 272 | 245 |
| 273 writer.StoreVector(entries); | 246 writer.StoreVector(entries); |
| 274 } | 247 } |
| 275 callback->Run(params.result()); | 248 callback->Run(params.result()); |
| 276 } | 249 } |
| 277 | 250 |
| 278 } // namespace proxy | 251 } // namespace proxy |
| 279 } // namespace ppapi | 252 } // namespace ppapi |
| OLD | NEW |