Convert //content/browser from scoped_ptr to std::unique_ptr

content/browser/byte_stream_unittest.cc

 // Copyright (c) 2012 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "content/browser/byte_stream.h"
 
 #include <stddef.h>
 
 #include <deque>
 #include <limits>
@@ skipping 85 matching lines @@
   std::deque<size_t> length_queue_;
 };
 
 ByteStreamTest::ByteStreamTest()
     : producing_seed_key_(0),
       consuming_seed_key_(0) { }
 
 // Confirm that filling and emptying the stream works properly, and that
 // we get full triggers when we expect.
 TEST_F(ByteStreamTest, ByteStream_PushBack) {
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(message_loop_.task_runner(), message_loop_.task_runner(),
                    3 * 1024, &byte_stream_input, &byte_stream_output);
 
   // Push a series of IO buffers on; test pushback happening and
   // that it's advisory.
   EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
   EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
   EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
   EXPECT_FALSE(Write(byte_stream_input.get(), 1));
   EXPECT_FALSE(Write(byte_stream_input.get(), 1024));
@@ skipping 32 matching lines @@
             byte_stream_output->Read(&output_io_buffer, &output_length));
 
   message_loop_.RunUntilIdle();
   // Reader now knows that all data is read out.
   EXPECT_EQ(1024U, byte_stream_input->GetTotalBufferedBytes());
 }
 
 // Confirm that Flush() method makes the writer to send written contents to
 // the reader.
 TEST_F(ByteStreamTest, ByteStream_Flush) {
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(message_loop_.task_runner(), message_loop_.task_runner(),
                    1024, &byte_stream_input, &byte_stream_output);
 
   EXPECT_TRUE(Write(byte_stream_input.get(), 1));
   message_loop_.RunUntilIdle();
 
   scoped_refptr<net::IOBuffer> output_io_buffer;
   size_t output_length = 0;
   // Check that data is not sent to the reader yet.
   EXPECT_EQ(ByteStreamReader::STREAM_EMPTY,
@@ skipping 17 matching lines @@
   message_loop_.RunUntilIdle();
 
   EXPECT_EQ(ByteStreamReader::STREAM_COMPLETE,
             byte_stream_output->Read(&output_io_buffer, &output_length));
 }
 
 // Same as above, only use knowledge of the internals to confirm
 // that we're getting pushback even when data's split across the two
 // objects
 TEST_F(ByteStreamTest, ByteStream_PushBackSplit) {
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(message_loop_.task_runner(), message_loop_.task_runner(),
                    9 * 1024, &byte_stream_input, &byte_stream_output);
 
   // Push a series of IO buffers on; test pushback happening and
   // that it's advisory.
   EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
   message_loop_.RunUntilIdle();
   EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
   message_loop_.RunUntilIdle();
   EXPECT_TRUE(Write(byte_stream_input.get(), 1024));
@@ skipping 27 matching lines @@
             byte_stream_output->Read(&output_io_buffer, &output_length));
   EXPECT_TRUE(ValidateIOBuffer(output_io_buffer, output_length));
 
   EXPECT_EQ(ByteStreamReader::STREAM_EMPTY,
             byte_stream_output->Read(&output_io_buffer, &output_length));
 }
 
 // Confirm that a Close() notification transmits in-order
 // with data on the stream.
 TEST_F(ByteStreamTest, ByteStream_CompleteTransmits) {
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
 
   scoped_refptr<net::IOBuffer> output_io_buffer;
   size_t output_length;
 
   // Empty stream, non-error case.
   CreateByteStream(message_loop_.task_runner(), message_loop_.task_runner(),
                    3 * 1024, &byte_stream_input, &byte_stream_output);
   EXPECT_EQ(ByteStreamReader::STREAM_EMPTY,
             byte_stream_output->Read(&output_io_buffer, &output_length));
   byte_stream_input->Close(0);
@@ skipping 44 matching lines @@
   ASSERT_EQ(ByteStreamReader::STREAM_COMPLETE,
             byte_stream_output->Read(&output_io_buffer, &output_length));
   EXPECT_EQ(kFakeErrorCode, byte_stream_output->GetStatus());
 }
 
 // Confirm that callbacks on the sink side are triggered when they should be.
 TEST_F(ByteStreamTest, ByteStream_SinkCallback) {
   scoped_refptr<base::TestSimpleTaskRunner> task_runner(
       new base::TestSimpleTaskRunner());
 
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(message_loop_.task_runner(), task_runner, 10000,
                    &byte_stream_input, &byte_stream_output);
 
   scoped_refptr<net::IOBuffer> output_io_buffer;
   size_t output_length;
 
   // Note that the specifics of when the callbacks are called with regard
   // to how much data is pushed onto the stream is not (currently) part
   // of the interface contract.  If it becomes part of the contract, the
   // tests below should get much more precise.
@@ skipping 29 matching lines @@
   EXPECT_EQ(ByteStreamReader::STREAM_EMPTY,
             byte_stream_output->Read(&output_io_buffer, &output_length));
 }
 
 // Confirm that callbacks on the source side are triggered when they should
 // be.
 TEST_F(ByteStreamTest, ByteStream_SourceCallback) {
   scoped_refptr<base::TestSimpleTaskRunner> task_runner(
       new base::TestSimpleTaskRunner());
 
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(task_runner, message_loop_.task_runner(), 10000,
                    &byte_stream_input, &byte_stream_output);
 
   scoped_refptr<net::IOBuffer> output_io_buffer;
   size_t output_length;
 
   // Note that the specifics of when the callbacks are called with regard
   // to how much data is pulled from the stream is not (currently) part
   // of the interface contract.  If it becomes part of the contract, the
   // tests below should get much more precise.
@@ skipping 39 matching lines @@
   // callback.
   EXPECT_EQ(1, num_callbacks);
 }
 
 // Confirm that racing a change to a sink callback with a post results
 // in the new callback being called.
 TEST_F(ByteStreamTest, ByteStream_SinkInterrupt) {
   scoped_refptr<base::TestSimpleTaskRunner> task_runner(
       new base::TestSimpleTaskRunner());
 
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(message_loop_.task_runner(), task_runner, 10000,
                    &byte_stream_input, &byte_stream_output);
 
   scoped_refptr<net::IOBuffer> output_io_buffer;
   size_t output_length;
   base::Closure intermediate_callback;
 
   // Record initial state.
   int num_callbacks = 0;
   byte_stream_output->RegisterCallback(
@@ skipping 24 matching lines @@
             byte_stream_output->Read(&output_io_buffer, &output_length));
 
 }
 
 // Confirm that racing a change to a source callback with a post results
 // in the new callback being called.
 TEST_F(ByteStreamTest, ByteStream_SourceInterrupt) {
   scoped_refptr<base::TestSimpleTaskRunner> task_runner(
       new base::TestSimpleTaskRunner());
 
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(task_runner, message_loop_.task_runner(), 10000,
                    &byte_stream_input, &byte_stream_output);
 
   scoped_refptr<net::IOBuffer> output_io_buffer;
   size_t output_length;
   base::Closure intermediate_callback;
 
   // Setup state for test.
   int num_callbacks = 0;
   byte_stream_input->RegisterCallback(
@@ skipping 29 matching lines @@
   EXPECT_EQ(ByteStreamReader::STREAM_EMPTY,
             byte_stream_output->Read(&output_io_buffer, &output_length));
 }
 
 // Confirm that callback is called on zero data transfer but source
 // complete.
 TEST_F(ByteStreamTest, ByteStream_ZeroCallback) {
   scoped_refptr<base::TestSimpleTaskRunner> task_runner(
       new base::TestSimpleTaskRunner());
 
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(message_loop_.task_runner(), task_runner, 10000,
                    &byte_stream_input, &byte_stream_output);
 
   base::Closure intermediate_callback;
 
   // Record initial state.
   int num_callbacks = 0;
   byte_stream_output->RegisterCallback(
       base::Bind(CountCallbacks, &num_callbacks));
 
   // Immediately close the stream.
   byte_stream_input->Close(0);
   task_runner->RunUntilIdle();
   EXPECT_EQ(1, num_callbacks);
 }
 
 TEST_F(ByteStreamTest, ByteStream_CloseWithoutAnyWrite) {
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(message_loop_.task_runner(), message_loop_.task_runner(),
                    3 * 1024, &byte_stream_input, &byte_stream_output);
 
   byte_stream_input->Close(0);
   message_loop_.RunUntilIdle();
 
   scoped_refptr<net::IOBuffer> output_io_buffer;
   size_t output_length;
   EXPECT_EQ(ByteStreamReader::STREAM_COMPLETE,
             byte_stream_output->Read(&output_io_buffer, &output_length));
 }
 
 TEST_F(ByteStreamTest, ByteStream_FlushWithoutAnyWrite) {
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(message_loop_.task_runner(), message_loop_.task_runner(),
                    3 * 1024, &byte_stream_input, &byte_stream_output);
 
   byte_stream_input->Flush();
   message_loop_.RunUntilIdle();
 
   scoped_refptr<net::IOBuffer> output_io_buffer;
   size_t output_length;
   EXPECT_EQ(ByteStreamReader::STREAM_EMPTY,
             byte_stream_output->Read(&output_io_buffer, &output_length));
 
   byte_stream_input->Close(0);
   message_loop_.RunUntilIdle();
 
   EXPECT_EQ(ByteStreamReader::STREAM_COMPLETE,
             byte_stream_output->Read(&output_io_buffer, &output_length));
 }
 
 TEST_F(ByteStreamTest, ByteStream_WriteOverflow) {
-  scoped_ptr<ByteStreamWriter> byte_stream_input;
-  scoped_ptr<ByteStreamReader> byte_stream_output;
+  std::unique_ptr<ByteStreamWriter> byte_stream_input;
+  std::unique_ptr<ByteStreamReader> byte_stream_output;
   CreateByteStream(message_loop_.task_runner(), message_loop_.task_runner(),
                    std::numeric_limits<size_t>::max(), &byte_stream_input,
                    &byte_stream_output);
 
   EXPECT_TRUE(Write(byte_stream_input.get(), 1));
   // 1 + size_t max -> Overflow.
   scoped_refptr<net::IOBuffer> empty_io_buffer;
   EXPECT_FALSE(byte_stream_input->Write(empty_io_buffer,
                                         std::numeric_limits<size_t>::max()));
   message_loop_.RunUntilIdle();
 
   // The first write is below PostToPeer threshold. We shouldn't get anything
   // from the output.
   scoped_refptr<net::IOBuffer> output_io_buffer;
   size_t output_length;
   EXPECT_EQ(ByteStreamReader::STREAM_EMPTY,
             byte_stream_output->Read(&output_io_buffer, &output_length));
 }
 
 }  // namespace content