| Index: mojo/edk/system/message_pipe.cc
|
| diff --git a/mojo/edk/system/message_pipe.cc b/mojo/edk/system/message_pipe.cc
|
| index 0f15698a9c7e8328025ddbdd8a176e849355b856..c89e24056bd2f13918587caf89d8016a4574f764 100644
|
| --- a/mojo/edk/system/message_pipe.cc
|
| +++ b/mojo/edk/system/message_pipe.cc
|
| @@ -5,6 +5,7 @@
|
| #include "mojo/edk/system/message_pipe.h"
|
|
|
| #include <memory>
|
| +#include <utility>
|
|
|
| #include "base/logging.h"
|
| #include "mojo/edk/system/channel.h"
|
| @@ -16,6 +17,7 @@
|
| #include "mojo/edk/system/message_pipe_dispatcher.h"
|
| #include "mojo/edk/system/message_pipe_endpoint.h"
|
| #include "mojo/edk/system/proxy_message_pipe_endpoint.h"
|
| +#include "mojo/edk/util/make_unique.h"
|
|
|
| namespace mojo {
|
| namespace system {
|
| @@ -155,9 +157,9 @@ MojoResult MessagePipe::WriteMessage(
|
| MutexLocker locker(&mutex_);
|
| return EnqueueMessageNoLock(
|
| GetPeerPort(port),
|
| - make_scoped_ptr(new MessageInTransit(
|
| + util::MakeUnique<MessageInTransit>(
|
| MessageInTransit::Type::ENDPOINT_CLIENT,
|
| - MessageInTransit::Subtype::ENDPOINT_CLIENT_DATA, num_bytes, bytes)),
|
| + MessageInTransit::Subtype::ENDPOINT_CLIENT_DATA, num_bytes, bytes),
|
| transports);
|
| }
|
|
|
| @@ -293,8 +295,8 @@ bool MessagePipe::OnReadMessage(unsigned port, MessageInTransit* message) {
|
| // |ProxyMessagePipeEndpoint| |port| receives a message (from the |Channel|).
|
| // We need to pass this message on to its peer port (typically a
|
| // |LocalMessagePipeEndpoint|).
|
| - MojoResult result = EnqueueMessageNoLock(GetPeerPort(port),
|
| - make_scoped_ptr(message), nullptr);
|
| + MojoResult result = EnqueueMessageNoLock(
|
| + GetPeerPort(port), std::unique_ptr<MessageInTransit>(message), nullptr);
|
| DLOG_IF(WARNING, result != MOJO_RESULT_OK)
|
| << "EnqueueMessageNoLock() failed (result = " << result << ")";
|
| return true;
|
| @@ -317,7 +319,7 @@ MessagePipe::~MessagePipe() {
|
|
|
| MojoResult MessagePipe::EnqueueMessageNoLock(
|
| unsigned port,
|
| - scoped_ptr<MessageInTransit> message,
|
| + std::unique_ptr<MessageInTransit> message,
|
| std::vector<DispatcherTransport>* transports) {
|
| DCHECK(port == 0 || port == 1);
|
| DCHECK(message);
|
| @@ -336,7 +338,7 @@ MojoResult MessagePipe::EnqueueMessageNoLock(
|
| }
|
|
|
| // The endpoint's |EnqueueMessage()| may not report failure.
|
| - endpoints_[port]->EnqueueMessage(message.Pass());
|
| + endpoints_[port]->EnqueueMessage(std::move(message));
|
| return MOJO_RESULT_OK;
|
| }
|
|
|
|
|