Index: mojo/edk/system/channel_endpoint.cc |
diff --git a/mojo/edk/system/channel_endpoint.cc b/mojo/edk/system/channel_endpoint.cc |
index e7e17b4bb3d7fd0e495f2de8b24f8bf8faa6afa4..73f3c7a9dc0563e5f20cf3b453dab3df59b06468 100644 |
--- a/mojo/edk/system/channel_endpoint.cc |
+++ b/mojo/edk/system/channel_endpoint.cc |
@@ -4,6 +4,8 @@ |
#include "mojo/edk/system/channel_endpoint.h" |
+#include <utility> |
+ |
#include "base/logging.h" |
#include "base/threading/platform_thread.h" |
#include "mojo/edk/system/channel.h" |
@@ -26,17 +28,18 @@ ChannelEndpoint::ChannelEndpoint(ChannelEndpointClient* client, |
channel_message_queue_.Swap(message_queue); |
} |
-bool ChannelEndpoint::EnqueueMessage(scoped_ptr<MessageInTransit> message) { |
+bool ChannelEndpoint::EnqueueMessage( |
+ std::unique_ptr<MessageInTransit> message) { |
DCHECK(message); |
MutexLocker locker(&mutex_); |
switch (state_) { |
case State::PAUSED: |
- channel_message_queue_.AddMessage(message.Pass()); |
+ channel_message_queue_.AddMessage(std::move(message)); |
return true; |
case State::RUNNING: |
- return WriteMessageNoLock(message.Pass()); |
+ return WriteMessageNoLock(std::move(message)); |
case State::DEAD: |
return false; |
} |
@@ -96,9 +99,9 @@ void ChannelEndpoint::AttachAndRun(Channel* channel, |
} |
} |
-void ChannelEndpoint::OnReadMessage(scoped_ptr<MessageInTransit> message) { |
+void ChannelEndpoint::OnReadMessage(std::unique_ptr<MessageInTransit> message) { |
if (message->type() == MessageInTransit::Type::ENDPOINT_CLIENT) { |
- OnReadMessageForClient(message.Pass()); |
+ OnReadMessageForClient(std::move(message)); |
return; |
} |
@@ -148,7 +151,8 @@ ChannelEndpoint::~ChannelEndpoint() { |
DCHECK(!remote_id_.is_valid()); |
} |
-bool ChannelEndpoint::WriteMessageNoLock(scoped_ptr<MessageInTransit> message) { |
+bool ChannelEndpoint::WriteMessageNoLock( |
+ std::unique_ptr<MessageInTransit> message) { |
DCHECK(message); |
mutex_.AssertHeld(); |
@@ -160,11 +164,11 @@ bool ChannelEndpoint::WriteMessageNoLock(scoped_ptr<MessageInTransit> message) { |
message->SerializeAndCloseDispatchers(channel_); |
message->set_source_id(local_id_); |
message->set_destination_id(remote_id_); |
- return channel_->WriteMessage(message.Pass()); |
+ return channel_->WriteMessage(std::move(message)); |
} |
void ChannelEndpoint::OnReadMessageForClient( |
- scoped_ptr<MessageInTransit> message) { |
+ std::unique_ptr<MessageInTransit> message) { |
DCHECK_EQ(message->type(), MessageInTransit::Type::ENDPOINT_CLIENT); |
scoped_refptr<ChannelEndpointClient> client; |