Index: ppapi/proxy/handle_converter.cc |
diff --git a/ppapi/proxy/handle_converter.cc b/ppapi/proxy/handle_converter.cc |
deleted file mode 100644 |
index 587585b53b6e449311721e83f120031beabd7395..0000000000000000000000000000000000000000 |
--- a/ppapi/proxy/handle_converter.cc |
+++ /dev/null |
@@ -1,282 +0,0 @@ |
-// Copyright (c) 2013 The Chromium Authors. All rights reserved. |
-// Use of this source code is governed by a BSD-style license that can be |
-// found in the LICENSE file. |
- |
-#include "ppapi/proxy/handle_converter.h" |
- |
-#include <vector> |
-#include "base/bind.h" |
-#include "ipc/ipc_message.h" |
-#include "ipc/ipc_message_macros.h" |
-#include "ppapi/proxy/ppapi_messages.h" |
-#include "ppapi/proxy/resource_message_params.h" |
-#include "ppapi/proxy/serialized_handle.h" |
-#include "ppapi/proxy/serialized_var.h" |
- |
-class NaClDescImcShm; |
- |
-namespace IPC { |
-class Message; |
-} |
- |
-namespace { |
- |
-void WriteHandle(int handle_index, |
- const ppapi::proxy::SerializedHandle& handle, |
- IPC::Message* message) { |
- ppapi::proxy::SerializedHandle::WriteHeader(handle.header(), message); |
- |
- // Now write the handle itself in POSIX style. |
- message->WriteBool(true); // valid == true |
- message->WriteInt(handle_index); |
-} |
- |
-typedef std::vector<ppapi::proxy::SerializedHandle> Handles; |
- |
-// We define overloads for catching SerializedHandles so that we can share |
-// them correctly to the untrusted side. |
-// See ConvertHandlesImpl for how these get used. |
-void ConvertHandlesInParam(const ppapi::proxy::SerializedHandle& handle, |
- Handles* handles, |
- IPC::Message* msg, |
- int* handle_index) { |
- handles->push_back(handle); |
- if (msg) |
- WriteHandle((*handle_index)++, handle, msg); |
-} |
- |
-void HandleWriter(int* handle_index, |
- IPC::Message* m, |
- const ppapi::proxy::SerializedHandle& handle) { |
- WriteHandle((*handle_index)++, handle, m); |
-} |
- |
-void ConvertHandlesInParam(const ppapi::proxy::SerializedVar& var, |
- Handles* handles, |
- IPC::Message* msg, |
- int* handle_index) { |
- std::vector<ppapi::proxy::SerializedHandle*> var_handles = var.GetHandles(); |
- if (var_handles.empty()) |
- return; |
- |
- for (size_t i = 0; i < var_handles.size(); ++i) |
- handles->push_back(*var_handles[i]); |
- if (msg) |
- var.WriteDataToMessage(msg, base::Bind(&HandleWriter, handle_index)); |
-} |
- |
-// For PpapiMsg_ResourceReply and the reply to PpapiHostMsg_ResourceSyncCall, |
-// the handles are carried inside the ResourceMessageReplyParams. |
-// NOTE: We only translate handles from host->NaCl. The only kind of |
-// ResourceMessageParams that travels this direction is |
-// ResourceMessageReplyParams, so that's the only one we need to handle. |
-void ConvertHandlesInParam( |
- const ppapi::proxy::ResourceMessageReplyParams& params, |
- Handles* handles, |
- IPC::Message* msg, |
- int* handle_index) { |
- // First, if we need to rewrite the message parameters, write everything |
- // before the handles (there's nothing after the handles). |
- if (msg) { |
- params.WriteReplyHeader(msg); |
- // IPC writes the vector length as an int before the contents of the |
- // vector. |
- msg->WriteInt(static_cast<int>(params.handles().size())); |
- } |
- for (Handles::const_iterator iter = params.handles().begin(); |
- iter != params.handles().end(); |
- ++iter) { |
- // ConvertHandle will write each handle to |msg|, if necessary. |
- ConvertHandlesInParam(*iter, handles, msg, handle_index); |
- } |
- // Tell ResourceMessageReplyParams that we have taken the handles, so it |
- // shouldn't close them. The NaCl runtime will take ownership of them. |
- params.ConsumeHandles(); |
-} |
- |
-// This overload is to catch all types other than SerializedHandle or |
-// ResourceMessageReplyParams. On Windows, |msg| will be a valid pointer, and we |
-// must write |param| to it. |
-template <class T> |
-void ConvertHandlesInParam(const T& param, |
- Handles* /* handles */, |
- IPC::Message* msg, |
- int* /* handle_index */) { |
- // It's not a handle, so just write to the output message, if necessary. |
- if (msg) |
- IPC::WriteParam(msg, param); |
-} |
- |
-// These just break apart the given tuple and run ConvertHandle over each param. |
-// The idea is to extract any handles in the tuple, while writing all data to |
-// msg (if msg is valid). The msg will only be valid on Windows, where we need |
-// to re-write all of the message parameters, writing the handles in POSIX style |
-// for NaCl. |
-template <class A> |
-void ConvertHandlesImpl(const Tuple1<A>& t1, Handles* handles, |
- IPC::Message* msg) { |
- int handle_index = 0; |
- ConvertHandlesInParam(t1.a, handles, msg, &handle_index); |
-} |
-template <class A, class B> |
-void ConvertHandlesImpl(const Tuple2<A, B>& t1, Handles* handles, |
- IPC::Message* msg) { |
- int handle_index = 0; |
- ConvertHandlesInParam(t1.a, handles, msg, &handle_index); |
- ConvertHandlesInParam(t1.b, handles, msg, &handle_index); |
-} |
-template <class A, class B, class C> |
-void ConvertHandlesImpl(const Tuple3<A, B, C>& t1, Handles* handles, |
- IPC::Message* msg) { |
- int handle_index = 0; |
- ConvertHandlesInParam(t1.a, handles, msg, &handle_index); |
- ConvertHandlesInParam(t1.b, handles, msg, &handle_index); |
- ConvertHandlesInParam(t1.c, handles, msg, &handle_index); |
-} |
-template <class A, class B, class C, class D> |
-void ConvertHandlesImpl(const Tuple4<A, B, C, D>& t1, Handles* handles, |
- IPC::Message* msg) { |
- int handle_index = 0; |
- ConvertHandlesInParam(t1.a, handles, msg, &handle_index); |
- ConvertHandlesInParam(t1.b, handles, msg, &handle_index); |
- ConvertHandlesInParam(t1.c, handles, msg, &handle_index); |
- ConvertHandlesInParam(t1.d, handles, msg, &handle_index); |
-} |
- |
-template <class MessageType> |
-class HandleConverterImpl { |
- public: |
- explicit HandleConverterImpl(const IPC::Message* msg) |
- : msg_(static_cast<const MessageType*>(msg)) { |
- } |
- bool ConvertMessage(Handles* handles, IPC::Message* out_msg) { |
- typename TupleTypes<typename MessageType::Schema::Param>::ValueTuple params; |
- if (!MessageType::Read(msg_, ¶ms)) |
- return false; |
- ConvertHandlesImpl(params, handles, out_msg); |
- return true; |
- } |
- |
- bool ConvertReply(Handles* handles, IPC::SyncMessage* out_msg) { |
- typename TupleTypes<typename MessageType::Schema::ReplyParam>::ValueTuple |
- params; |
- if (!MessageType::ReadReplyParam(msg_, ¶ms)) |
- return false; |
- // If we need to rewrite the message (i.e., on Windows), we need to make |
- // sure we write the message id first. |
- if (out_msg) { |
- out_msg->set_reply(); |
- int id = IPC::SyncMessage::GetMessageId(*msg_); |
- out_msg->WriteInt(id); |
- } |
- ConvertHandlesImpl(params, handles, out_msg); |
- return true; |
- } |
- // TODO(dmichael): Add ConvertSyncMessage for outgoing sync messages, if we |
- // ever pass handles in one of those. |
- |
- private: |
- const MessageType* msg_; |
-}; |
- |
-} // namespace |
- |
-#define CASE_FOR_MESSAGE(MESSAGE_TYPE) \ |
- case MESSAGE_TYPE::ID: { \ |
- HandleConverterImpl<MESSAGE_TYPE> extractor(&msg); \ |
- if (!extractor.ConvertMessage(handles, new_msg_ptr->get())) \ |
- return false; \ |
- break; \ |
- } |
-#define CASE_FOR_REPLY(MESSAGE_TYPE) \ |
- case MESSAGE_TYPE::ID: { \ |
- HandleConverterImpl<MESSAGE_TYPE> extractor(&msg); \ |
- if (!extractor.ConvertReply( \ |
- handles, \ |
- static_cast<IPC::SyncMessage*>(new_msg_ptr->get()))) \ |
- return false; \ |
- break; \ |
- } |
- |
-namespace ppapi { |
-namespace proxy { |
- |
-class SerializedHandle; |
- |
-HandleConverter::HandleConverter() { |
-} |
- |
-bool HandleConverter::ConvertNativeHandlesToPosix( |
- const IPC::Message& msg, |
- std::vector<SerializedHandle>* handles, |
- scoped_ptr<IPC::Message>* new_msg_ptr) { |
- DCHECK(handles); |
- DCHECK(new_msg_ptr); |
- DCHECK(!new_msg_ptr->get()); |
- |
- // In Windows, we need to re-write the contents of the message. This is |
- // because in Windows IPC code, native HANDLE values are serialized in the |
- // body of the message. |
- // |
- // In POSIX, we only serialize an index in to a FileDescriptorSet, and the |
- // actual file descriptors are sent out-of-band. So on Windows, to make a |
- // message that's compatible with Windows, we need to write a new message that |
- // has simple indices in the message body instead of the HANDLEs. |
- // |
- // NOTE: This means on Windows, new_msg_ptr's serialized contents are not |
- // compatible with Windows IPC deserialization code; it is intended to be |
- // passed to NaCl. |
-#if defined(OS_WIN) |
- new_msg_ptr->reset(new IPC::Message(msg.routing_id(), msg.type())); |
-#else |
- // Even on POSIX, we have to rewrite messages to create channels, because |
- // these contain a handle with an invalid (place holder) descriptor. The |
- // message sending code sees this and doesn't pass the descriptor over |
- // correctly. |
- if (msg.type() == PpapiMsg_CreateNaClChannel::ID) |
- new_msg_ptr->reset(new IPC::Message(msg.routing_id(), msg.type())); |
-#endif |
- |
- switch (msg.type()) { |
- CASE_FOR_MESSAGE(PpapiMsg_CreateNaClChannel) |
- CASE_FOR_MESSAGE(PpapiMsg_PPBAudio_NotifyAudioStreamCreated) |
- CASE_FOR_MESSAGE(PpapiMsg_PPPMessaging_HandleMessage) |
- CASE_FOR_MESSAGE(PpapiPluginMsg_ResourceReply) |
- case IPC_REPLY_ID: { |
- int id = IPC::SyncMessage::GetMessageId(msg); |
- PendingSyncMsgMap::iterator iter(pending_sync_msgs_.find(id)); |
- if (iter == pending_sync_msgs_.end()) { |
- NOTREACHED(); |
- return false; |
- } |
- uint32_t type = iter->second; |
- pending_sync_msgs_.erase(iter); |
- switch (type) { |
- CASE_FOR_REPLY(PpapiHostMsg_PPBGraphics3D_GetTransferBuffer) |
- CASE_FOR_REPLY(PpapiHostMsg_PPBImageData_CreateSimple) |
- CASE_FOR_REPLY(PpapiHostMsg_ResourceSyncCall) |
- CASE_FOR_REPLY(PpapiHostMsg_SharedMemory_CreateSharedMemory) |
- default: |
- // Do nothing for messages we don't know. |
- break; |
- } |
- break; |
- } |
- default: |
- // Do nothing for messages we don't know. |
- break; |
- } |
- return true; |
-} |
- |
-void HandleConverter::RegisterSyncMessageForReply(const IPC::Message& msg) { |
- DCHECK(msg.is_sync()); |
- |
- int msg_id = IPC::SyncMessage::GetMessageId(msg); |
- DCHECK(pending_sync_msgs_.find(msg_id) == pending_sync_msgs_.end()); |
- |
- pending_sync_msgs_[msg_id] = msg.type(); |
-} |
- |
-} // namespace proxy |
-} // namespace ppapi |