Skip to content

Commit

Permalink
Change scoped_ptr to std::unique_ptr in //net/quic.
Browse files Browse the repository at this point in the history
R=gavinp@chromium.org
BUG=554298

Review URL: https://codereview.chromium.org/1892973003

Cr-Commit-Position: refs/heads/master@{#387772}
  • Loading branch information
danakj authored and Commit bot committed Apr 16, 2016
1 parent 9c5cab5 commit ad1777e
Show file tree
Hide file tree
Showing 118 changed files with 980 additions and 918 deletions.
2 changes: 1 addition & 1 deletion net/quic/bidirectional_stream_quic_impl.cc
Original file line number Diff line number Diff line change
Expand Up @@ -46,7 +46,7 @@ void BidirectionalStreamQuicImpl::Start(
const BidirectionalStreamRequestInfo* request_info,
const BoundNetLog& net_log,
BidirectionalStreamImpl::Delegate* delegate,
scoped_ptr<base::Timer> /* timer */) {
std::unique_ptr<base::Timer> /* timer */) {
DCHECK(!stream_);

if (!session_) {
Expand Down
5 changes: 3 additions & 2 deletions net/quic/bidirectional_stream_quic_impl.h
Original file line number Diff line number Diff line change
Expand Up @@ -7,8 +7,9 @@

#include <stdint.h>

#include <memory>

#include "base/macros.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/weak_ptr.h"
#include "net/http/bidirectional_stream_impl.h"
#include "net/quic/quic_chromium_client_session.h"
Expand Down Expand Up @@ -39,7 +40,7 @@ class NET_EXPORT_PRIVATE BidirectionalStreamQuicImpl
void Start(const BidirectionalStreamRequestInfo* request_info,
const BoundNetLog& net_log,
BidirectionalStreamImpl::Delegate* delegate,
scoped_ptr<base::Timer> timer) override;
std::unique_ptr<base::Timer> timer) override;
int ReadData(IOBuffer* buffer, int buffer_len) override;
void SendData(IOBuffer* data, int length, bool end_stream) override;
void Cancel() override;
Expand Down
76 changes: 39 additions & 37 deletions net/quic/bidirectional_stream_quic_impl_unittest.cc
Original file line number Diff line number Diff line change
Expand Up @@ -5,10 +5,12 @@
#include "net/quic/bidirectional_stream_quic_impl.h"

#include <stdint.h>

#include <memory>
#include <vector>

#include "base/callback_helpers.h"
#include "base/memory/scoped_ptr.h"
#include "base/memory/ptr_util.h"
#include "base/message_loop/message_loop.h"
#include "base/run_loop.h"
#include "base/strings/string_number_conversions.h"
Expand Down Expand Up @@ -59,11 +61,11 @@ class TestDelegateBase : public BidirectionalStreamImpl::Delegate {
TestDelegateBase(IOBuffer* read_buf, int read_buf_len)
: TestDelegateBase(read_buf,
read_buf_len,
make_scoped_ptr(new base::Timer(false, false))) {}
base::WrapUnique(new base::Timer(false, false))) {}

TestDelegateBase(IOBuffer* read_buf,
int read_buf_len,
scoped_ptr<base::Timer> timer)
std::unique_ptr<base::Timer> timer)
: read_buf_(read_buf),
read_buf_len_(read_buf_len),
timer_(std::move(timer)),
Expand Down Expand Up @@ -180,12 +182,12 @@ class TestDelegateBase : public BidirectionalStreamImpl::Delegate {
void DeleteStream() { stream_job_.reset(); }

private:
scoped_ptr<BidirectionalStreamQuicImpl> stream_job_;
std::unique_ptr<BidirectionalStreamQuicImpl> stream_job_;
scoped_refptr<IOBuffer> read_buf_;
int read_buf_len_;
scoped_ptr<base::Timer> timer_;
std::unique_ptr<base::Timer> timer_;
std::string data_received_;
scoped_ptr<base::RunLoop> loop_;
std::unique_ptr<base::RunLoop> loop_;
SpdyHeaderBlock response_headers_;
SpdyHeaderBlock trailers_;
int error_;
Expand Down Expand Up @@ -300,11 +302,11 @@ class BidirectionalStreamQuicImplTest
}

// Adds a packet to the list of expected writes.
void AddWrite(scoped_ptr<QuicReceivedPacket> packet) {
void AddWrite(std::unique_ptr<QuicReceivedPacket> packet) {
writes_.push_back(PacketToWrite(SYNCHRONOUS, packet.release()));
}

void ProcessPacket(scoped_ptr<QuicReceivedPacket> packet) {
void ProcessPacket(std::unique_ptr<QuicReceivedPacket> packet) {
connection_->ProcessUdpPacket(self_addr_, peer_addr_, *packet);
}

Expand All @@ -323,7 +325,7 @@ class BidirectionalStreamQuicImplTest
socket_data_.reset(new StaticSocketDataProvider(
nullptr, 0, mock_writes_.get(), writes_.size()));

scoped_ptr<MockUDPClientSocket> socket(new MockUDPClientSocket(
std::unique_ptr<MockUDPClientSocket> socket(new MockUDPClientSocket(
socket_data_.get(), net_log().bound().net_log()));
socket->Connect(peer_addr_);
runner_ = new TestTaskRunner(&clock_);
Expand All @@ -337,7 +339,7 @@ class BidirectionalStreamQuicImplTest
session_.reset(new QuicChromiumClientSession(
connection_, std::move(socket),
/*stream_factory=*/nullptr, &crypto_client_stream_factory_, &clock_,
&transport_security_state_, make_scoped_ptr((QuicServerInfo*)nullptr),
&transport_security_state_, base::WrapUnique((QuicServerInfo*)nullptr),
QuicServerId(kDefaultServerHostName, kDefaultServerPort,
PRIVACY_MODE_DISABLED),
kQuicYieldAfterPacketsRead,
Expand All @@ -361,20 +363,20 @@ class BidirectionalStreamQuicImplTest
return maker_.GetResponseHeaders(response_code);
}

scoped_ptr<QuicReceivedPacket> ConstructDataPacket(
std::unique_ptr<QuicReceivedPacket> ConstructDataPacket(
QuicPacketNumber packet_number,
bool should_include_version,
bool fin,
QuicStreamOffset offset,
base::StringPiece data) {
scoped_ptr<QuicReceivedPacket> packet(maker_.MakeDataPacket(
std::unique_ptr<QuicReceivedPacket> packet(maker_.MakeDataPacket(
packet_number, stream_id_, should_include_version, fin, offset, data));
DVLOG(2) << "packet(" << packet_number << "): " << std::endl
<< QuicUtils::StringToHexASCIIDump(packet->AsStringPiece());
return packet;
}

scoped_ptr<QuicReceivedPacket> ConstructRequestHeadersPacket(
std::unique_ptr<QuicReceivedPacket> ConstructRequestHeadersPacket(
QuicPacketNumber packet_number,
bool fin,
RequestPriority request_priority,
Expand All @@ -386,7 +388,7 @@ class BidirectionalStreamQuicImplTest
request_headers_, spdy_headers_frame_length);
}

scoped_ptr<QuicReceivedPacket> ConstructResponseHeadersPacket(
std::unique_ptr<QuicReceivedPacket> ConstructResponseHeadersPacket(
QuicPacketNumber packet_number,
bool fin,
const SpdyHeaderBlock& response_headers,
Expand All @@ -397,7 +399,7 @@ class BidirectionalStreamQuicImplTest
spdy_headers_frame_length, offset);
}

scoped_ptr<QuicReceivedPacket> ConstructResponseTrailersPacket(
std::unique_ptr<QuicReceivedPacket> ConstructResponseTrailersPacket(
QuicPacketNumber packet_number,
bool fin,
const SpdyHeaderBlock& trailers,
Expand All @@ -408,23 +410,23 @@ class BidirectionalStreamQuicImplTest
spdy_headers_frame_length, offset);
}

scoped_ptr<QuicReceivedPacket> ConstructRstStreamPacket(
std::unique_ptr<QuicReceivedPacket> ConstructRstStreamPacket(
QuicPacketNumber packet_number) {
return ConstructRstStreamCancelledPacket(packet_number, 0);
}

scoped_ptr<QuicReceivedPacket> ConstructRstStreamCancelledPacket(
std::unique_ptr<QuicReceivedPacket> ConstructRstStreamCancelledPacket(
QuicPacketNumber packet_number,
size_t bytes_written) {
scoped_ptr<QuicReceivedPacket> packet(
std::unique_ptr<QuicReceivedPacket> packet(
maker_.MakeRstPacket(packet_number, !kIncludeVersion, stream_id_,
QUIC_STREAM_CANCELLED, bytes_written));
DVLOG(2) << "packet(" << packet_number << "): " << std::endl
<< QuicUtils::StringToHexASCIIDump(packet->AsStringPiece());
return packet;
}

scoped_ptr<QuicReceivedPacket> ConstructAckAndRstStreamPacket(
std::unique_ptr<QuicReceivedPacket> ConstructAckAndRstStreamPacket(
QuicPacketNumber packet_number,
QuicPacketNumber largest_received,
QuicPacketNumber ack_least_unacked,
Expand All @@ -435,23 +437,23 @@ class BidirectionalStreamQuicImplTest
!kIncludeCongestionFeedback);
}

scoped_ptr<QuicReceivedPacket> ConstructAckAndDataPacket(
std::unique_ptr<QuicReceivedPacket> ConstructAckAndDataPacket(
QuicPacketNumber packet_number,
bool should_include_version,
QuicPacketNumber largest_received,
QuicPacketNumber least_unacked,
bool fin,
QuicStreamOffset offset,
base::StringPiece data) {
scoped_ptr<QuicReceivedPacket> packet(maker_.MakeAckAndDataPacket(
std::unique_ptr<QuicReceivedPacket> packet(maker_.MakeAckAndDataPacket(
packet_number, should_include_version, stream_id_, largest_received,
least_unacked, fin, offset, data));
DVLOG(2) << "packet(" << packet_number << "): " << std::endl
<< QuicUtils::StringToHexASCIIDump(packet->AsStringPiece());
return packet;
}

scoped_ptr<QuicReceivedPacket> ConstructAckPacket(
std::unique_ptr<QuicReceivedPacket> ConstructAckPacket(
QuicPacketNumber packet_number,
QuicPacketNumber largest_received,
QuicPacketNumber least_unacked) {
Expand All @@ -466,12 +468,12 @@ class BidirectionalStreamQuicImplTest
private:
BoundTestNetLog net_log_;
scoped_refptr<TestTaskRunner> runner_;
scoped_ptr<MockWrite[]> mock_writes_;
std::unique_ptr<MockWrite[]> mock_writes_;
MockClock clock_;
QuicConnection* connection_;
scoped_ptr<QuicChromiumConnectionHelper> helper_;
std::unique_ptr<QuicChromiumConnectionHelper> helper_;
TransportSecurityState transport_security_state_;
scoped_ptr<QuicChromiumClientSession> session_;
std::unique_ptr<QuicChromiumClientSession> session_;
QuicCryptoClientConfig crypto_config_;
HttpRequestHeaders headers_;
HttpResponseInfo response_;
Expand All @@ -484,7 +486,7 @@ class BidirectionalStreamQuicImplTest
IPEndPoint peer_addr_;
MockRandom random_generator_;
MockCryptoClientStreamFactory crypto_client_stream_factory_;
scoped_ptr<StaticSocketDataProvider> socket_data_;
std::unique_ptr<StaticSocketDataProvider> socket_data_;
std::vector<PacketToWrite> writes_;
QuicClientPushPromiseIndex push_promise_index_;
};
Expand All @@ -509,7 +511,7 @@ TEST_P(BidirectionalStreamQuicImplTest, GetRequest) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<TestDelegateBase> delegate(
std::unique_ptr<TestDelegateBase> delegate(
new TestDelegateBase(read_buffer.get(), kReadBufferSize));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
delegate->WaitUntilNextCallback(); // OnHeadersSent
Expand Down Expand Up @@ -600,7 +602,7 @@ TEST_P(BidirectionalStreamQuicImplTest, PostRequest) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<TestDelegateBase> delegate(
std::unique_ptr<TestDelegateBase> delegate(
new TestDelegateBase(read_buffer.get(), kReadBufferSize));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
delegate->WaitUntilNextCallback(); // OnHeadersSent
Expand Down Expand Up @@ -677,7 +679,7 @@ TEST_P(BidirectionalStreamQuicImplTest, InterleaveReadDataAndSendData) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<TestDelegateBase> delegate(
std::unique_ptr<TestDelegateBase> delegate(
new TestDelegateBase(read_buffer.get(), kReadBufferSize));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
delegate->WaitUntilNextCallback(); // OnHeadersSent
Expand Down Expand Up @@ -754,7 +756,7 @@ TEST_P(BidirectionalStreamQuicImplTest, ServerSendsRstAfterHeaders) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<TestDelegateBase> delegate(
std::unique_ptr<TestDelegateBase> delegate(
new TestDelegateBase(read_buffer.get(), kReadBufferSize));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
delegate->WaitUntilNextCallback(); // OnHeadersSent
Expand Down Expand Up @@ -793,7 +795,7 @@ TEST_P(BidirectionalStreamQuicImplTest, ServerSendsRstAfterReadData) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<TestDelegateBase> delegate(
std::unique_ptr<TestDelegateBase> delegate(
new TestDelegateBase(read_buffer.get(), kReadBufferSize));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
delegate->WaitUntilNextCallback(); // OnHeadersSent
Expand Down Expand Up @@ -850,7 +852,7 @@ TEST_P(BidirectionalStreamQuicImplTest, CancelStreamAfterSendData) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<TestDelegateBase> delegate(
std::unique_ptr<TestDelegateBase> delegate(
new TestDelegateBase(read_buffer.get(), kReadBufferSize));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
delegate->WaitUntilNextCallback(); // OnHeadersSent
Expand Down Expand Up @@ -900,7 +902,7 @@ TEST_P(BidirectionalStreamQuicImplTest, SessionClosedBeforeReadData) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<TestDelegateBase> delegate(
std::unique_ptr<TestDelegateBase> delegate(
new TestDelegateBase(read_buffer.get(), kReadBufferSize));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
delegate->WaitUntilNextCallback(); // OnHeadersSent
Expand Down Expand Up @@ -954,7 +956,7 @@ TEST_P(BidirectionalStreamQuicImplTest, CancelStreamAfterReadData) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<TestDelegateBase> delegate(
std::unique_ptr<TestDelegateBase> delegate(
new TestDelegateBase(read_buffer.get(), kReadBufferSize));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
delegate->WaitUntilNextCallback(); // OnHeadersSent
Expand Down Expand Up @@ -1003,7 +1005,7 @@ TEST_P(BidirectionalStreamQuicImplTest, DeleteStreamDuringOnHeadersReceived) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<DeleteStreamDelegate> delegate(new DeleteStreamDelegate(
std::unique_ptr<DeleteStreamDelegate> delegate(new DeleteStreamDelegate(
read_buffer.get(), kReadBufferSize,
DeleteStreamDelegate::ON_HEADERS_RECEIVED, true));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
Expand Down Expand Up @@ -1046,7 +1048,7 @@ TEST_P(BidirectionalStreamQuicImplTest, DeleteStreamDuringOnDataRead) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<DeleteStreamDelegate> delegate(
std::unique_ptr<DeleteStreamDelegate> delegate(
new DeleteStreamDelegate(read_buffer.get(), kReadBufferSize,
DeleteStreamDelegate::ON_DATA_READ, true));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
Expand Down Expand Up @@ -1098,7 +1100,7 @@ TEST_P(BidirectionalStreamQuicImplTest, DeleteStreamDuringOnTrailersReceived) {
request.priority = DEFAULT_PRIORITY;

scoped_refptr<IOBuffer> read_buffer(new IOBuffer(kReadBufferSize));
scoped_ptr<DeleteStreamDelegate> delegate(new DeleteStreamDelegate(
std::unique_ptr<DeleteStreamDelegate> delegate(new DeleteStreamDelegate(
read_buffer.get(), kReadBufferSize,
DeleteStreamDelegate::ON_TRAILERS_RECEIVED, true));
delegate->Start(&request, net_log().bound(), session()->GetWeakPtr());
Expand Down
5 changes: 3 additions & 2 deletions net/quic/congestion_control/hybrid_slow_start_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,9 @@

#include "net/quic/congestion_control/hybrid_slow_start.h"

#include <memory>

#include "base/logging.h"
#include "base/memory/scoped_ptr.h"
#include "testing/gtest/include/gtest/gtest.h"

namespace net {
Expand All @@ -19,7 +20,7 @@ class HybridSlowStartTest : public ::testing::Test {
void SetUp() override { slow_start_.reset(new HybridSlowStart()); }
const QuicTime::Delta one_ms_;
const QuicTime::Delta rtt_;
scoped_ptr<HybridSlowStart> slow_start_;
std::unique_ptr<HybridSlowStart> slow_start_;
};

TEST_F(HybridSlowStartTest, Simple) {
Expand Down
4 changes: 2 additions & 2 deletions net/quic/congestion_control/pacing_sender.h
Original file line number Diff line number Diff line change
Expand Up @@ -14,9 +14,9 @@
#include <stdint.h>

#include <map>
#include <memory>

#include "base/macros.h"
#include "base/memory/scoped_ptr.h"
#include "net/quic/congestion_control/send_algorithm_interface.h"
#include "net/quic/quic_bandwidth.h"
#include "net/quic/quic_config.h"
Expand Down Expand Up @@ -68,7 +68,7 @@ class NET_EXPORT_PRIVATE PacingSender : public SendAlgorithmInterface {
// End implementation of SendAlgorithmInterface.

private:
scoped_ptr<SendAlgorithmInterface> sender_; // Underlying sender.
std::unique_ptr<SendAlgorithmInterface> sender_; // Underlying sender.
// The estimated system alarm granularity.
const QuicTime::Delta alarm_granularity_;
// Configured maximum size of the burst coming out of quiescence. The burst
Expand Down
5 changes: 3 additions & 2 deletions net/quic/congestion_control/pacing_sender_test.cc
Original file line number Diff line number Diff line change
Expand Up @@ -4,8 +4,9 @@

#include "net/quic/congestion_control/pacing_sender.h"

#include <memory>

#include "base/logging.h"
#include "base/memory/scoped_ptr.h"
#include "net/quic/quic_protocol.h"
#include "net/quic/test_tools/mock_clock.h"
#include "net/quic/test_tools/quic_test_utils.h"
Expand Down Expand Up @@ -100,7 +101,7 @@ class PacingSenderTest : public ::testing::Test {
MockClock clock_;
QuicPacketNumber packet_number_;
StrictMock<MockSendAlgorithm>* mock_sender_;
scoped_ptr<PacingSender> pacing_sender_;
std::unique_ptr<PacingSender> pacing_sender_;
};

TEST_F(PacingSenderTest, NoSend) {
Expand Down
Loading

0 comments on commit ad1777e

Please sign in to comment.