| 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();
|
|
|