OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 The Chromium Authors. All rights reserved. |
2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
4 // | 4 // |
5 #include "net/quic/quic_write_blocked_list.h" | 5 #include "net/quic/quic_write_blocked_list.h" |
6 | 6 |
7 #include "testing/gtest/include/gtest/gtest.h" | 7 #include "testing/gtest/include/gtest/gtest.h" |
8 | 8 |
9 namespace net { | 9 namespace net { |
10 namespace test { | 10 namespace test { |
11 namespace { | 11 namespace { |
12 | 12 |
13 TEST(QuicWriteBlockedListTest, PriorityOrder) { | 13 TEST(QuicWriteBlockedListTest, PriorityOrder) { |
14 QuicWriteBlockedList write_blocked_list; | 14 QuicWriteBlockedList write_blocked_list; |
15 | 15 |
16 // Mark streams blocked in roughly reverse priority order, and | 16 // Mark streams blocked in roughly reverse priority order, and |
17 // verify that streams are sorted. | 17 // verify that streams are sorted. |
18 write_blocked_list.PushBack(40, | 18 write_blocked_list.PushBack(40, |
19 QuicWriteBlockedList::kLowestPriority, | 19 QuicWriteBlockedList::kLowestPriority); |
20 QUIC_VERSION_13); | |
21 write_blocked_list.PushBack(23, | 20 write_blocked_list.PushBack(23, |
22 QuicWriteBlockedList::kHighestPriority, | 21 QuicWriteBlockedList::kHighestPriority); |
23 QUIC_VERSION_13); | |
24 write_blocked_list.PushBack(17, | 22 write_blocked_list.PushBack(17, |
25 QuicWriteBlockedList::kHighestPriority, | 23 QuicWriteBlockedList::kHighestPriority); |
26 QUIC_VERSION_13); | |
27 write_blocked_list.PushBack(kHeadersStreamId, | 24 write_blocked_list.PushBack(kHeadersStreamId, |
28 QuicWriteBlockedList::kHighestPriority, | 25 QuicWriteBlockedList::kHighestPriority); |
29 QUIC_VERSION_13); | |
30 write_blocked_list.PushBack(kCryptoStreamId, | 26 write_blocked_list.PushBack(kCryptoStreamId, |
31 QuicWriteBlockedList::kHighestPriority, | 27 QuicWriteBlockedList::kHighestPriority); |
32 QUIC_VERSION_13); | |
33 | 28 |
34 EXPECT_EQ(5u, write_blocked_list.NumBlockedStreams()); | 29 EXPECT_EQ(5u, write_blocked_list.NumBlockedStreams()); |
35 EXPECT_TRUE(write_blocked_list.HasWriteBlockedStreams()); | 30 EXPECT_TRUE(write_blocked_list.HasWriteBlockedStreams()); |
36 // The Crypto stream is highest priority. | 31 // The Crypto stream is highest priority. |
37 EXPECT_EQ(kCryptoStreamId, write_blocked_list.PopFront()); | 32 EXPECT_EQ(kCryptoStreamId, write_blocked_list.PopFront()); |
38 // Followed by the Headers stream. | 33 // Followed by the Headers stream. |
39 EXPECT_EQ(kHeadersStreamId, write_blocked_list.PopFront()); | 34 EXPECT_EQ(kHeadersStreamId, write_blocked_list.PopFront()); |
40 // Streams with same priority are popped in the order they were inserted. | 35 // Streams with same priority are popped in the order they were inserted. |
41 EXPECT_EQ(23u, write_blocked_list.PopFront()); | 36 EXPECT_EQ(23u, write_blocked_list.PopFront()); |
42 EXPECT_EQ(17u, write_blocked_list.PopFront()); | 37 EXPECT_EQ(17u, write_blocked_list.PopFront()); |
43 // Low priority stream appears last. | 38 // Low priority stream appears last. |
44 EXPECT_EQ(40u, write_blocked_list.PopFront()); | 39 EXPECT_EQ(40u, write_blocked_list.PopFront()); |
45 | 40 |
46 EXPECT_EQ(0u, write_blocked_list.NumBlockedStreams()); | 41 EXPECT_EQ(0u, write_blocked_list.NumBlockedStreams()); |
47 EXPECT_FALSE(write_blocked_list.HasWriteBlockedStreams()); | 42 EXPECT_FALSE(write_blocked_list.HasWriteBlockedStreams()); |
48 } | 43 } |
49 | 44 |
50 TEST(QuicWriteBlockedListTest, CryptoStream) { | 45 TEST(QuicWriteBlockedListTest, CryptoStream) { |
51 QuicWriteBlockedList write_blocked_list; | 46 QuicWriteBlockedList write_blocked_list; |
52 write_blocked_list.PushBack(kCryptoStreamId, | 47 write_blocked_list.PushBack(kCryptoStreamId, |
53 QuicWriteBlockedList::kHighestPriority, | 48 QuicWriteBlockedList::kHighestPriority); |
54 QUIC_VERSION_13); | |
55 | 49 |
56 EXPECT_EQ(1u, write_blocked_list.NumBlockedStreams()); | 50 EXPECT_EQ(1u, write_blocked_list.NumBlockedStreams()); |
57 EXPECT_TRUE(write_blocked_list.HasWriteBlockedStreams()); | 51 EXPECT_TRUE(write_blocked_list.HasWriteBlockedStreams()); |
58 EXPECT_EQ(kCryptoStreamId, write_blocked_list.PopFront()); | 52 EXPECT_EQ(kCryptoStreamId, write_blocked_list.PopFront()); |
59 EXPECT_EQ(0u, write_blocked_list.NumBlockedStreams()); | 53 EXPECT_EQ(0u, write_blocked_list.NumBlockedStreams()); |
60 EXPECT_FALSE(write_blocked_list.HasWriteBlockedStreams()); | 54 EXPECT_FALSE(write_blocked_list.HasWriteBlockedStreams()); |
61 } | 55 } |
62 | 56 |
63 TEST(QuicWriteBlockedListTest, HeadersStream) { | 57 TEST(QuicWriteBlockedListTest, HeadersStream) { |
64 QuicWriteBlockedList write_blocked_list; | 58 QuicWriteBlockedList write_blocked_list; |
65 write_blocked_list.PushBack(kHeadersStreamId, | 59 write_blocked_list.PushBack(kHeadersStreamId, |
66 QuicWriteBlockedList::kHighestPriority, | 60 QuicWriteBlockedList::kHighestPriority); |
67 QUIC_VERSION_13); | |
68 | 61 |
69 EXPECT_EQ(1u, write_blocked_list.NumBlockedStreams()); | 62 EXPECT_EQ(1u, write_blocked_list.NumBlockedStreams()); |
70 EXPECT_TRUE(write_blocked_list.HasWriteBlockedStreams()); | 63 EXPECT_TRUE(write_blocked_list.HasWriteBlockedStreams()); |
71 EXPECT_EQ(kHeadersStreamId, write_blocked_list.PopFront()); | 64 EXPECT_EQ(kHeadersStreamId, write_blocked_list.PopFront()); |
72 EXPECT_EQ(0u, write_blocked_list.NumBlockedStreams()); | 65 EXPECT_EQ(0u, write_blocked_list.NumBlockedStreams()); |
73 EXPECT_FALSE(write_blocked_list.HasWriteBlockedStreams()); | 66 EXPECT_FALSE(write_blocked_list.HasWriteBlockedStreams()); |
74 } | 67 } |
75 | 68 |
76 TEST(QuicWriteBlockedListTest, NoHeadersStreamInVersion12) { | 69 TEST(QuicWriteBlockedListTest, VerifyHeadersStream) { |
77 for (int idx = 0; idx < 2; ++idx) { | 70 QuicWriteBlockedList write_blocked_list; |
78 QuicVersion version = ((idx == 0) ? QUIC_VERSION_13 : QUIC_VERSION_12); | 71 write_blocked_list.PushBack(5, |
79 QuicWriteBlockedList write_blocked_list; | 72 QuicWriteBlockedList::kHighestPriority); |
80 write_blocked_list.PushBack(5, | 73 write_blocked_list.PushBack(kHeadersStreamId, |
81 QuicWriteBlockedList::kHighestPriority, | 74 QuicWriteBlockedList::kHighestPriority); |
82 version); | |
83 write_blocked_list.PushBack(kHeadersStreamId, | |
84 QuicWriteBlockedList::kHighestPriority, | |
85 version); | |
86 | 75 |
87 EXPECT_EQ(2u, write_blocked_list.NumBlockedStreams()); | 76 EXPECT_EQ(2u, write_blocked_list.NumBlockedStreams()); |
88 EXPECT_TRUE(write_blocked_list.HasWriteBlockedStreams()); | 77 EXPECT_TRUE(write_blocked_list.HasWriteBlockedStreams()); |
89 if (version > QUIC_VERSION_12) { | 78 // In newer QUIC versions, there is a headers stream which is |
90 // In newer QUIC versions, there is a headers stream which is | 79 // higher priority than data streams. |
91 // higher priority than data streams. | 80 EXPECT_EQ(kHeadersStreamId, write_blocked_list.PopFront()); |
92 EXPECT_EQ(kHeadersStreamId, write_blocked_list.PopFront()); | 81 EXPECT_EQ(5u, write_blocked_list.PopFront()); |
93 EXPECT_EQ(5u, write_blocked_list.PopFront()); | 82 EXPECT_EQ(0u, write_blocked_list.NumBlockedStreams()); |
94 } else { | 83 EXPECT_FALSE(write_blocked_list.HasWriteBlockedStreams()); |
95 // In older QUIC versions, there is no reserved headers stream id. | |
96 EXPECT_EQ(5u, write_blocked_list.PopFront()); | |
97 EXPECT_EQ(kHeadersStreamId, write_blocked_list.PopFront()); | |
98 } | |
99 EXPECT_EQ(0u, write_blocked_list.NumBlockedStreams()); | |
100 EXPECT_FALSE(write_blocked_list.HasWriteBlockedStreams()); | |
101 } | |
102 } | 84 } |
103 | 85 |
104 } // namespace | 86 } // namespace |
105 } // namespace test | 87 } // namespace test |
106 } // namespace net | 88 } // namespace net |
OLD | NEW |