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