| 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 "components/nacl/loader/nacl_ipc_adapter.h" | 5 #include "components/nacl/loader/nacl_ipc_adapter.h" |
| 6 | 6 |
| 7 #include <limits.h> | 7 #include <limits.h> |
| 8 #include <string.h> | 8 #include <string.h> |
| 9 | 9 |
| 10 #include "base/basictypes.h" | 10 #include "base/basictypes.h" |
| 11 #include "base/bind.h" | 11 #include "base/bind.h" |
| 12 #include "base/location.h" | 12 #include "base/location.h" |
| 13 #include "base/memory/scoped_ptr.h" | 13 #include "base/memory/scoped_ptr.h" |
| 14 #include "base/memory/shared_memory.h" | 14 #include "base/memory/shared_memory.h" |
| 15 #include "base/task_runner_util.h" | 15 #include "base/task_runner_util.h" |
| 16 #include "build/build_config.h" | 16 #include "build/build_config.h" |
| 17 #include "ipc/ipc_channel.h" | 17 #include "ipc/ipc_channel.h" |
| 18 #include "ipc/ipc_platform_file.h" | 18 #include "ipc/ipc_platform_file.h" |
| 19 #include "native_client/src/public/nacl_desc.h" |
| 19 #include "native_client/src/trusted/desc/nacl_desc_base.h" | 20 #include "native_client/src/trusted/desc/nacl_desc_base.h" |
| 20 #include "native_client/src/trusted/desc/nacl_desc_custom.h" | 21 #include "native_client/src/trusted/desc/nacl_desc_custom.h" |
| 21 #include "native_client/src/trusted/desc/nacl_desc_imc_shm.h" | 22 #include "native_client/src/trusted/desc/nacl_desc_imc_shm.h" |
| 22 #include "native_client/src/trusted/desc/nacl_desc_io.h" | 23 #include "native_client/src/trusted/desc/nacl_desc_io.h" |
| 23 #include "native_client/src/trusted/desc/nacl_desc_quota.h" | 24 #include "native_client/src/trusted/desc/nacl_desc_quota.h" |
| 24 #include "native_client/src/trusted/desc/nacl_desc_quota_interface.h" | 25 #include "native_client/src/trusted/desc/nacl_desc_quota_interface.h" |
| 25 #include "native_client/src/trusted/desc/nacl_desc_sync_socket.h" | 26 #include "native_client/src/trusted/desc/nacl_desc_sync_socket.h" |
| 26 #include "native_client/src/trusted/desc/nacl_desc_wrapper.h" | |
| 27 #include "native_client/src/trusted/service_runtime/include/sys/fcntl.h" | 27 #include "native_client/src/trusted/service_runtime/include/sys/fcntl.h" |
| 28 #include "native_client/src/trusted/validator/rich_file_info.h" | |
| 29 #include "ppapi/c/ppb_file_io.h" | 28 #include "ppapi/c/ppb_file_io.h" |
| 30 #include "ppapi/proxy/ppapi_messages.h" | 29 #include "ppapi/proxy/ppapi_messages.h" |
| 31 #include "ppapi/proxy/serialized_handle.h" | 30 #include "ppapi/proxy/serialized_handle.h" |
| 32 | 31 |
| 33 using ppapi::proxy::NaClMessageScanner; | 32 using ppapi::proxy::NaClMessageScanner; |
| 34 | 33 |
| 35 namespace { | 34 namespace { |
| 36 | 35 |
| 37 enum BufferSizeStatus { | 36 enum BufferSizeStatus { |
| 38 // The buffer contains a full message with no extra bytes. | 37 // The buffer contains a full message with no extra bytes. |
| (...skipping 619 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 658 SaveMessage(*new_msg, rewritten_msg.get()); | 657 SaveMessage(*new_msg, rewritten_msg.get()); |
| 659 cond_var_.Signal(); | 658 cond_var_.Signal(); |
| 660 } | 659 } |
| 661 return; | 660 return; |
| 662 } | 661 } |
| 663 | 662 |
| 664 // The file token was sucessfully resolved. | 663 // The file token was sucessfully resolved. |
| 665 std::string file_path_str = file_path.AsUTF8Unsafe(); | 664 std::string file_path_str = file_path.AsUTF8Unsafe(); |
| 666 base::PlatformFile handle = | 665 base::PlatformFile handle = |
| 667 IPC::PlatformFileForTransitToPlatformFile(ipc_fd); | 666 IPC::PlatformFileForTransitToPlatformFile(ipc_fd); |
| 668 // The file token was resolved successfully, so we populate the new | |
| 669 // NaClDesc with that information. | |
| 670 char* alloc_file_path = static_cast<char*>( | |
| 671 malloc(file_path_str.length() + 1)); | |
| 672 strcpy(alloc_file_path, file_path_str.c_str()); | |
| 673 scoped_ptr<NaClDescWrapper> desc_wrapper(new NaClDescWrapper( | |
| 674 NaClDescIoDescFromHandleAllocCtor(handle, NACL_ABI_O_RDONLY))); | |
| 675 | |
| 676 // Mark the desc as OK for mapping as executable memory. | |
| 677 NaClDescMarkSafeForMmap(desc_wrapper->desc()); | |
| 678 | |
| 679 // Provide metadata for validation. | |
| 680 struct NaClRichFileInfo info; | |
| 681 NaClRichFileInfoCtor(&info); | |
| 682 info.known_file = 1; | |
| 683 info.file_path = alloc_file_path; // Takes ownership. | |
| 684 info.file_path_length = | |
| 685 static_cast<uint32_t>(file_path_str.length()); | |
| 686 NaClSetFileOriginInfo(desc_wrapper->desc(), &info); | |
| 687 NaClRichFileInfoDtor(&info); | |
| 688 | 667 |
| 689 ppapi::proxy::SerializedHandle sh; | 668 ppapi::proxy::SerializedHandle sh; |
| 690 sh.set_file_handle(ipc_fd, PP_FILEOPENFLAG_READ, 0); | 669 sh.set_file_handle(ipc_fd, PP_FILEOPENFLAG_READ, 0); |
| 691 scoped_ptr<IPC::Message> new_msg = CreateOpenResourceReply(orig_msg, sh); | 670 scoped_ptr<IPC::Message> new_msg = CreateOpenResourceReply(orig_msg, sh); |
| 692 scoped_refptr<RewrittenMessage> rewritten_msg(new RewrittenMessage); | 671 scoped_refptr<RewrittenMessage> rewritten_msg(new RewrittenMessage); |
| 693 | 672 |
| 694 rewritten_msg->AddDescriptor(desc_wrapper.release()); | 673 struct NaClDesc* desc = |
| 674 NaClDescCreateWithFilePathMetadata(handle, file_path_str.c_str()); |
| 675 rewritten_msg->AddDescriptor(new NaClDescWrapper(desc)); |
| 695 { | 676 { |
| 696 base::AutoLock lock(lock_); | 677 base::AutoLock lock(lock_); |
| 697 SaveMessage(*new_msg, rewritten_msg.get()); | 678 SaveMessage(*new_msg, rewritten_msg.get()); |
| 698 cond_var_.Signal(); | 679 cond_var_.Signal(); |
| 699 } | 680 } |
| 700 } | 681 } |
| 701 | 682 |
| 702 void NaClIPCAdapter::OnChannelConnected(int32 peer_pid) { | 683 void NaClIPCAdapter::OnChannelConnected(int32 peer_pid) { |
| 703 } | 684 } |
| 704 | 685 |
| (...skipping 121 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 826 header.flags = msg.flags(); | 807 header.flags = msg.flags(); |
| 827 header.num_fds = static_cast<uint16>(rewritten_msg->desc_count()); | 808 header.num_fds = static_cast<uint16>(rewritten_msg->desc_count()); |
| 828 | 809 |
| 829 rewritten_msg->SetData(header, msg.payload(), msg.payload_size()); | 810 rewritten_msg->SetData(header, msg.payload(), msg.payload_size()); |
| 830 locked_data_.to_be_received_.push(rewritten_msg); | 811 locked_data_.to_be_received_.push(rewritten_msg); |
| 831 } | 812 } |
| 832 | 813 |
| 833 int TranslatePepperFileReadWriteOpenFlagsForTesting(int32_t pp_open_flags) { | 814 int TranslatePepperFileReadWriteOpenFlagsForTesting(int32_t pp_open_flags) { |
| 834 return TranslatePepperFileReadWriteOpenFlags(pp_open_flags); | 815 return TranslatePepperFileReadWriteOpenFlags(pp_open_flags); |
| 835 } | 816 } |
| OLD | NEW |