Index: mojo/edk/system/data_pipe.cc |
diff --git a/mojo/edk/system/data_pipe.cc b/mojo/edk/system/data_pipe.cc |
index ef87058c45c6f06a3fc2b397685b81310c046a54..59b4d0191ff744fadd54beb20e64e847174d03b1 100644 |
--- a/mojo/edk/system/data_pipe.cc |
+++ b/mojo/edk/system/data_pipe.cc |
@@ -23,6 +23,7 @@ |
#include "mojo/edk/system/options_validation.h" |
#include "mojo/edk/system/remote_consumer_data_pipe_impl.h" |
#include "mojo/edk/system/remote_producer_data_pipe_impl.h" |
+#include "mojo/edk/util/make_unique.h" |
namespace mojo { |
namespace system { |
@@ -96,7 +97,7 @@ MojoResult DataPipe::ValidateCreateOptions( |
DataPipe* DataPipe::CreateLocal( |
const MojoCreateDataPipeOptions& validated_options) { |
return new DataPipe(true, true, validated_options, |
- make_scoped_ptr(new LocalDataPipeImpl())); |
+ util::MakeUnique<LocalDataPipeImpl>()); |
} |
// static |
@@ -119,8 +120,8 @@ DataPipe* DataPipe::CreateRemoteProducerFromExisting( |
// is called. |
DataPipe* data_pipe = new DataPipe( |
false, true, validated_options, |
- make_scoped_ptr(new RemoteProducerDataPipeImpl( |
- channel_endpoint, std::move(buffer), 0, buffer_num_bytes))); |
+ util::MakeUnique<RemoteProducerDataPipeImpl>( |
+ channel_endpoint, std::move(buffer), 0, buffer_num_bytes)); |
if (channel_endpoint) { |
if (!channel_endpoint->ReplaceClient(data_pipe, 0)) |
data_pipe->OnDetachFromChannel(0); |
@@ -149,8 +150,8 @@ DataPipe* DataPipe::CreateRemoteConsumerFromExisting( |
// is called. |
DataPipe* data_pipe = |
new DataPipe(true, false, validated_options, |
- make_scoped_ptr(new RemoteConsumerDataPipeImpl( |
- channel_endpoint, consumer_num_bytes))); |
+ util::MakeUnique<RemoteConsumerDataPipeImpl>( |
+ channel_endpoint, consumer_num_bytes)); |
if (channel_endpoint) { |
if (!channel_endpoint->ReplaceClient(data_pipe, 0)) |
data_pipe->OnDetachFromChannel(0); |
@@ -195,9 +196,9 @@ bool DataPipe::ProducerDeserialize(Channel* channel, |
return false; |
} |
- *data_pipe = new DataPipe( |
- true, false, revalidated_options, |
- make_scoped_ptr(new RemoteConsumerDataPipeImpl(nullptr, 0))); |
+ *data_pipe = |
+ new DataPipe(true, false, revalidated_options, |
+ util::MakeUnique<RemoteConsumerDataPipeImpl>(nullptr, 0)); |
(*data_pipe)->SetConsumerClosed(); |
return true; |
@@ -667,7 +668,7 @@ bool DataPipe::ConsumerIsBusy() const { |
DataPipe::DataPipe(bool has_local_producer, |
bool has_local_consumer, |
const MojoCreateDataPipeOptions& validated_options, |
- scoped_ptr<DataPipeImpl> impl) |
+ std::unique_ptr<DataPipeImpl> impl) |
: validated_options_(validated_options), |
producer_open_(true), |
consumer_open_(true), |
@@ -677,7 +678,7 @@ DataPipe::DataPipe(bool has_local_producer, |
: nullptr), |
producer_two_phase_max_num_bytes_written_(0), |
consumer_two_phase_max_num_bytes_read_(0), |
- impl_(impl.Pass()) { |
+ impl_(std::move(impl)) { |
impl_->set_owner(this); |
#if !defined(NDEBUG) || defined(DCHECK_ALWAYS_ON) |
@@ -695,16 +696,16 @@ DataPipe::~DataPipe() { |
DCHECK(!consumer_awakable_list_); |
} |
-scoped_ptr<DataPipeImpl> DataPipe::ReplaceImplNoLock( |
- scoped_ptr<DataPipeImpl> new_impl) { |
+std::unique_ptr<DataPipeImpl> DataPipe::ReplaceImplNoLock( |
+ std::unique_ptr<DataPipeImpl> new_impl) { |
mutex_.AssertHeld(); |
DCHECK(new_impl); |
impl_->set_owner(nullptr); |
- scoped_ptr<DataPipeImpl> rv(impl_.Pass()); |
- impl_ = new_impl.Pass(); |
+ std::unique_ptr<DataPipeImpl> rv(std::move(impl_)); |
+ impl_ = std::move(new_impl); |
impl_->set_owner(this); |
- return rv.Pass(); |
+ return rv; |
} |
void DataPipe::SetProducerClosedNoLock() { |