Index: net/quic/quic_session_test.cc |
diff --git a/net/quic/quic_session_test.cc b/net/quic/quic_session_test.cc |
index 9d4acbfba3cfe1a939d6f83fc9a717c9d27d67fe..20c6f6317ac7cea10dce911e3efeaf58f4b107c1 100644 |
--- a/net/quic/quic_session_test.cc |
+++ b/net/quic/quic_session_test.cc |
@@ -32,7 +32,8 @@ namespace net { |
namespace test { |
namespace { |
-const QuicPriority kSomeMiddlePriority = 2; |
+const QuicPriority kHighestPriority = 0; |
+const QuicPriority kSomeMiddlePriority = 3; |
class TestCryptoStream : public QuicCryptoStream { |
public: |
@@ -279,6 +280,32 @@ TEST_P(QuicSessionTest, DecompressionError) { |
} |
} |
+TEST_P(QuicSessionTest, DebugDFatalIfMarkingClosedStreamWriteBlocked) { |
+ TestStream* stream2 = session_.CreateOutgoingDataStream(); |
+ // Close the stream. |
+ stream2->Reset(QUIC_BAD_APPLICATION_PAYLOAD); |
+ // TODO(rtenneti): enable when chromium supports EXPECT_DEBUG_DFATAL. |
+ /* |
+ QuicStreamId kClosedStreamId = stream2->id(); |
+ EXPECT_DEBUG_DFATAL( |
+ session_.MarkWriteBlocked(kClosedStreamId, kSomeMiddlePriority), |
+ "Marking unknown stream 2 blocked."); |
+ */ |
+} |
+ |
+TEST_P(QuicSessionTest, DebugDFatalIfMarkWriteBlockedCalledWithWrongPriority) { |
+ const QuicPriority kDifferentPriority = 0; |
+ |
+ TestStream* stream2 = session_.CreateOutgoingDataStream(); |
+ EXPECT_NE(kDifferentPriority, stream2->EffectivePriority()); |
+ // TODO(rtenneti): enable when chromium supports EXPECT_DEBUG_DFATAL. |
+ /* |
+ EXPECT_DEBUG_DFATAL( |
+ session_.MarkWriteBlocked(stream2->id(), kDifferentPriority), |
+ "Priorities do not match. Got: 0 Expected: 3"); |
+ */ |
+} |
+ |
TEST_P(QuicSessionTest, OnCanWrite) { |
TestStream* stream2 = session_.CreateOutgoingDataStream(); |
TestStream* stream4 = session_.CreateOutgoingDataStream(); |
@@ -314,7 +341,7 @@ TEST_P(QuicSessionTest, BufferedHandshake) { |
EXPECT_FALSE(session_.HasPendingHandshake()); |
// Blocking (due to buffering of) the Crypto stream is detected. |
- session_.MarkWriteBlocked(kCryptoStreamId, kSomeMiddlePriority); |
+ session_.MarkWriteBlocked(kCryptoStreamId, kHighestPriority); |
EXPECT_TRUE(session_.HasPendingHandshake()); |
TestStream* stream4 = session_.CreateOutgoingDataStream(); |