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 FileRefCreateInfo& create_info) | 25 const FileRef_CreateInfo& 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 |
37 create_info_.display_name = GetNameForInternalFilePath( | 38 create_info_.display_name = GetNameForInternalFilePath( |
38 create_info_.internal_path); | 39 create_info_.internal_path); |
39 } | 40 } |
40 name_var_ = new StringVar(create_info_.display_name); | 41 name_var_ = new StringVar(create_info_.display_name); |
41 | 42 |
42 if (create_info_.pending_host_resource_id != 0) { | 43 if (create_info_.pending_host_resource_id != 0) { |
43 AttachToPendingHost(BROWSER, create_info_.pending_host_resource_id); | 44 AttachToPendingHost(BROWSER, create_info_.pending_host_resource_id); |
44 } else { | 45 } else { |
45 CHECK(create_info_.file_system_type != PP_FILESYSTEMTYPE_EXTERNAL); | 46 CHECK(create_info_.file_system_type != PP_FILESYSTEMTYPE_EXTERNAL); |
46 SendCreate(BROWSER, PpapiHostMsg_FileRef_CreateInternal( | 47 SendCreate(BROWSER, PpapiHostMsg_FileRef_CreateInternal( |
47 create_info.file_system_plugin_resource, | 48 create_info.file_system_plugin_resource, |
48 create_info.internal_path)); | 49 create_info.internal_path)); |
49 } | 50 } |
50 } | 51 } |
51 | 52 |
52 FileRefResource::~FileRefResource() { | 53 FileRefResource::~FileRefResource() { |
53 } | 54 } |
54 | 55 |
55 //static | 56 //static |
56 PP_Resource FileRefResource::CreateFileRef( | 57 PP_Resource FileRefResource::CreateFileRef( |
57 Connection connection, | 58 Connection connection, |
58 PP_Instance instance, | 59 PP_Instance instance, |
59 const FileRefCreateInfo& create_info) { | 60 const FileRef_CreateInfo& create_info) { |
60 // If we have a valid file_system resource, ensure that its type matches that | 61 // If we have a valid file_system resource, ensure that its type matches that |
61 // of the fs_type parameter. | 62 // of the fs_type parameter. |
62 if (create_info.file_system_plugin_resource != 0) { | 63 if (create_info.file_system_plugin_resource != 0) { |
63 thunk::EnterResourceNoLock<thunk::PPB_FileSystem_API> enter( | 64 thunk::EnterResourceNoLock<thunk::PPB_FileSystem_API> enter( |
64 create_info.file_system_plugin_resource, true); | 65 create_info.file_system_plugin_resource, true); |
65 if (enter.failed()) | 66 if (enter.failed()) |
66 return 0; | 67 return 0; |
67 if (enter.object()->GetType() != create_info.file_system_type) { | 68 if (enter.object()->GetType() != create_info.file_system_type) { |
68 NOTREACHED() << "file system type mismatch with resource"; | 69 NOTREACHED() << "file system type mismatch with resource"; |
69 return 0; | 70 return 0; |
70 } | 71 } |
71 } | 72 } |
72 | 73 |
73 if (create_info.file_system_type == PP_FILESYSTEMTYPE_LOCALPERSISTENT || | 74 if (create_info.file_system_type == PP_FILESYSTEMTYPE_LOCALPERSISTENT || |
74 create_info.file_system_type == PP_FILESYSTEMTYPE_LOCALTEMPORARY) { | 75 create_info.file_system_type == PP_FILESYSTEMTYPE_LOCALTEMPORARY) { |
75 if (!IsValidInternalPath(create_info.internal_path)) | 76 if (!IsValidInternalPath(create_info.internal_path)) |
76 return 0; | 77 return 0; |
77 } | 78 } |
78 return (new FileRefResource(connection, | 79 return (new FileRefResource(connection, |
79 instance, | 80 instance, |
80 create_info))->GetReference(); | 81 create_info))->GetReference(); |
81 } | 82 } |
82 | 83 |
83 thunk::PPB_FileRef_API* FileRefResource::AsPPB_FileRef_API() { | 84 thunk::PPB_FileRef_API* FileRefResource::AsPPB_FileRef_API() { |
84 return this; | 85 // TODO: return "this" once we update PPB_FileRef_API. |
| 86 NOTREACHED(); |
| 87 return NULL; |
85 } | 88 } |
86 | 89 |
87 PP_FileSystemType FileRefResource::GetFileSystemType() const { | 90 PP_FileSystemType FileRefResource::GetFileSystemType() const { |
88 return create_info_.file_system_type; | 91 return create_info_.file_system_type; |
89 } | 92 } |
90 | 93 |
91 PP_Var FileRefResource::GetName() const { | 94 PP_Var FileRefResource::GetName() const { |
92 return name_var_->GetPPVar(); | 95 return name_var_->GetPPVar(); |
93 } | 96 } |
94 | 97 |
95 PP_Var FileRefResource::GetPath() const { | 98 PP_Var FileRefResource::GetPath() const { |
96 if (create_info_.file_system_type == PP_FILESYSTEMTYPE_EXTERNAL) | 99 if (create_info_.file_system_type == PP_FILESYSTEMTYPE_EXTERNAL) |
97 return PP_MakeUndefined(); | 100 return PP_MakeUndefined(); |
98 return path_var_->GetPPVar(); | 101 return path_var_->GetPPVar(); |
99 } | 102 } |
100 | 103 |
101 PP_Resource FileRefResource::GetParent() { | 104 PP_Resource FileRefResource::GetParent() { |
102 if (create_info_.file_system_type == PP_FILESYSTEMTYPE_EXTERNAL) | 105 if (create_info_.file_system_type == PP_FILESYSTEMTYPE_EXTERNAL) |
103 return 0; | 106 return 0; |
104 | 107 |
105 size_t pos = create_info_.internal_path.rfind('/'); | 108 size_t pos = create_info_.internal_path.rfind('/'); |
106 CHECK(pos != std::string::npos); | 109 CHECK(pos != std::string::npos); |
107 if (pos == 0) | 110 if (pos == 0) |
108 pos++; | 111 pos++; |
109 std::string parent_path = create_info_.internal_path.substr(0, pos); | 112 std::string parent_path = create_info_.internal_path.substr(0, pos); |
110 | 113 |
111 ppapi::FileRefCreateInfo parent_info; | 114 ppapi::FileRef_CreateInfo parent_info; |
112 parent_info.file_system_type = create_info_.file_system_type; | 115 parent_info.file_system_type = create_info_.file_system_type; |
113 parent_info.internal_path = parent_path; | 116 parent_info.internal_path = parent_path; |
114 parent_info.display_name = GetNameForInternalFilePath(parent_path); | 117 parent_info.display_name = GetNameForInternalFilePath(parent_path); |
115 parent_info.file_system_plugin_resource = | 118 parent_info.file_system_plugin_resource = |
116 create_info_.file_system_plugin_resource; | 119 create_info_.file_system_plugin_resource; |
117 | 120 |
118 return (new FileRefResource(connection(), | 121 return (new FileRefResource(connection(), |
119 pp_instance(), | 122 pp_instance(), |
120 parent_info))->GetReference(); | 123 parent_info))->GetReference(); |
121 } | 124 } |
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
174 const PP_ArrayOutput& output, | 177 const PP_ArrayOutput& output, |
175 scoped_refptr<TrackedCallback> callback) { | 178 scoped_refptr<TrackedCallback> callback) { |
176 Call<PpapiPluginMsg_FileRef_ReadDirectoryEntriesReply>( | 179 Call<PpapiPluginMsg_FileRef_ReadDirectoryEntriesReply>( |
177 BROWSER, | 180 BROWSER, |
178 PpapiHostMsg_FileRef_ReadDirectoryEntries(), | 181 PpapiHostMsg_FileRef_ReadDirectoryEntries(), |
179 base::Bind(&FileRefResource::OnDirectoryEntriesReply, | 182 base::Bind(&FileRefResource::OnDirectoryEntriesReply, |
180 this, output, callback)); | 183 this, output, callback)); |
181 return PP_OK_COMPLETIONPENDING; | 184 return PP_OK_COMPLETIONPENDING; |
182 } | 185 } |
183 | 186 |
184 const FileRefCreateInfo& FileRefResource::GetCreateInfo() const { | 187 /* |
| 188 const FileRef_CreateInfo& FileRefResource::GetCreateInfo() const { |
185 return create_info_; | 189 return create_info_; |
186 } | 190 } |
| 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 } |
187 | 214 |
188 PP_Var FileRefResource::GetAbsolutePath() { | 215 PP_Var FileRefResource::GetAbsolutePath() { |
189 if (!absolute_path_var_.get()) { | 216 if (!absolute_path_var_.get()) { |
190 std::string absolute_path; | 217 std::string absolute_path; |
191 int32_t result = SyncCall<PpapiPluginMsg_FileRef_GetAbsolutePathReply>( | 218 int32_t result = SyncCall<PpapiPluginMsg_FileRef_GetAbsolutePathReply>( |
192 BROWSER, PpapiHostMsg_FileRef_GetAbsolutePath(), &absolute_path); | 219 BROWSER, PpapiHostMsg_FileRef_GetAbsolutePath(), &absolute_path); |
193 if (result != PP_OK) | 220 if (result != PP_OK) |
194 return PP_MakeUndefined(); | 221 return PP_MakeUndefined(); |
195 absolute_path_var_ = new StringVar(absolute_path); | 222 absolute_path_var_ = new StringVar(absolute_path); |
196 } | 223 } |
(...skipping 17 matching lines...) Expand all Loading... |
214 | 241 |
215 if (params.result() == PP_OK) | 242 if (params.result() == PP_OK) |
216 *out_info = info; | 243 *out_info = info; |
217 callback->Run(params.result()); | 244 callback->Run(params.result()); |
218 } | 245 } |
219 | 246 |
220 void FileRefResource::OnDirectoryEntriesReply( | 247 void FileRefResource::OnDirectoryEntriesReply( |
221 const PP_ArrayOutput& output, | 248 const PP_ArrayOutput& output, |
222 scoped_refptr<TrackedCallback> callback, | 249 scoped_refptr<TrackedCallback> callback, |
223 const ResourceMessageReplyParams& params, | 250 const ResourceMessageReplyParams& params, |
224 const std::vector<ppapi::FileRefCreateInfo>& infos, | 251 const std::vector<ppapi::FileRef_CreateInfo>& infos, |
225 const std::vector<PP_FileType>& file_types) { | 252 const std::vector<PP_FileType>& file_types) { |
226 if (!TrackedCallback::IsPending(callback)) | 253 if (!TrackedCallback::IsPending(callback)) |
227 return; | 254 return; |
228 | 255 |
229 if (params.result() == PP_OK) { | 256 if (params.result() == PP_OK) { |
230 ArrayWriter writer(output); | 257 ArrayWriter writer(output); |
231 if (!writer.is_valid()) { | 258 if (!writer.is_valid()) { |
232 callback->Run(PP_ERROR_BADARGUMENT); | 259 callback->Run(PP_ERROR_BADARGUMENT); |
233 return; | 260 return; |
234 } | 261 } |
235 | 262 |
236 std::vector<PP_DirectoryEntry> entries; | 263 std::vector<PP_DirectoryEntry> entries; |
237 for (size_t i = 0; i < infos.size(); ++i) { | 264 for (size_t i = 0; i < infos.size(); ++i) { |
238 PP_DirectoryEntry entry; | 265 PP_DirectoryEntry entry; |
239 entry.file_ref = FileRefResource::CreateFileRef(connection(), | 266 entry.file_ref = FileRefResource::CreateFileRef(connection(), |
240 pp_instance(), | 267 pp_instance(), |
241 infos[i]); | 268 infos[i]); |
242 entry.file_type = file_types[i]; | 269 entry.file_type = file_types[i]; |
243 entries.push_back(entry); | 270 entries.push_back(entry); |
244 } | 271 } |
245 | 272 |
246 writer.StoreVector(entries); | 273 writer.StoreVector(entries); |
247 } | 274 } |
248 callback->Run(params.result()); | 275 callback->Run(params.result()); |
249 } | 276 } |
250 | 277 |
251 } // namespace proxy | 278 } // namespace proxy |
252 } // namespace ppapi | 279 } // namespace ppapi |
OLD | NEW |