Index: mojo/edk/system/slave_connection_manager.cc |
diff --git a/mojo/edk/system/slave_connection_manager.cc b/mojo/edk/system/slave_connection_manager.cc |
index 0018a60b0167e9938ed8c303eff244c057e21e23..c0504e7eed3ae2a82d5bf69e0a46122a135a3a71 100644 |
--- a/mojo/edk/system/slave_connection_manager.cc |
+++ b/mojo/edk/system/slave_connection_manager.cc |
@@ -15,6 +15,7 @@ |
#include "mojo/edk/system/message_in_transit.h" |
#include "mojo/edk/util/make_unique.h" |
+using mojo::embedder::ScopedPlatformHandle; |
using mojo::platform::TaskRunner; |
using mojo::util::MutexLocker; |
using mojo::util::RefPtr; |
@@ -49,7 +50,7 @@ SlaveConnectionManager::~SlaveConnectionManager() { |
void SlaveConnectionManager::Init( |
RefPtr<TaskRunner>&& delegate_thread_task_runner, |
embedder::SlaveProcessDelegate* slave_process_delegate, |
- embedder::ScopedPlatformHandle platform_handle) { |
+ ScopedPlatformHandle platform_handle) { |
DCHECK(delegate_thread_task_runner); |
DCHECK(slave_process_delegate); |
DCHECK(platform_handle.is_valid()); |
@@ -116,7 +117,7 @@ ConnectionManager::Result SlaveConnectionManager::Connect( |
const ConnectionIdentifier& connection_id, |
ProcessIdentifier* peer_process_identifier, |
bool* is_first, |
- embedder::ScopedPlatformHandle* platform_handle) { |
+ ScopedPlatformHandle* platform_handle) { |
AssertNotOnPrivateThread(); |
DCHECK(peer_process_identifier); |
DCHECK(is_first); |
@@ -135,7 +136,7 @@ ConnectionManager::Result SlaveConnectionManager::Connect( |
} |
void SlaveConnectionManager::InitOnPrivateThread( |
- embedder::ScopedPlatformHandle platform_handle) { |
+ ScopedPlatformHandle platform_handle) { |
AssertOnPrivateThread(); |
raw_channel_ = RawChannel::Create(platform_handle.Pass()); |
@@ -208,7 +209,7 @@ void SlaveConnectionManager::ConnectOnPrivateThread( |
Result* result, |
ProcessIdentifier* peer_process_identifier, |
bool* is_first, |
- embedder::ScopedPlatformHandle* platform_handle) { |
+ ScopedPlatformHandle* platform_handle) { |
DCHECK(result); |
AssertOnPrivateThread(); |
// This should only posted (from another thread, to |private_thread_|) with |
@@ -236,7 +237,7 @@ void SlaveConnectionManager::ConnectOnPrivateThread( |
void SlaveConnectionManager::OnReadMessage( |
const MessageInTransit::View& message_view, |
- embedder::ScopedPlatformHandleVectorPtr platform_handles) { |
+ std::unique_ptr<std::vector<ScopedPlatformHandle>> platform_handles) { |
AssertOnPrivateThread(); |
// Set |*ack_result_| to failure by default. |
@@ -292,8 +293,7 @@ void SlaveConnectionManager::OnReadMessage( |
CONNECTION_MANAGER_ACK_SUCCESS_CONNECT_NEW_CONNECTION: |
CHECK_EQ(num_platform_handles, 1u); |
*ack_result_ = Result::SUCCESS_CONNECT_NEW_CONNECTION; |
- ack_platform_handle_->reset(platform_handles->at(0)); |
- platform_handles->at(0) = embedder::PlatformHandle(); |
+ *ack_platform_handle_ = std::move(platform_handles->at(0)); |
break; |
case MessageInTransit::Subtype:: |
CONNECTION_MANAGER_ACK_SUCCESS_CONNECT_REUSE_CONNECTION: |