| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 "mojo/edk/system/node_channel.h" | 5 #include "mojo/edk/system/node_channel.h" |
| 6 | 6 |
| 7 #include <cstring> | 7 #include <cstring> |
| 8 #include <limits> | 8 #include <limits> |
| 9 #include <sstream> | 9 #include <sstream> |
| 10 | 10 |
| (...skipping 138 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 149 } | 149 } |
| 150 | 150 |
| 151 } // namespace | 151 } // namespace |
| 152 | 152 |
| 153 // static | 153 // static |
| 154 scoped_refptr<NodeChannel> NodeChannel::Create( | 154 scoped_refptr<NodeChannel> NodeChannel::Create( |
| 155 Delegate* delegate, | 155 Delegate* delegate, |
| 156 ScopedPlatformHandle platform_handle, | 156 ScopedPlatformHandle platform_handle, |
| 157 scoped_refptr<base::TaskRunner> io_task_runner, | 157 scoped_refptr<base::TaskRunner> io_task_runner, |
| 158 const ProcessErrorCallback& process_error_callback) { | 158 const ProcessErrorCallback& process_error_callback) { |
| 159 #if defined(OS_NACL) | 159 #if defined(OS_NACL_SFI) |
| 160 LOG(FATAL) << "Multi-process not yet supported on NaCl"; | 160 LOG(FATAL) << "Multi-process not yet supported on NaCl-SFI"; |
| 161 return nullptr; | 161 return nullptr; |
| 162 #else | 162 #else |
| 163 return new NodeChannel(delegate, std::move(platform_handle), io_task_runner, | 163 return new NodeChannel(delegate, std::move(platform_handle), io_task_runner, |
| 164 process_error_callback); | 164 process_error_callback); |
| 165 #endif | 165 #endif |
| 166 } | 166 } |
| 167 | 167 |
| 168 // static | 168 // static |
| 169 Channel::MessagePtr NodeChannel::CreatePortsMessage(size_t payload_size, | 169 Channel::MessagePtr NodeChannel::CreatePortsMessage(size_t payload_size, |
| 170 void** payload, | 170 void** payload, |
| (...skipping 248 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 419 } | 419 } |
| 420 #endif // defined(OS_WIN) || (defined(OS_MACOSX) && !defined(OS_IOS)) | 420 #endif // defined(OS_WIN) || (defined(OS_MACOSX) && !defined(OS_IOS)) |
| 421 | 421 |
| 422 NodeChannel::NodeChannel(Delegate* delegate, | 422 NodeChannel::NodeChannel(Delegate* delegate, |
| 423 ScopedPlatformHandle platform_handle, | 423 ScopedPlatformHandle platform_handle, |
| 424 scoped_refptr<base::TaskRunner> io_task_runner, | 424 scoped_refptr<base::TaskRunner> io_task_runner, |
| 425 const ProcessErrorCallback& process_error_callback) | 425 const ProcessErrorCallback& process_error_callback) |
| 426 : delegate_(delegate), | 426 : delegate_(delegate), |
| 427 io_task_runner_(io_task_runner), | 427 io_task_runner_(io_task_runner), |
| 428 process_error_callback_(process_error_callback) | 428 process_error_callback_(process_error_callback) |
| 429 #if !defined(OS_NACL) | 429 #if !defined(OS_NACL_SFI) |
| 430 , channel_( | 430 , channel_( |
| 431 Channel::Create(this, std::move(platform_handle), io_task_runner_)) | 431 Channel::Create(this, std::move(platform_handle), io_task_runner_)) |
| 432 #endif | 432 #endif |
| 433 { | 433 { |
| 434 } | 434 } |
| 435 | 435 |
| 436 NodeChannel::~NodeChannel() { | 436 NodeChannel::~NodeChannel() { |
| 437 ShutDown(); | 437 ShutDown(); |
| 438 } | 438 } |
| 439 | 439 |
| (...skipping 404 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 844 | 844 |
| 845 base::AutoLock lock(channel_lock_); | 845 base::AutoLock lock(channel_lock_); |
| 846 if (!channel_) | 846 if (!channel_) |
| 847 DLOG(ERROR) << "Dropping message on closed channel."; | 847 DLOG(ERROR) << "Dropping message on closed channel."; |
| 848 else | 848 else |
| 849 channel_->Write(std::move(message)); | 849 channel_->Write(std::move(message)); |
| 850 } | 850 } |
| 851 | 851 |
| 852 } // namespace edk | 852 } // namespace edk |
| 853 } // namespace mojo | 853 } // namespace mojo |
| OLD | NEW |