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 |