| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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/browser/nacl_process_host.h" | 5 #include "components/nacl/browser/nacl_process_host.h" |
| 6 | 6 |
| 7 #include <string.h> | 7 #include <string.h> |
| 8 #include <algorithm> | 8 #include <algorithm> |
| 9 #include <string> | 9 #include <string> |
| 10 #include <utility> | 10 #include <utility> |
| (...skipping 236 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 247 CHECK(handle.socket.fd == -1 || handle.socket.fd != handle_.socket.fd); | 247 CHECK(handle.socket.fd == -1 || handle.socket.fd != handle_.socket.fd); |
| 248 #endif | 248 #endif |
| 249 CloseIfNecessary(); | 249 CloseIfNecessary(); |
| 250 handle_ = handle; | 250 handle_ = handle; |
| 251 } | 251 } |
| 252 | 252 |
| 253 private: | 253 private: |
| 254 // Returns true if the given handle is closable automatically by this | 254 // Returns true if the given handle is closable automatically by this |
| 255 // class. This function is just a helper for validation. | 255 // class. This function is just a helper for validation. |
| 256 static bool IsSupportedHandle(const IPC::ChannelHandle& handle) { | 256 static bool IsSupportedHandle(const IPC::ChannelHandle& handle) { |
| 257 #if defined(OS_WIN) | 257 #if defined(OS_POSIX) |
| 258 // Only ChannelMojo is supported. |
| 259 return handle.socket.fd == -1; |
| 260 #elif defined(OS_WIN) |
| 258 // On Windows, it is not supported to marshal the |pipe.handle|. | 261 // On Windows, it is not supported to marshal the |pipe.handle|. |
| 259 // In our case, we wrap a transferred ChannelHandle (or one to be | 262 // In our case, we wrap a transferred ChannelHandle (or one to be |
| 260 // transferred) via IPC, so we can assume |handle.pipe.handle| is NULL. | 263 // transferred) via IPC, so we can assume |handle.pipe.handle| is NULL. |
| 261 return handle.pipe.handle == NULL; | 264 return handle.pipe.handle == NULL; |
| 262 #else | 265 #else |
| 263 return true; | 266 return true; |
| 264 #endif | 267 #endif // defined(OS_POSIX) |
| 265 } | 268 } |
| 266 | 269 |
| 267 void CloseIfNecessary() { | 270 void CloseIfNecessary() { |
| 271 if (handle_.mojo_handle.is_valid()) |
| 272 handle_.mojo_handle.Close(); |
| 273 |
| 268 #if defined(OS_POSIX) | 274 #if defined(OS_POSIX) |
| 269 if (handle_.socket.auto_close) { | 275 if (handle_.socket.auto_close) { |
| 270 // Defer closing task to the ScopedFD. | 276 // Defer closing task to the ScopedFD. |
| 271 base::ScopedFD(handle_.socket.fd); | 277 base::ScopedFD(handle_.socket.fd); |
| 272 } | 278 } |
| 273 #endif | 279 #endif |
| 274 } | 280 } |
| 275 | 281 |
| 276 IPC::ChannelHandle handle_; | 282 IPC::ChannelHandle handle_; |
| 277 | 283 |
| (...skipping 749 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1027 } | 1033 } |
| 1028 | 1034 |
| 1029 #if defined(OS_LINUX) | 1035 #if defined(OS_LINUX) |
| 1030 // static | 1036 // static |
| 1031 bool NaClProcessHost::CreateChannelHandlePair( | 1037 bool NaClProcessHost::CreateChannelHandlePair( |
| 1032 ScopedChannelHandle* channel_handle1, | 1038 ScopedChannelHandle* channel_handle1, |
| 1033 ScopedChannelHandle* channel_handle2) { | 1039 ScopedChannelHandle* channel_handle2) { |
| 1034 DCHECK(channel_handle1); | 1040 DCHECK(channel_handle1); |
| 1035 DCHECK(channel_handle2); | 1041 DCHECK(channel_handle2); |
| 1036 | 1042 |
| 1037 int fd1 = -1; | 1043 IPC::ChannelHandle handle1; |
| 1038 int fd2 = -1; | 1044 IPC::ChannelHandle handle2; |
| 1039 if (!IPC::SocketPair(&fd1, &fd2)) { | 1045 IPC::Channel::GenerateMojoChannelHandlePair("NaCl", &handle1, &handle2); |
| 1040 return false; | 1046 channel_handle1->reset(handle1); |
| 1041 } | 1047 channel_handle2->reset(handle2); |
| 1042 | 1048 |
| 1043 IPC::ChannelHandle handle = IPC::Channel::GenerateVerifiedChannelID("nacl"); | |
| 1044 handle.socket = base::FileDescriptor(fd1, true); | |
| 1045 channel_handle1->reset(handle); | |
| 1046 handle.socket = base::FileDescriptor(fd2, true); | |
| 1047 channel_handle2->reset(handle); | |
| 1048 return true; | 1049 return true; |
| 1049 } | 1050 } |
| 1050 #endif | 1051 #endif |
| 1051 | 1052 |
| 1052 bool NaClProcessHost::StartPPAPIProxy(ScopedChannelHandle channel_handle) { | 1053 bool NaClProcessHost::StartPPAPIProxy(ScopedChannelHandle channel_handle) { |
| 1053 if (ipc_proxy_channel_.get()) { | 1054 if (ipc_proxy_channel_.get()) { |
| 1054 // Attempt to open more than 1 browser channel is not supported. | 1055 // Attempt to open more than 1 browser channel is not supported. |
| 1055 // Shut down the NaCl process. | 1056 // Shut down the NaCl process. |
| 1056 process_->GetHost()->ForceShutdown(); | 1057 process_->GetHost()->ForceShutdown(); |
| 1057 return false; | 1058 return false; |
| (...skipping 241 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1299 NaClStartDebugExceptionHandlerThread( | 1300 NaClStartDebugExceptionHandlerThread( |
| 1300 std::move(process), info, base::ThreadTaskRunnerHandle::Get(), | 1301 std::move(process), info, base::ThreadTaskRunnerHandle::Get(), |
| 1301 base::Bind(&NaClProcessHost::OnDebugExceptionHandlerLaunchedByBroker, | 1302 base::Bind(&NaClProcessHost::OnDebugExceptionHandlerLaunchedByBroker, |
| 1302 weak_factory_.GetWeakPtr())); | 1303 weak_factory_.GetWeakPtr())); |
| 1303 return true; | 1304 return true; |
| 1304 } | 1305 } |
| 1305 } | 1306 } |
| 1306 #endif | 1307 #endif |
| 1307 | 1308 |
| 1308 } // namespace nacl | 1309 } // namespace nacl |
| OLD | NEW |