| Index: net/quic/core/quic_stream.h
|
| diff --git a/net/quic/core/quic_stream.h b/net/quic/core/quic_stream.h
|
| index ebfa62d3f10395f7e7afdfba0e859189a4a73456..e74150c9de23821c44bfc01457e3e1c155afc601 100644
|
| --- a/net/quic/core/quic_stream.h
|
| +++ b/net/quic/core/quic_stream.h
|
| @@ -184,19 +184,21 @@ class QUIC_EXPORT_PRIVATE QuicStream {
|
| // 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,
|
| - QuicAckListenerInterface* ack_listener);
|
| + void WriteOrBufferData(
|
| + base::StringPiece data,
|
| + bool fin,
|
| + const scoped_refptr<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,
|
| - QuicAckListenerInterface* ack_listener);
|
| + QuicConsumedData WritevData(
|
| + const struct iovec* iov,
|
| + int iov_count,
|
| + bool fin,
|
| + const scoped_refptr<QuicAckListenerInterface>& ack_listener);
|
|
|
| // Allows override of the session level writev, for the force HOL
|
| // blocking experiment.
|
| @@ -204,7 +206,7 @@ class QUIC_EXPORT_PRIVATE QuicStream {
|
| QuicIOVector iov,
|
| QuicStreamOffset offset,
|
| bool fin,
|
| - QuicAckListenerInterface* ack_notifier_delegate);
|
| + const scoped_refptr<QuicAckListenerInterface>& ack_notifier_delegate);
|
|
|
| // Close the write side of the socket. Further writes will fail.
|
| // Can be called by the subclass or internally.
|
| @@ -235,7 +237,8 @@ class QUIC_EXPORT_PRIVATE QuicStream {
|
| bool read_side_closed() const { return read_side_closed_; }
|
|
|
| struct PendingData {
|
| - PendingData(std::string data_in, QuicAckListenerInterface* ack_listener_in);
|
| + PendingData(std::string data_in,
|
| + scoped_refptr<QuicAckListenerInterface> ack_listener_in);
|
| ~PendingData();
|
|
|
| // Pending data to be written.
|
|
|