commit 9946bc08676d6659e7c7848dd0ff2f978c65f9fa
author renjietang <renjietang@google.com> Thu Jul 16 15:14:27 2020 -0700
committer Copybara-Service <copybara-worker@google.com> Thu Jul 16 15:15:10 2020 -0700
tree 9a51e31a15fdb7974805c8eb083c80c8bd957981
parent a0d2a575cd793f5ca2ea3a13a88c6acd09a4c08a

Move handling of STOP_SENDING frame from QuicSession to QuicStream.

Refactor only. not protected.

PiperOrigin-RevId: 321656082
Change-Id: I430fc25ab69436c817d95c5ef6626e69ddb80dda

quic/core/http/quic_spdy_stream_test.cc

diff --git a/quic/core/http/quic_spdy_stream_test.cc b/quic/core/http/quic_spdy_stream_test.cc
index 63df00e..983ae8c 100644
--- a/quic/core/http/quic_spdy_stream_test.cc
+++ b/quic/core/http/quic_spdy_stream_test.cc
@@ -505,7 +505,7 @@
         spdy::SpdyStreamPrecedence(kV3HighestPriority));
 
     EXPECT_CALL(*session_,
-                SendRstStream(stream_->id(), QUIC_HEADERS_TOO_LARGE, 0));
+                SendRstStream(stream_->id(), QUIC_HEADERS_TOO_LARGE, 0, _));
     stream_->OnStreamHeaderList(false, 1 << 20, headers);
 
     EXPECT_THAT(stream_->stream_error(), IsStreamError(QUIC_HEADERS_TOO_LARGE));
@@ -521,7 +521,7 @@
   QuicStreamFrame frame(stream_->id(), false, 0, headers);
 
   EXPECT_CALL(*session_,
-              SendRstStream(stream_->id(), QUIC_HEADERS_TOO_LARGE, 0));
+              SendRstStream(stream_->id(), QUIC_HEADERS_TOO_LARGE, 0, _));
 
   auto qpack_decoder_stream =
       QuicSpdySessionPeer::GetQpackDecoderSendStream(session_.get());
@@ -657,8 +657,8 @@
                               ConnectionCloseSource source) {
         session_->ReallyOnConnectionClosed(frame, source);
       }));
-  EXPECT_CALL(*session_, SendRstStream(_, _, _));
-  EXPECT_CALL(*session_, SendRstStream(_, _, _));
+  EXPECT_CALL(*session_, SendRstStream(_, _, _, _));
+  EXPECT_CALL(*session_, SendRstStream(_, _, _, _));
 
   stream_->OnStreamFrame(frame);
 }
@@ -2124,8 +2124,8 @@
                               ConnectionCloseSource source) {
         session_->ReallyOnConnectionClosed(frame, source);
       }));
-  EXPECT_CALL(*session_, SendRstStream(_, _, _));
-  EXPECT_CALL(*session_, SendRstStream(_, _, _));
+  EXPECT_CALL(*session_, SendRstStream(_, _, _, _));
+  EXPECT_CALL(*session_, SendRstStream(_, _, _, _));
   stream_->OnStreamFrame(frame);
 }
 
@@ -2163,8 +2163,8 @@
           session_->ReallyOnConnectionClosed(frame, source);
         }));
   }
-  EXPECT_CALL(*session_, SendRstStream(stream_->id(), _, _));
-  EXPECT_CALL(*session_, SendRstStream(stream2_->id(), _, _));
+  EXPECT_CALL(*session_, SendRstStream(stream_->id(), _, _, _));
+  EXPECT_CALL(*session_, SendRstStream(stream2_->id(), _, _, _));
 
   // Invalid headers: Required Insert Count is zero, but the header block
   // contains a dynamic table reference.
@@ -2893,7 +2893,7 @@
               WritevData(qpack_decoder_stream->id(), /* write_length = */ 1,
                          /* offset = */ 1, _, _, _));
   EXPECT_CALL(*session_,
-              SendRstStream(stream_->id(), QUIC_STREAM_CANCELLED, 0));
+              SendRstStream(stream_->id(), QUIC_STREAM_CANCELLED, 0, _));
 
   stream_->Reset(QUIC_STREAM_CANCELLED);
 }