Create a QUIC wrapper around scoped_refptr.

net/quic/core/quic_stream.h

 // 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.
 //
 // The base class for client/server QUIC streams.
 
 // It does not contain the entire interface needed by an application to interact
 // with a QUIC stream.  Some parts of the interface must be obtained by
 // accessing the owning session object.  A subclass of QuicStream
 // connects the object and the application that generates and consumes the data
 // of the stream.
 
 // The QuicStream object has a dependent QuicStreamSequencer object,
 // which is given the stream frames as they arrive, and provides stream data in
 // order by invoking ProcessRawData().
 
 #ifndef NET_QUIC_CORE_QUIC_STREAM_H_
 #define NET_QUIC_CORE_QUIC_STREAM_H_
 
 #include <stddef.h>
 #include <stdint.h>
 #include <sys/types.h>
 
 #include <list>
 #include <string>
 
 #include "base/macros.h"
-#include "base/memory/ref_counted.h"
 #include "base/strings/string_piece.h"
 #include "net/base/iovec.h"
 #include "net/quic/core/quic_flow_controller.h"
 #include "net/quic/core/quic_iovector.h"
 #include "net/quic/core/quic_packets.h"
 #include "net/quic/core/quic_stream_sequencer.h"
 #include "net/quic/core/quic_types.h"
 #include "net/quic/platform/api/quic_export.h"
+#include "net/quic/platform/api/quic_reference_counted.h"
 
 namespace net {
 
 namespace test {
 class QuicStreamPeer;
 }  // namespace test
 
 class QuicSession;
 
 class QUIC_EXPORT_PRIVATE QuicStream {
@@ skipping 130 matching lines @@
   virtual void StopReading();
 
   // Get peer IP of the lastest packet which connection is dealing/delt with.
   virtual const QuicSocketAddress& PeerAddressOfLatestPacket() const;
 
  protected:
   // Sends as much of 'data' to the connection as the connection will consume,
   // and then buffers any remaining data in queued_data_.
   // If fin is true: if it is immediately passed on to the session,
   // write_side_closed() becomes true, otherwise fin_buffered_ becomes true.
-  void WriteOrBufferData(base::StringPiece data,
-                         bool fin,
-                         scoped_refptr<QuicAckListenerInterface> ack_listener);
+  void WriteOrBufferData(
+      base::StringPiece data,
+      bool fin,
+      QuicReferenceCountedPointer<QuicAckListenerInterface> ack_listener);
 
   // Sends as many bytes in the first |count| buffers of |iov| to the connection
   // as the connection will consume.
   // If |ack_listener| is provided, then it will be notified once all
   // the ACKs for this write have been received.
   // Returns the number of bytes consumed by the connection.
   QuicConsumedData WritevData(
       const struct iovec* iov,
       int iov_count,
       bool fin,
-      scoped_refptr<QuicAckListenerInterface> ack_listener);
+      QuicReferenceCountedPointer<QuicAckListenerInterface> ack_listener);
 
   // Allows override of the session level writev, for the force HOL
   // blocking experiment.
   virtual QuicConsumedData WritevDataInner(
       QuicIOVector iov,
       QuicStreamOffset offset,
       bool fin,
-      scoped_refptr<QuicAckListenerInterface> ack_notifier_delegate);
+      QuicReferenceCountedPointer<QuicAckListenerInterface>
+          ack_notifier_delegate);
 
   // Close the write side of the socket.  Further writes will fail.
   // Can be called by the subclass or internally.
   // Does not send a FIN.  May cause the stream to be closed.
   virtual void CloseWriteSide();
 
   bool fin_buffered() const { return fin_buffered_; }
 
   const QuicSession* session() const { return session_; }
   QuicSession* session() { return session_; }
@@ skipping 10 matching lines @@
   friend class QuicStreamUtils;
 
   // Close the read side of the socket.  May cause the stream to be closed.
   // Subclasses and consumers should use StopReading to terminate reading early.
   void CloseReadSide();
 
   // Subclasses and consumers should use reading_stopped.
   bool read_side_closed() const { return read_side_closed_; }
 
   struct PendingData {
-    PendingData(std::string data_in,
-                scoped_refptr<QuicAckListenerInterface> ack_listener_in);
+    PendingData(
+        std::string data_in,
+        QuicReferenceCountedPointer<QuicAckListenerInterface> ack_listener_in);
     ~PendingData();
 
     // Pending data to be written.
     std::string data;
     // Index of the first byte in data still to be written.
     size_t offset;
     // AckListener that should be notified when the pending data is acked.
     // Can be nullptr.
-    scoped_refptr<QuicAckListenerInterface> ack_listener;
+    QuicReferenceCountedPointer<QuicAckListenerInterface> ack_listener;
   };
 
   // Calls MaybeSendBlocked on the stream's flow controller and the connection
   // level flow controller.  If the stream is flow control blocked by the
   // connection-level flow controller but not by the stream-level flow
   // controller, marks this stream as connection-level write blocked.
   void MaybeSendBlocked();
 
   std::list<PendingData> queued_data_;
   // How many bytes are queued?
@@ skipping 55 matching lines @@
 
   // For debugging only, used for busy loop check.
   size_t busy_counter_;
 
   DISALLOW_COPY_AND_ASSIGN(QuicStream);
 };
 
 }  // namespace net
 
 #endif  // NET_QUIC_CORE_QUIC_STREAM_H_