| 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 "ipc/ipc_channel_mojo.h" | 5 #include "ipc/ipc_channel_mojo.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <memory> | 10 #include <memory> |
| (...skipping 352 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 363 // this object, and that would be bad if we are called from Send(). Instead, | 363 // this object, and that would be bad if we are called from Send(). Instead, |
| 364 // we return false and hope the caller will close the pipe. If they do not, | 364 // we return false and hope the caller will close the pipe. If they do not, |
| 365 // the pipe will still be closed next time OnFileCanReadWithoutBlocking is | 365 // the pipe will still be closed next time OnFileCanReadWithoutBlocking is |
| 366 // called. | 366 // called. |
| 367 // | 367 // |
| 368 // With Mojo, there's no OnFileCanReadWithoutBlocking, but we expect the | 368 // With Mojo, there's no OnFileCanReadWithoutBlocking, but we expect the |
| 369 // pipe's connection error handler will be invoked in its place. | 369 // pipe's connection error handler will be invoked in its place. |
| 370 return message_reader_->Send(std::move(scoped_message)); | 370 return message_reader_->Send(std::move(scoped_message)); |
| 371 } | 371 } |
| 372 | 372 |
| 373 bool ChannelMojo::IsSendThreadSafe() const { | |
| 374 return false; | |
| 375 } | |
| 376 | |
| 377 base::ProcessId ChannelMojo::GetPeerPID() const { | 373 base::ProcessId ChannelMojo::GetPeerPID() const { |
| 378 if (!message_reader_) | 374 if (!message_reader_) |
| 379 return base::kNullProcessId; | 375 return base::kNullProcessId; |
| 380 return message_reader_->GetPeerPid(); | 376 return message_reader_->GetPeerPid(); |
| 381 } | 377 } |
| 382 | 378 |
| 383 base::ProcessId ChannelMojo::GetSelfPID() const { | 379 base::ProcessId ChannelMojo::GetSelfPID() const { |
| 384 #if defined(OS_LINUX) | 380 #if defined(OS_LINUX) |
| 385 if (int global_pid = GetGlobalPid()) | 381 if (int global_pid = GetGlobalPid()) |
| 386 return global_pid; | 382 return global_pid; |
| (...skipping 110 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 497 } | 493 } |
| 498 | 494 |
| 499 void ChannelMojo::GetGenericRemoteAssociatedInterface( | 495 void ChannelMojo::GetGenericRemoteAssociatedInterface( |
| 500 const std::string& name, | 496 const std::string& name, |
| 501 mojo::ScopedInterfaceEndpointHandle handle) { | 497 mojo::ScopedInterfaceEndpointHandle handle) { |
| 502 if (message_reader_) | 498 if (message_reader_) |
| 503 message_reader_->GetRemoteInterface(name, std::move(handle)); | 499 message_reader_->GetRemoteInterface(name, std::move(handle)); |
| 504 } | 500 } |
| 505 | 501 |
| 506 } // namespace IPC | 502 } // namespace IPC |
| OLD | NEW |