| OLD | NEW |
| 1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "build/build_config.h" | 5 #include "build/build_config.h" |
| 6 #include "ipc/ipc_channel.h" | 6 #include "ipc/ipc_channel.h" |
| 7 #include "ipc/ipc_channel_mojo.h" | 7 #include "ipc/ipc_channel_mojo.h" |
| 8 #include "mojo/public/cpp/system/message_pipe.h" | 8 #include "mojo/public/cpp/system/message_pipe.h" |
| 9 | 9 |
| 10 namespace IPC { | 10 namespace IPC { |
| 11 | 11 |
| 12 #if defined(OS_LINUX) |
| 13 |
| 14 namespace { |
| 15 int g_global_pid = 0; |
| 16 } |
| 17 |
| 18 // static |
| 19 void Channel::SetGlobalPid(int pid) { |
| 20 g_global_pid = pid; |
| 21 } |
| 22 |
| 23 // static |
| 24 int Channel::GetGlobalPid() { |
| 25 return g_global_pid; |
| 26 } |
| 27 |
| 28 #endif // defined(OS_LINUX) |
| 29 |
| 12 // static | 30 // static |
| 13 std::unique_ptr<Channel> Channel::CreateClient( | 31 std::unique_ptr<Channel> Channel::CreateClient( |
| 14 const IPC::ChannelHandle& channel_handle, | 32 const IPC::ChannelHandle& channel_handle, |
| 15 Listener* listener, | 33 Listener* listener, |
| 16 const scoped_refptr<base::SingleThreadTaskRunner>& ipc_task_runner) { | 34 const scoped_refptr<base::SingleThreadTaskRunner>& ipc_task_runner) { |
| 17 if (channel_handle.mojo_handle.is_valid()) { | 35 #if defined(OS_NACL_SFI) |
| 18 return ChannelMojo::Create( | |
| 19 mojo::ScopedMessagePipeHandle(channel_handle.mojo_handle), | |
| 20 Channel::MODE_CLIENT, listener, ipc_task_runner); | |
| 21 } | |
| 22 return Channel::Create(channel_handle, Channel::MODE_CLIENT, listener); | 36 return Channel::Create(channel_handle, Channel::MODE_CLIENT, listener); |
| 37 #else |
| 38 DCHECK(channel_handle.is_mojo_channel_handle()); |
| 39 return ChannelMojo::Create( |
| 40 mojo::ScopedMessagePipeHandle(channel_handle.mojo_handle), |
| 41 Channel::MODE_CLIENT, listener, ipc_task_runner); |
| 42 #endif |
| 23 } | 43 } |
| 24 | 44 |
| 25 // static | 45 // static |
| 26 std::unique_ptr<Channel> Channel::CreateNamedServer( | |
| 27 const IPC::ChannelHandle& channel_handle, | |
| 28 Listener* listener) { | |
| 29 return Channel::Create(channel_handle, Channel::MODE_NAMED_SERVER, listener); | |
| 30 } | |
| 31 | |
| 32 // static | |
| 33 std::unique_ptr<Channel> Channel::CreateNamedClient( | |
| 34 const IPC::ChannelHandle& channel_handle, | |
| 35 Listener* listener) { | |
| 36 return Channel::Create(channel_handle, Channel::MODE_NAMED_CLIENT, listener); | |
| 37 } | |
| 38 | |
| 39 // static | |
| 40 std::unique_ptr<Channel> Channel::CreateServer( | 46 std::unique_ptr<Channel> Channel::CreateServer( |
| 41 const IPC::ChannelHandle& channel_handle, | 47 const IPC::ChannelHandle& channel_handle, |
| 42 Listener* listener, | 48 Listener* listener, |
| 43 const scoped_refptr<base::SingleThreadTaskRunner>& ipc_task_runner) { | 49 const scoped_refptr<base::SingleThreadTaskRunner>& ipc_task_runner) { |
| 44 if (channel_handle.mojo_handle.is_valid()) { | 50 #if defined(OS_NACL_SFI) |
| 45 return ChannelMojo::Create( | |
| 46 mojo::ScopedMessagePipeHandle(channel_handle.mojo_handle), | |
| 47 Channel::MODE_SERVER, listener, ipc_task_runner); | |
| 48 } | |
| 49 return Channel::Create(channel_handle, Channel::MODE_SERVER, listener); | 51 return Channel::Create(channel_handle, Channel::MODE_SERVER, listener); |
| 52 #else |
| 53 DCHECK(channel_handle.is_mojo_channel_handle()); |
| 54 return ChannelMojo::Create( |
| 55 mojo::ScopedMessagePipeHandle(channel_handle.mojo_handle), |
| 56 Channel::MODE_SERVER, listener, ipc_task_runner); |
| 57 #endif |
| 50 } | 58 } |
| 51 | 59 |
| 52 // static | 60 // static |
| 53 void Channel::GenerateMojoChannelHandlePair( | 61 void Channel::GenerateMojoChannelHandlePair( |
| 54 const std::string& name_postfix, | 62 const std::string& name_postfix, |
| 55 IPC::ChannelHandle* handle0, | 63 IPC::ChannelHandle* handle0, |
| 56 IPC::ChannelHandle* handle1) { | 64 IPC::ChannelHandle* handle1) { |
| 57 DCHECK_NE(handle0, handle1); | 65 DCHECK_NE(handle0, handle1); |
| 58 mojo::MessagePipe message_pipe; | 66 mojo::MessagePipe message_pipe; |
| 59 *handle0 = ChannelHandle(message_pipe.handle0.release()); | 67 *handle0 = ChannelHandle(message_pipe.handle0.release()); |
| (...skipping 15 matching lines...) Expand all Loading... |
| 75 | 83 |
| 76 void Channel::OnSetAttachmentBrokerEndpoint() { | 84 void Channel::OnSetAttachmentBrokerEndpoint() { |
| 77 CHECK(!did_start_connect_); | 85 CHECK(!did_start_connect_); |
| 78 } | 86 } |
| 79 | 87 |
| 80 void Channel::WillConnect() { | 88 void Channel::WillConnect() { |
| 81 did_start_connect_ = true; | 89 did_start_connect_ = true; |
| 82 } | 90 } |
| 83 | 91 |
| 84 } // namespace IPC | 92 } // namespace IPC |
| 85 | |
| OLD | NEW |