| Index: net/quic/core/quic_stream.cc
|
| diff --git a/net/quic/core/quic_stream.cc b/net/quic/core/quic_stream.cc
|
| index 403a1b1ce88df1f55d097347e8a7e926d678be61..8a3d4a1364fba2ff258e3b76a022b4b51d807abe 100644
|
| --- a/net/quic/core/quic_stream.cc
|
| +++ b/net/quic/core/quic_stream.cc
|
| @@ -43,7 +43,7 @@ size_t GetReceivedFlowControlWindow(QuicSession* session) {
|
|
|
| QuicStream::PendingData::PendingData(
|
| string data_in,
|
| - scoped_refptr<QuicAckListenerInterface> ack_listener_in)
|
| + QuicReferenceCountedPointer<QuicAckListenerInterface> ack_listener_in)
|
| : data(std::move(data_in)),
|
| offset(0),
|
| ack_listener(std::move(ack_listener_in)) {}
|
| @@ -182,7 +182,7 @@ void QuicStream::CloseConnectionWithDetails(QuicErrorCode error,
|
| void QuicStream::WriteOrBufferData(
|
| StringPiece data,
|
| bool fin,
|
| - scoped_refptr<QuicAckListenerInterface> ack_listener) {
|
| + QuicReferenceCountedPointer<QuicAckListenerInterface> ack_listener) {
|
| if (data.empty() && !fin) {
|
| QUIC_BUG << "data.empty() && !fin";
|
| return;
|
| @@ -219,7 +219,7 @@ void QuicStream::OnCanWrite() {
|
| bool fin = false;
|
| while (!queued_data_.empty()) {
|
| PendingData* pending_data = &queued_data_.front();
|
| - scoped_refptr<QuicAckListenerInterface> ack_listener =
|
| + QuicReferenceCountedPointer<QuicAckListenerInterface> ack_listener =
|
| pending_data->ack_listener;
|
| if (queued_data_.size() == 1 && fin_buffered_) {
|
| fin = true;
|
| @@ -270,7 +270,7 @@ QuicConsumedData QuicStream::WritevData(
|
| const struct iovec* iov,
|
| int iov_count,
|
| bool fin,
|
| - scoped_refptr<QuicAckListenerInterface> ack_listener) {
|
| + QuicReferenceCountedPointer<QuicAckListenerInterface> ack_listener) {
|
| if (write_side_closed_) {
|
| DLOG(ERROR) << ENDPOINT << "Attempt to write when the write side is closed";
|
| return QuicConsumedData(0, false);
|
| @@ -351,7 +351,8 @@ QuicConsumedData QuicStream::WritevDataInner(
|
| QuicIOVector iov,
|
| QuicStreamOffset offset,
|
| bool fin,
|
| - scoped_refptr<QuicAckListenerInterface> ack_notifier_delegate) {
|
| + QuicReferenceCountedPointer<QuicAckListenerInterface>
|
| + ack_notifier_delegate) {
|
| return session()->WritevData(this, id(), iov, offset, fin,
|
| std::move(ack_notifier_delegate));
|
| }
|
|
|