| OLD | NEW |
| (Empty) |
| 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 | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "ppapi/proxy/ppb_file_io_proxy.h" | |
| 6 | |
| 7 #include "ppapi/c/pp_errors.h" | |
| 8 #include "ppapi/proxy/enter_proxy.h" | |
| 9 #include "ppapi/proxy/ppapi_messages.h" | |
| 10 #include "ppapi/proxy/ppb_file_ref_proxy.h" | |
| 11 #include "ppapi/shared_impl/ppapi_globals.h" | |
| 12 #include "ppapi/shared_impl/ppb_file_io_shared.h" | |
| 13 #include "ppapi/shared_impl/resource.h" | |
| 14 #include "ppapi/shared_impl/resource_tracker.h" | |
| 15 | |
| 16 using ppapi::thunk::PPB_FileIO_API; | |
| 17 using ppapi::thunk::PPB_FileRef_API; | |
| 18 | |
| 19 namespace ppapi { | |
| 20 namespace proxy { | |
| 21 | |
| 22 namespace { | |
| 23 | |
| 24 // The maximum size we'll support reading in one chunk. The renderer process | |
| 25 // must allocate a buffer sized according to the request of the plugin. To | |
| 26 // keep things from getting out of control, we cap the read size to this value. | |
| 27 // This should generally be OK since the API specifies that it may perform a | |
| 28 // partial read. | |
| 29 static const int32_t kMaxReadSize = 33554432; // 32MB | |
| 30 | |
| 31 typedef EnterHostFromHostResourceForceCallback<PPB_FileIO_API> EnterHostFileIO; | |
| 32 typedef EnterPluginFromHostResource<PPB_FileIO_API> EnterPluginFileIO; | |
| 33 | |
| 34 class FileIO : public PPB_FileIO_Shared { | |
| 35 public: | |
| 36 explicit FileIO(const HostResource& host_resource); | |
| 37 virtual ~FileIO(); | |
| 38 | |
| 39 // PPB_FileIO_API implementation (not provided by FileIOImpl). | |
| 40 virtual void Close() OVERRIDE; | |
| 41 virtual int32_t GetOSFileDescriptor() OVERRIDE; | |
| 42 virtual int32_t WillWrite(int64_t offset, | |
| 43 int32_t bytes_to_write, | |
| 44 PP_CompletionCallback callback) OVERRIDE; | |
| 45 virtual int32_t WillSetLength(int64_t length, | |
| 46 PP_CompletionCallback callback) OVERRIDE; | |
| 47 | |
| 48 private: | |
| 49 // FileIOImpl overrides. | |
| 50 virtual int32_t OpenValidated(PP_Resource file_ref_resource, | |
| 51 PPB_FileRef_API* file_ref_api, | |
| 52 int32_t open_flags, | |
| 53 PP_CompletionCallback callback) OVERRIDE; | |
| 54 virtual int32_t QueryValidated(PP_FileInfo* info, | |
| 55 PP_CompletionCallback callback) OVERRIDE; | |
| 56 virtual int32_t TouchValidated(PP_Time last_access_time, | |
| 57 PP_Time last_modified_time, | |
| 58 PP_CompletionCallback callback) OVERRIDE; | |
| 59 virtual int32_t ReadValidated(int64_t offset, | |
| 60 char* buffer, | |
| 61 int32_t bytes_to_read, | |
| 62 PP_CompletionCallback callback) OVERRIDE; | |
| 63 virtual int32_t WriteValidated(int64_t offset, | |
| 64 const char* buffer, | |
| 65 int32_t bytes_to_write, | |
| 66 PP_CompletionCallback callback) OVERRIDE; | |
| 67 virtual int32_t SetLengthValidated(int64_t length, | |
| 68 PP_CompletionCallback callback) OVERRIDE; | |
| 69 virtual int32_t FlushValidated(PP_CompletionCallback callback) OVERRIDE; | |
| 70 | |
| 71 PluginDispatcher* GetDispatcher() const { | |
| 72 return PluginDispatcher::GetForResource(this); | |
| 73 } | |
| 74 | |
| 75 static const ApiID kApiID = API_ID_PPB_FILE_IO; | |
| 76 | |
| 77 DISALLOW_IMPLICIT_CONSTRUCTORS(FileIO); | |
| 78 }; | |
| 79 | |
| 80 FileIO::FileIO(const HostResource& host_resource) | |
| 81 : PPB_FileIO_Shared(host_resource) { | |
| 82 } | |
| 83 | |
| 84 FileIO::~FileIO() { | |
| 85 Close(); | |
| 86 } | |
| 87 | |
| 88 void FileIO::Close() { | |
| 89 if (file_open_) { | |
| 90 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_Close(kApiID, | |
| 91 host_resource())); | |
| 92 } | |
| 93 } | |
| 94 | |
| 95 int32_t FileIO::GetOSFileDescriptor() { | |
| 96 return -1; | |
| 97 } | |
| 98 | |
| 99 int32_t FileIO::WillWrite(int64_t offset, | |
| 100 int32_t bytes_to_write, | |
| 101 PP_CompletionCallback callback) { | |
| 102 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_WillWrite( | |
| 103 kApiID, host_resource(), offset, bytes_to_write)); | |
| 104 RegisterCallback(OPERATION_EXCLUSIVE, callback, NULL, NULL); | |
| 105 return PP_OK_COMPLETIONPENDING; | |
| 106 } | |
| 107 | |
| 108 int32_t FileIO::WillSetLength(int64_t length, | |
| 109 PP_CompletionCallback callback) { | |
| 110 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_WillSetLength( | |
| 111 kApiID, host_resource(), length)); | |
| 112 RegisterCallback(OPERATION_EXCLUSIVE, callback, NULL, NULL); | |
| 113 return PP_OK_COMPLETIONPENDING; | |
| 114 } | |
| 115 | |
| 116 int32_t FileIO::OpenValidated(PP_Resource file_ref_resource, | |
| 117 PPB_FileRef_API* file_ref_api, | |
| 118 int32_t open_flags, | |
| 119 PP_CompletionCallback callback) { | |
| 120 Resource* file_ref_object = | |
| 121 PpapiGlobals::Get()->GetResourceTracker()->GetResource(file_ref_resource); | |
| 122 | |
| 123 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_Open( | |
| 124 kApiID, host_resource(), file_ref_object->host_resource(), open_flags)); | |
| 125 RegisterCallback(OPERATION_EXCLUSIVE, callback, NULL, NULL); | |
| 126 return PP_OK_COMPLETIONPENDING; | |
| 127 } | |
| 128 | |
| 129 int32_t FileIO::QueryValidated(PP_FileInfo* info, | |
| 130 PP_CompletionCallback callback) { | |
| 131 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_Query( | |
| 132 kApiID, host_resource())); | |
| 133 RegisterCallback(OPERATION_EXCLUSIVE, callback, NULL, info); | |
| 134 return PP_OK_COMPLETIONPENDING; | |
| 135 } | |
| 136 | |
| 137 int32_t FileIO::TouchValidated(PP_Time last_access_time, | |
| 138 PP_Time last_modified_time, | |
| 139 PP_CompletionCallback callback) { | |
| 140 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_Touch( | |
| 141 kApiID, host_resource(), last_access_time, last_modified_time)); | |
| 142 RegisterCallback(OPERATION_EXCLUSIVE, callback, NULL, NULL); | |
| 143 return PP_OK_COMPLETIONPENDING; | |
| 144 } | |
| 145 | |
| 146 int32_t FileIO::ReadValidated(int64_t offset, | |
| 147 char* buffer, | |
| 148 int32_t bytes_to_read, | |
| 149 PP_CompletionCallback callback) { | |
| 150 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_Read( | |
| 151 kApiID, host_resource(), offset, bytes_to_read)); | |
| 152 RegisterCallback(OPERATION_READ, callback, buffer, NULL); | |
| 153 return PP_OK_COMPLETIONPENDING; | |
| 154 } | |
| 155 | |
| 156 int32_t FileIO::WriteValidated(int64_t offset, | |
| 157 const char* buffer, | |
| 158 int32_t bytes_to_write, | |
| 159 PP_CompletionCallback callback) { | |
| 160 // TODO(brettw) it would be nice to use a shared memory buffer for large | |
| 161 // writes rather than having to copy to a string (which will involve a number | |
| 162 // of extra copies to serialize over IPC). | |
| 163 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_Write( | |
| 164 kApiID, host_resource(), offset, std::string(buffer, bytes_to_write))); | |
| 165 RegisterCallback(OPERATION_WRITE, callback, NULL, NULL); | |
| 166 return PP_OK_COMPLETIONPENDING; | |
| 167 } | |
| 168 | |
| 169 int32_t FileIO::SetLengthValidated(int64_t length, | |
| 170 PP_CompletionCallback callback) { | |
| 171 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_SetLength( | |
| 172 kApiID, host_resource(), length)); | |
| 173 RegisterCallback(OPERATION_EXCLUSIVE, callback, NULL, NULL); | |
| 174 return PP_OK_COMPLETIONPENDING; | |
| 175 } | |
| 176 | |
| 177 int32_t FileIO::FlushValidated(PP_CompletionCallback callback) { | |
| 178 GetDispatcher()->Send(new PpapiHostMsg_PPBFileIO_Flush( | |
| 179 kApiID, host_resource())); | |
| 180 RegisterCallback(OPERATION_EXCLUSIVE, callback, NULL, NULL); | |
| 181 return PP_OK_COMPLETIONPENDING; | |
| 182 } | |
| 183 | |
| 184 } // namespace | |
| 185 | |
| 186 // ----------------------------------------------------------------------------- | |
| 187 | |
| 188 PPB_FileIO_Proxy::PPB_FileIO_Proxy(Dispatcher* dispatcher) | |
| 189 : InterfaceProxy(dispatcher), | |
| 190 callback_factory_(ALLOW_THIS_IN_INITIALIZER_LIST(this)) { | |
| 191 } | |
| 192 | |
| 193 PPB_FileIO_Proxy::~PPB_FileIO_Proxy() { | |
| 194 } | |
| 195 | |
| 196 // static | |
| 197 PP_Resource PPB_FileIO_Proxy::CreateProxyResource(PP_Instance instance) { | |
| 198 PluginDispatcher* dispatcher = PluginDispatcher::GetForInstance(instance); | |
| 199 if (!dispatcher) | |
| 200 return 0; | |
| 201 | |
| 202 HostResource result; | |
| 203 dispatcher->Send(new PpapiHostMsg_PPBFileIO_Create(kApiID, instance, | |
| 204 &result)); | |
| 205 if (result.is_null()) | |
| 206 return 0; | |
| 207 return (new FileIO(result))->GetReference(); | |
| 208 } | |
| 209 | |
| 210 bool PPB_FileIO_Proxy::OnMessageReceived(const IPC::Message& msg) { | |
| 211 bool handled = true; | |
| 212 IPC_BEGIN_MESSAGE_MAP(PPB_FileIO_Proxy, msg) | |
| 213 // Plugin -> host message. | |
| 214 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_Create, OnHostMsgCreate) | |
| 215 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_Open, OnHostMsgOpen) | |
| 216 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_Close, OnHostMsgClose) | |
| 217 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_Query, OnHostMsgQuery) | |
| 218 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_Touch, OnHostMsgTouch) | |
| 219 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_Read, OnHostMsgRead) | |
| 220 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_Write, OnHostMsgWrite) | |
| 221 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_SetLength, OnHostMsgSetLength) | |
| 222 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_Flush, OnHostMsgFlush) | |
| 223 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_WillWrite, OnHostMsgWillWrite) | |
| 224 IPC_MESSAGE_HANDLER(PpapiHostMsg_PPBFileIO_WillSetLength, | |
| 225 OnHostMsgWillSetLength) | |
| 226 | |
| 227 // Host -> plugin messages. | |
| 228 IPC_MESSAGE_HANDLER(PpapiMsg_PPBFileIO_GeneralComplete, | |
| 229 OnPluginMsgGeneralComplete) | |
| 230 IPC_MESSAGE_HANDLER(PpapiMsg_PPBFileIO_OpenFileComplete, | |
| 231 OnPluginMsgOpenFileComplete) | |
| 232 IPC_MESSAGE_HANDLER(PpapiMsg_PPBFileIO_QueryComplete, | |
| 233 OnPluginMsgQueryComplete) | |
| 234 IPC_MESSAGE_HANDLER(PpapiMsg_PPBFileIO_ReadComplete, | |
| 235 OnPluginMsgReadComplete) | |
| 236 IPC_MESSAGE_UNHANDLED(handled = false) | |
| 237 IPC_END_MESSAGE_MAP() | |
| 238 return handled; | |
| 239 } | |
| 240 | |
| 241 void PPB_FileIO_Proxy::OnHostMsgCreate(PP_Instance instance, | |
| 242 HostResource* result) { | |
| 243 thunk::EnterResourceCreation enter(instance); | |
| 244 if (enter.succeeded()) { | |
| 245 result->SetHostResource(instance, | |
| 246 enter.functions()->CreateFileIO(instance)); | |
| 247 } | |
| 248 } | |
| 249 | |
| 250 void PPB_FileIO_Proxy::OnHostMsgOpen(const HostResource& host_resource, | |
| 251 const HostResource& file_ref_resource, | |
| 252 int32_t open_flags) { | |
| 253 EnterHostFileIO enter(host_resource, callback_factory_, | |
| 254 &PPB_FileIO_Proxy::OpenFileCallbackCompleteInHost, host_resource); | |
| 255 if (enter.succeeded()) { | |
| 256 enter.SetResult(enter.object()->Open( | |
| 257 file_ref_resource.host_resource(), open_flags, enter.callback())); | |
| 258 } | |
| 259 } | |
| 260 | |
| 261 void PPB_FileIO_Proxy::OnHostMsgClose(const HostResource& host_resource) { | |
| 262 EnterHostFromHostResource<PPB_FileIO_API> enter(host_resource); | |
| 263 if (enter.succeeded()) | |
| 264 enter.object()->Close(); | |
| 265 } | |
| 266 | |
| 267 void PPB_FileIO_Proxy::OnHostMsgQuery(const HostResource& host_resource) { | |
| 268 // The callback will take charge of deleting the FileInfo. The contents must | |
| 269 // be defined so we don't send garbage to the plugin in the failure case. | |
| 270 PP_FileInfo* info = new PP_FileInfo; | |
| 271 memset(info, 0, sizeof(PP_FileInfo)); | |
| 272 EnterHostFileIO enter(host_resource, callback_factory_, | |
| 273 &PPB_FileIO_Proxy::QueryCallbackCompleteInHost, | |
| 274 host_resource, info); | |
| 275 if (enter.succeeded()) | |
| 276 enter.SetResult(enter.object()->Query(info, enter.callback())); | |
| 277 } | |
| 278 | |
| 279 void PPB_FileIO_Proxy::OnHostMsgTouch(const HostResource& host_resource, | |
| 280 PP_Time last_access_time, | |
| 281 PP_Time last_modified_time) { | |
| 282 EnterHostFileIO enter(host_resource, callback_factory_, | |
| 283 &PPB_FileIO_Proxy::GeneralCallbackCompleteInHost, | |
| 284 host_resource); | |
| 285 if (enter.succeeded()) { | |
| 286 enter.SetResult(enter.object()->Touch(last_access_time, last_modified_time, | |
| 287 enter.callback())); | |
| 288 } | |
| 289 } | |
| 290 | |
| 291 void PPB_FileIO_Proxy::OnHostMsgRead(const HostResource& host_resource, | |
| 292 int64_t offset, | |
| 293 int32_t bytes_to_read) { | |
| 294 // Validate bytes_to_read before allocating below. This value is coming from | |
| 295 // the untrusted plugin. | |
| 296 bytes_to_read = std::min(bytes_to_read, kMaxReadSize); | |
| 297 if (bytes_to_read < 0) { | |
| 298 ReadCallbackCompleteInHost(PP_ERROR_FAILED, host_resource, | |
| 299 new std::string()); | |
| 300 return; | |
| 301 } | |
| 302 | |
| 303 // The callback will take charge of deleting the string. | |
| 304 std::string* dest = new std::string; | |
| 305 dest->resize(bytes_to_read); | |
| 306 EnterHostFileIO enter(host_resource, callback_factory_, | |
| 307 &PPB_FileIO_Proxy::ReadCallbackCompleteInHost, | |
| 308 host_resource, dest); | |
| 309 if (enter.succeeded()) { | |
| 310 enter.SetResult(enter.object()->Read(offset, | |
| 311 bytes_to_read > 0 ? &(*dest)[0] : NULL, | |
| 312 bytes_to_read, enter.callback())); | |
| 313 } | |
| 314 } | |
| 315 | |
| 316 void PPB_FileIO_Proxy::OnHostMsgWrite(const HostResource& host_resource, | |
| 317 int64_t offset, | |
| 318 const std::string& data) { | |
| 319 EnterHostFileIO enter(host_resource, callback_factory_, | |
| 320 &PPB_FileIO_Proxy::GeneralCallbackCompleteInHost, | |
| 321 host_resource); | |
| 322 if (enter.succeeded()) { | |
| 323 enter.SetResult(enter.object()->Write(offset, data.data(), data.size(), | |
| 324 enter.callback())); | |
| 325 } | |
| 326 } | |
| 327 | |
| 328 void PPB_FileIO_Proxy::OnHostMsgSetLength(const HostResource& host_resource, | |
| 329 int64_t length) { | |
| 330 EnterHostFileIO enter(host_resource, callback_factory_, | |
| 331 &PPB_FileIO_Proxy::GeneralCallbackCompleteInHost, | |
| 332 host_resource); | |
| 333 if (enter.succeeded()) | |
| 334 enter.SetResult(enter.object()->SetLength(length, enter.callback())); | |
| 335 } | |
| 336 | |
| 337 void PPB_FileIO_Proxy::OnHostMsgFlush(const HostResource& host_resource) { | |
| 338 EnterHostFileIO enter(host_resource, callback_factory_, | |
| 339 &PPB_FileIO_Proxy::GeneralCallbackCompleteInHost, | |
| 340 host_resource); | |
| 341 if (enter.succeeded()) | |
| 342 enter.SetResult(enter.object()->Flush(enter.callback())); | |
| 343 } | |
| 344 | |
| 345 void PPB_FileIO_Proxy::OnHostMsgWillWrite(const HostResource& host_resource, | |
| 346 int64_t offset, | |
| 347 int32_t bytes_to_write) { | |
| 348 EnterHostFileIO enter(host_resource, callback_factory_, | |
| 349 &PPB_FileIO_Proxy::GeneralCallbackCompleteInHost, | |
| 350 host_resource); | |
| 351 if (enter.succeeded()) { | |
| 352 enter.SetResult(enter.object()->WillWrite(offset, bytes_to_write, | |
| 353 enter.callback())); | |
| 354 } | |
| 355 } | |
| 356 | |
| 357 void PPB_FileIO_Proxy::OnHostMsgWillSetLength(const HostResource& host_resource, | |
| 358 int64_t length) { | |
| 359 EnterHostFileIO enter(host_resource, callback_factory_, | |
| 360 &PPB_FileIO_Proxy::GeneralCallbackCompleteInHost, | |
| 361 host_resource); | |
| 362 if (enter.succeeded()) | |
| 363 enter.SetResult(enter.object()->WillSetLength(length, enter.callback())); | |
| 364 } | |
| 365 | |
| 366 void PPB_FileIO_Proxy::OnPluginMsgGeneralComplete( | |
| 367 const HostResource& host_resource, | |
| 368 int32_t result) { | |
| 369 EnterPluginFileIO enter(host_resource); | |
| 370 if (enter.succeeded()) | |
| 371 static_cast<FileIO*>(enter.object())->ExecuteGeneralCallback(result); | |
| 372 } | |
| 373 | |
| 374 void PPB_FileIO_Proxy::OnPluginMsgOpenFileComplete( | |
| 375 const HostResource& host_resource, | |
| 376 int32_t result) { | |
| 377 EnterPluginFileIO enter(host_resource); | |
| 378 if (enter.succeeded()) | |
| 379 static_cast<FileIO*>(enter.object())->ExecuteOpenFileCallback(result); | |
| 380 } | |
| 381 | |
| 382 void PPB_FileIO_Proxy::OnPluginMsgQueryComplete( | |
| 383 const HostResource& host_resource, | |
| 384 int32_t result, | |
| 385 const PP_FileInfo& info) { | |
| 386 EnterPluginFileIO enter(host_resource); | |
| 387 if (enter.succeeded()) | |
| 388 static_cast<FileIO*>(enter.object())->ExecuteQueryCallback(result, info); | |
| 389 } | |
| 390 | |
| 391 void PPB_FileIO_Proxy::OnPluginMsgReadComplete( | |
| 392 const HostResource& host_resource, | |
| 393 int32_t result, | |
| 394 const std::string& data) { | |
| 395 EnterPluginFileIO enter(host_resource); | |
| 396 if (enter.succeeded()) { | |
| 397 // The result code should contain the data size if it's positive. | |
| 398 DCHECK((result < 0 && data.size() == 0) || | |
| 399 result == static_cast<int32_t>(data.size())); | |
| 400 static_cast<FileIO*>(enter.object())->ExecuteReadCallback(result, | |
| 401 data.data()); | |
| 402 } | |
| 403 } | |
| 404 | |
| 405 void PPB_FileIO_Proxy::GeneralCallbackCompleteInHost( | |
| 406 int32_t pp_error, | |
| 407 const HostResource& host_resource) { | |
| 408 Send(new PpapiMsg_PPBFileIO_GeneralComplete(kApiID, host_resource, pp_error)); | |
| 409 } | |
| 410 | |
| 411 void PPB_FileIO_Proxy::OpenFileCallbackCompleteInHost( | |
| 412 int32_t pp_error, | |
| 413 const HostResource& host_resource) { | |
| 414 Send(new PpapiMsg_PPBFileIO_OpenFileComplete(kApiID, host_resource, | |
| 415 pp_error)); | |
| 416 } | |
| 417 | |
| 418 void PPB_FileIO_Proxy::QueryCallbackCompleteInHost( | |
| 419 int32_t pp_error, | |
| 420 const HostResource& host_resource, | |
| 421 PP_FileInfo* info) { | |
| 422 Send(new PpapiMsg_PPBFileIO_QueryComplete(kApiID, host_resource, pp_error, | |
| 423 *info)); | |
| 424 delete info; | |
| 425 } | |
| 426 | |
| 427 void PPB_FileIO_Proxy::ReadCallbackCompleteInHost( | |
| 428 int32_t pp_error, | |
| 429 const HostResource& host_resource, | |
| 430 std::string* data) { | |
| 431 // Only send the amount of data in the string that was actually read. | |
| 432 if (pp_error >= 0) { | |
| 433 DCHECK(pp_error <= static_cast<int32_t>(data->size())); | |
| 434 data->resize(pp_error); | |
| 435 } | |
| 436 Send(new PpapiMsg_PPBFileIO_ReadComplete(kApiID, host_resource, pp_error, | |
| 437 *data)); | |
| 438 delete data; | |
| 439 } | |
| 440 | |
| 441 } // namespace proxy | |
| 442 } // namespace ppapi | |
| OLD | NEW |