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/spdy/spdy_headers_block_parser.h" | 5 #include "net/spdy/spdy_headers_block_parser.h" |
6 | 6 |
7 #include <string> | 7 #include <string> |
8 | 8 |
9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
10 #include "base/strings/string_number_conversions.h" | 10 #include "base/strings/string_number_conversions.h" |
11 #include "base/sys_byteorder.h" | 11 #include "base/sys_byteorder.h" |
| 12 #include "net/test/gtest_util.h" |
12 #include "testing/gmock/include/gmock/gmock.h" | 13 #include "testing/gmock/include/gmock/gmock.h" |
13 #include "testing/gtest/include/gtest/gtest.h" | 14 #include "testing/gtest/include/gtest/gtest.h" |
14 | 15 |
15 namespace net { | 16 namespace net { |
16 | 17 |
17 using base::IntToString; | 18 using base::IntToString; |
18 using base::StringPiece; | 19 using base::StringPiece; |
19 using std::string; | 20 using std::string; |
20 | 21 |
21 // A mock the handler class to check that we parse out the correct headers | 22 // A mock the handler class to check that we parse out the correct headers |
22 // and call the callback methods when we should. | 23 // and call the callback methods when we should. |
23 class MockSpdyHeadersHandler : public SpdyHeadersHandlerInterface { | 24 class MockSpdyHeadersHandler : public SpdyHeadersHandlerInterface { |
24 public: | 25 public: |
25 MOCK_METHOD2(OnHeaderBlock, void(SpdyStreamId stream_id, | 26 MOCK_METHOD1(OnHeaderBlock, void(uint32_t num_of_headers)); |
26 uint32_t num_of_headers)); | 27 MOCK_METHOD1(OnHeaderBlockEnd, void(size_t bytes)); |
27 MOCK_METHOD2(OnHeaderBlockEnd, void(SpdyStreamId stream_id, size_t bytes)); | 28 MOCK_METHOD2(OnHeader, void(StringPiece key, StringPiece value)); |
28 MOCK_METHOD3(OnHeader, void(SpdyStreamId stream_id, | |
29 StringPiece, | |
30 StringPiece)); | |
31 }; | 29 }; |
32 | 30 |
33 class SpdyHeadersBlockParserTest : | 31 class SpdyHeadersBlockParserTest : |
34 public ::testing::TestWithParam<SpdyMajorVersion> { | 32 public ::testing::TestWithParam<SpdyMajorVersion> { |
35 public: | 33 public: |
36 virtual ~SpdyHeadersBlockParserTest() {} | 34 virtual ~SpdyHeadersBlockParserTest() {} |
37 | 35 |
38 protected: | 36 protected: |
39 void SetUp() override { | 37 void SetUp() override { |
40 // Create a parser using the mock handler. | 38 // Create a parser using the mock handler. |
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
114 INSTANTIATE_TEST_CASE_P(SpdyHeadersBlockParserTests, | 112 INSTANTIATE_TEST_CASE_P(SpdyHeadersBlockParserTests, |
115 SpdyHeadersBlockParserTest, | 113 SpdyHeadersBlockParserTest, |
116 ::testing::Values(SPDY2, SPDY3, SPDY4)); | 114 ::testing::Values(SPDY2, SPDY3, SPDY4)); |
117 | 115 |
118 TEST_P(SpdyHeadersBlockParserTest, BasicTest) { | 116 TEST_P(SpdyHeadersBlockParserTest, BasicTest) { |
119 // Sanity test, verify that we parse out correctly a block with | 117 // Sanity test, verify that we parse out correctly a block with |
120 // a single key-value pair and that we notify when we start and finish | 118 // a single key-value pair and that we notify when we start and finish |
121 // handling a headers block. | 119 // handling a headers block. |
122 string headers(CreateHeaders(1, false)); | 120 string headers(CreateHeaders(1, false)); |
123 | 121 |
124 EXPECT_CALL(handler_, OnHeaderBlock(1, 1)).Times(1); | 122 EXPECT_CALL(handler_, OnHeaderBlock(1)).Times(1); |
125 | 123 |
126 std::string expect_key = kBaseKey + IntToString(0); | 124 std::string expect_key = kBaseKey + IntToString(0); |
127 std::string expect_value = kBaseValue + IntToString(0); | 125 std::string expect_value = kBaseValue + IntToString(0); |
128 EXPECT_CALL(handler_, OnHeader(1, StringPiece(expect_key), | 126 EXPECT_CALL(handler_, OnHeader(StringPiece(expect_key), |
129 StringPiece(expect_value))).Times(1); | 127 StringPiece(expect_value))).Times(1); |
130 EXPECT_CALL(handler_, OnHeaderBlockEnd(1, headers.length())).Times(1); | 128 EXPECT_CALL(handler_, OnHeaderBlockEnd(headers.length())).Times(1); |
131 | 129 |
132 EXPECT_TRUE(parser_-> | 130 EXPECT_TRUE(parser_-> |
133 HandleControlFrameHeadersData(1, headers.c_str(), headers.length())); | 131 HandleControlFrameHeadersData(1, headers.c_str(), headers.length())); |
134 EXPECT_EQ(SpdyHeadersBlockParser::OK, parser_->get_error()); | 132 EXPECT_EQ(SpdyHeadersBlockParser::OK, parser_->get_error()); |
135 } | 133 } |
136 | 134 |
137 TEST_P(SpdyHeadersBlockParserTest, NullsSupportedTest) { | 135 TEST_P(SpdyHeadersBlockParserTest, NullsSupportedTest) { |
138 // Sanity test, verify that we parse out correctly a block with | 136 // Sanity test, verify that we parse out correctly a block with |
139 // a single key-value pair when the key and value contain null charecters. | 137 // a single key-value pair when the key and value contain null charecters. |
140 string headers(CreateHeaders(1, true)); | 138 string headers(CreateHeaders(1, true)); |
141 | 139 |
142 EXPECT_CALL(handler_, OnHeaderBlock(1, 1)).Times(1); | 140 EXPECT_CALL(handler_, OnHeaderBlock(1)).Times(1); |
143 | 141 |
144 std::string expect_key = kBaseKey + string("\0", 1) + IntToString(0); | 142 std::string expect_key = kBaseKey + string("\0", 1) + IntToString(0); |
145 std::string expect_value = kBaseValue + string("\0", 1) + IntToString(0); | 143 std::string expect_value = kBaseValue + string("\0", 1) + IntToString(0); |
146 EXPECT_CALL(handler_, OnHeader(1, StringPiece(expect_key), | 144 EXPECT_CALL(handler_, OnHeader(StringPiece(expect_key), |
147 StringPiece(expect_value))).Times(1); | 145 StringPiece(expect_value))).Times(1); |
148 EXPECT_CALL(handler_, OnHeaderBlockEnd(1, headers.length())).Times(1); | 146 EXPECT_CALL(handler_, OnHeaderBlockEnd(headers.length())).Times(1); |
149 | 147 |
150 EXPECT_TRUE(parser_-> | 148 EXPECT_TRUE(parser_-> |
151 HandleControlFrameHeadersData(1, headers.c_str(), headers.length())); | 149 HandleControlFrameHeadersData(1, headers.c_str(), headers.length())); |
152 EXPECT_EQ(SpdyHeadersBlockParser::OK, parser_->get_error()); | 150 EXPECT_EQ(SpdyHeadersBlockParser::OK, parser_->get_error()); |
153 } | 151 } |
154 | 152 |
155 TEST_P(SpdyHeadersBlockParserTest, MultipleBlocksAndHeadersWithPartialData) { | 153 TEST_P(SpdyHeadersBlockParserTest, MultipleBlocksAndHeadersWithPartialData) { |
156 testing::InSequence s; | 154 testing::InSequence s; |
157 | 155 |
158 // CreateHeaders is deterministic; we can call it once for the whole test. | 156 // CreateHeaders is deterministic; we can call it once for the whole test. |
159 string headers(CreateHeaders(kNumHeadersInBlock, false)); | 157 string headers(CreateHeaders(kNumHeadersInBlock, false)); |
160 | 158 |
161 // The mock doesn't retain storage of arguments, so keep them in scope. | 159 // The mock doesn't retain storage of arguments, so keep them in scope. |
162 std::vector<string> retained_arguments; | 160 std::vector<string> retained_arguments; |
163 for (int i = 0; i < kNumHeadersInBlock; i++) { | 161 for (int i = 0; i < kNumHeadersInBlock; i++) { |
164 retained_arguments.push_back(kBaseKey + IntToString(i)); | 162 retained_arguments.push_back(kBaseKey + IntToString(i)); |
165 retained_arguments.push_back(kBaseValue + IntToString(i)); | 163 retained_arguments.push_back(kBaseValue + IntToString(i)); |
166 } | 164 } |
167 // For each block we expect to parse out the headers in order. | 165 // For each block we expect to parse out the headers in order. |
168 for (int i = 0; i < kNumHeaderBlocks; i++) { | 166 for (int i = 0; i < kNumHeaderBlocks; i++) { |
169 EXPECT_CALL(handler_, OnHeaderBlock(i, kNumHeadersInBlock)).Times(1); | 167 EXPECT_CALL(handler_, OnHeaderBlock(kNumHeadersInBlock)).Times(1); |
170 for (int j = 0; j < kNumHeadersInBlock; j++) { | 168 for (int j = 0; j < kNumHeadersInBlock; j++) { |
171 EXPECT_CALL(handler_, OnHeader( | 169 EXPECT_CALL(handler_, OnHeader( |
172 i, | |
173 StringPiece(retained_arguments[2 * j]), | 170 StringPiece(retained_arguments[2 * j]), |
174 StringPiece(retained_arguments[2 * j + 1]))).Times(1); | 171 StringPiece(retained_arguments[2 * j + 1]))).Times(1); |
175 } | 172 } |
176 EXPECT_CALL(handler_, OnHeaderBlockEnd(i, headers.length())).Times(1); | 173 EXPECT_CALL(handler_, OnHeaderBlockEnd(headers.length())).Times(1); |
177 } | 174 } |
178 // Parse the header blocks, feeding the parser one byte at a time. | 175 // Parse the header blocks, feeding the parser one byte at a time. |
179 for (int i = 0; i < kNumHeaderBlocks; i++) { | 176 for (int i = 1; i <= kNumHeaderBlocks; i++) { |
180 for (string::iterator it = headers.begin(); it != headers.end(); ++it) { | 177 for (string::iterator it = headers.begin(); it != headers.end(); ++it) { |
181 if ((it + 1) == headers.end()) { | 178 if ((it + 1) == headers.end()) { |
182 // Last byte completes the block. | 179 // Last byte completes the block. |
183 EXPECT_TRUE(parser_->HandleControlFrameHeadersData(i, &(*it), 1)); | 180 EXPECT_TRUE(parser_->HandleControlFrameHeadersData(i, &(*it), 1)); |
184 EXPECT_EQ(SpdyHeadersBlockParser::OK, parser_->get_error()); | 181 EXPECT_EQ(SpdyHeadersBlockParser::OK, parser_->get_error()); |
185 } else { | 182 } else { |
186 EXPECT_FALSE(parser_->HandleControlFrameHeadersData(i, &(*it), 1)); | 183 EXPECT_FALSE(parser_->HandleControlFrameHeadersData(i, &(*it), 1)); |
187 EXPECT_EQ(SpdyHeadersBlockParser::NEED_MORE_DATA, parser_->get_error()); | 184 EXPECT_EQ(SpdyHeadersBlockParser::NEED_MORE_DATA, parser_->get_error()); |
188 } | 185 } |
189 } | 186 } |
190 } | 187 } |
191 } | 188 } |
192 | 189 |
193 TEST_P(SpdyHeadersBlockParserTest, HandlesEmptyCallsTest) { | 190 TEST_P(SpdyHeadersBlockParserTest, HandlesEmptyCallsTest) { |
194 EXPECT_CALL(handler_, OnHeaderBlock(1, 1)).Times(1); | 191 EXPECT_CALL(handler_, OnHeaderBlock(1)).Times(1); |
195 | 192 |
196 string headers(CreateHeaders(1, false)); | 193 string headers(CreateHeaders(1, false)); |
197 | 194 |
198 string expect_key = kBaseKey + IntToString(0); | 195 string expect_key = kBaseKey + IntToString(0); |
199 string expect_value = kBaseValue + IntToString(0); | 196 string expect_value = kBaseValue + IntToString(0); |
200 EXPECT_CALL(handler_, OnHeader(1, StringPiece(expect_key), | 197 EXPECT_CALL(handler_, OnHeader(StringPiece(expect_key), |
201 StringPiece(expect_value))).Times(1); | 198 StringPiece(expect_value))).Times(1); |
202 EXPECT_CALL(handler_, OnHeaderBlockEnd(1, headers.length())).Times(1); | 199 EXPECT_CALL(handler_, OnHeaderBlockEnd(headers.length())).Times(1); |
203 | 200 |
204 // Send a header in pieces with intermediate empty calls. | 201 // Send a header in pieces with intermediate empty calls. |
205 for (string::iterator it = headers.begin(); it != headers.end(); ++it) { | 202 for (string::iterator it = headers.begin(); it != headers.end(); ++it) { |
206 if ((it + 1) == headers.end()) { | 203 if ((it + 1) == headers.end()) { |
207 // Last byte completes the block. | 204 // Last byte completes the block. |
208 EXPECT_TRUE(parser_->HandleControlFrameHeadersData(1, &(*it), 1)); | 205 EXPECT_TRUE(parser_->HandleControlFrameHeadersData(1, &(*it), 1)); |
209 EXPECT_EQ(SpdyHeadersBlockParser::OK, parser_->get_error()); | 206 EXPECT_EQ(SpdyHeadersBlockParser::OK, parser_->get_error()); |
210 } else { | 207 } else { |
211 EXPECT_FALSE(parser_->HandleControlFrameHeadersData(1, &(*it), 1)); | 208 EXPECT_FALSE(parser_->HandleControlFrameHeadersData(1, &(*it), 1)); |
212 EXPECT_EQ(SpdyHeadersBlockParser::NEED_MORE_DATA, parser_->get_error()); | 209 EXPECT_EQ(SpdyHeadersBlockParser::NEED_MORE_DATA, parser_->get_error()); |
213 EXPECT_FALSE(parser_->HandleControlFrameHeadersData(1, NULL, 0)); | 210 EXPECT_FALSE(parser_->HandleControlFrameHeadersData(1, NULL, 0)); |
214 } | 211 } |
215 } | 212 } |
216 } | 213 } |
217 | 214 |
218 TEST_P(SpdyHeadersBlockParserTest, LargeBlocksDiscardedTest) { | 215 TEST_P(SpdyHeadersBlockParserTest, LargeBlocksDiscardedTest) { |
219 // Header block with too many headers. | 216 // Header block with too many headers. |
220 { | 217 { |
221 string headers = EncodeLength( | 218 string headers = EncodeLength( |
222 parser_->MaxNumberOfHeadersForVersion(spdy_version_) + 1); | 219 parser_->MaxNumberOfHeadersForVersion(spdy_version_) + 1); |
223 EXPECT_FALSE(parser_-> | 220 EXPECT_FALSE(parser_-> |
224 HandleControlFrameHeadersData(1, headers.c_str(), headers.length())); | 221 HandleControlFrameHeadersData(1, headers.c_str(), headers.length())); |
225 EXPECT_EQ(SpdyHeadersBlockParser::HEADER_BLOCK_TOO_LARGE, | 222 EXPECT_EQ(SpdyHeadersBlockParser::HEADER_BLOCK_TOO_LARGE, |
226 parser_->get_error()); | 223 parser_->get_error()); |
227 } | 224 } |
228 parser_.reset(new SpdyHeadersBlockParser(spdy_version_, &handler_)); | 225 parser_.reset(new SpdyHeadersBlockParser(spdy_version_, &handler_)); |
229 // Header block with one header, which has a too-long key. | 226 // Header block with one header, which has a too-long key. |
230 { | 227 { |
231 EXPECT_CALL(handler_, OnHeaderBlock(1, 1)).Times(1); | 228 EXPECT_CALL(handler_, OnHeaderBlock(1)).Times(1); |
232 | 229 |
233 string headers = EncodeLength(1) + EncodeLength( | 230 string headers = EncodeLength(1) + EncodeLength( |
234 SpdyHeadersBlockParser::kMaximumFieldLength + 1); | 231 SpdyHeadersBlockParser::kMaximumFieldLength + 1); |
235 EXPECT_FALSE(parser_-> | 232 EXPECT_FALSE(parser_-> |
236 HandleControlFrameHeadersData(1, headers.c_str(), headers.length())); | 233 HandleControlFrameHeadersData(1, headers.c_str(), headers.length())); |
237 EXPECT_EQ(SpdyHeadersBlockParser::HEADER_FIELD_TOO_LARGE, | 234 EXPECT_EQ(SpdyHeadersBlockParser::HEADER_FIELD_TOO_LARGE, |
238 parser_->get_error()); | 235 parser_->get_error()); |
239 } | 236 } |
240 } | 237 } |
241 | 238 |
242 TEST_P(SpdyHeadersBlockParserTest, ExtraDataTest) { | 239 TEST_P(SpdyHeadersBlockParserTest, ExtraDataTest) { |
243 string headers = CreateHeaders(1, false) + "foobar"; | 240 string headers = CreateHeaders(1, false) + "foobar"; |
244 | 241 |
245 EXPECT_CALL(handler_, OnHeaderBlock(1, 1)).Times(1); | 242 EXPECT_CALL(handler_, OnHeaderBlock(1)).Times(1); |
246 EXPECT_CALL(handler_, OnHeaderBlockEnd(1, headers.length())).Times(1); | 243 EXPECT_CALL(handler_, OnHeaderBlockEnd(headers.length())).Times(1); |
247 | 244 |
248 string expect_key = kBaseKey + IntToString(0); | 245 string expect_key = kBaseKey + IntToString(0); |
249 string expect_value = kBaseValue + IntToString(0); | 246 string expect_value = kBaseValue + IntToString(0); |
250 EXPECT_CALL(handler_, OnHeader(1, StringPiece(expect_key), | 247 EXPECT_CALL(handler_, OnHeader(StringPiece(expect_key), |
251 StringPiece(expect_value))).Times(1); | 248 StringPiece(expect_value))).Times(1); |
252 | 249 |
253 EXPECT_FALSE(parser_-> | 250 EXPECT_FALSE(parser_->HandleControlFrameHeadersData(1, headers.c_str(), |
254 HandleControlFrameHeadersData(1, headers.c_str(), headers.length())); | 251 headers.length())); |
255 EXPECT_EQ(SpdyHeadersBlockParser::TOO_MUCH_DATA, parser_->get_error()); | 252 EXPECT_EQ(SpdyHeadersBlockParser::TOO_MUCH_DATA, parser_->get_error()); |
256 } | 253 } |
257 | 254 |
| 255 TEST_P(SpdyHeadersBlockParserTest, WrongStreamIdTest) { |
| 256 string headers(CreateHeaders(kNumHeadersInBlock, false)); |
| 257 EXPECT_FALSE(parser_->HandleControlFrameHeadersData(1, headers.data(), 1)); |
| 258 EXPECT_EQ(SpdyHeadersBlockParser::NEED_MORE_DATA, parser_->get_error()); |
| 259 bool result; |
| 260 EXPECT_DFATAL( |
| 261 result = parser_->HandleControlFrameHeadersData(2, headers.data() + 1, 1), |
| 262 "Unexpected stream id: 2 \\(expected 1\\)"); |
| 263 EXPECT_FALSE(result); |
| 264 EXPECT_EQ(SpdyHeadersBlockParser::UNEXPECTED_STREAM_ID, parser_->get_error()); |
| 265 } |
| 266 |
| 267 TEST_P(SpdyHeadersBlockParserTest, InvalidStreamIdTest) { |
| 268 string headers(CreateHeaders(kNumHeadersInBlock, false)); |
| 269 bool result; |
| 270 EXPECT_DFATAL( |
| 271 result = parser_->HandleControlFrameHeadersData(0, headers.data(), 1), |
| 272 "Expected nonzero stream id, saw: 0"); |
| 273 EXPECT_FALSE(result); |
| 274 EXPECT_EQ(SpdyHeadersBlockParser::UNEXPECTED_STREAM_ID, parser_->get_error()); |
| 275 } |
| 276 |
258 } // namespace net | 277 } // namespace net |
OLD | NEW |