| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_stream.h" | 5 #include "net/spdy/spdy_stream.h" |
| 6 | 6 |
| 7 #include <stdint.h> | 7 #include <stdint.h> |
| 8 | 8 |
| 9 #include <cstddef> | 9 #include <cstddef> |
| 10 #include <limits> | 10 #include <limits> |
| (...skipping 1263 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1274 | 1274 |
| 1275 EXPECT_TRUE(stream->GetUrlFromHeaders().is_empty()); | 1275 EXPECT_TRUE(stream->GetUrlFromHeaders().is_empty()); |
| 1276 | 1276 |
| 1277 SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl)); | 1277 SpdyHeaderBlock headers(spdy_util_.ConstructGetHeaderBlock(kDefaultUrl)); |
| 1278 EXPECT_THAT( | 1278 EXPECT_THAT( |
| 1279 stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND), | 1279 stream->SendRequestHeaders(std::move(headers), NO_MORE_DATA_TO_SEND), |
| 1280 IsError(ERR_IO_PENDING)); | 1280 IsError(ERR_IO_PENDING)); |
| 1281 EXPECT_EQ(kDefaultUrl, stream->GetUrlFromHeaders().spec()); | 1281 EXPECT_EQ(kDefaultUrl, stream->GetUrlFromHeaders().spec()); |
| 1282 | 1282 |
| 1283 int64_t reply_frame_len = reply.size(); | 1283 int64_t reply_frame_len = reply.size(); |
| 1284 int64_t data_header_len = SpdyConstants::GetDataFrameMinimumSize(HTTP2); | 1284 int64_t data_header_len = SpdyConstants::kDataFrameMinimumSize; |
| 1285 int64_t data_frame_len = data_header_len + kPostBodyLength; | 1285 int64_t data_frame_len = data_header_len + kPostBodyLength; |
| 1286 int64_t response_len = reply_frame_len + data_frame_len; | 1286 int64_t response_len = reply_frame_len + data_frame_len; |
| 1287 | 1287 |
| 1288 EXPECT_EQ(0, stream->raw_received_bytes()); | 1288 EXPECT_EQ(0, stream->raw_received_bytes()); |
| 1289 | 1289 |
| 1290 // REQUEST | 1290 // REQUEST |
| 1291 data.RunUntilPaused(); | 1291 data.RunUntilPaused(); |
| 1292 EXPECT_EQ(0, stream->raw_received_bytes()); | 1292 EXPECT_EQ(0, stream->raw_received_bytes()); |
| 1293 | 1293 |
| 1294 // REPLY | 1294 // REPLY |
| 1295 data.Resume(); | 1295 data.Resume(); |
| 1296 data.RunUntilPaused(); | 1296 data.RunUntilPaused(); |
| 1297 EXPECT_EQ(reply_frame_len, stream->raw_received_bytes()); | 1297 EXPECT_EQ(reply_frame_len, stream->raw_received_bytes()); |
| 1298 | 1298 |
| 1299 // DATA | 1299 // DATA |
| 1300 data.Resume(); | 1300 data.Resume(); |
| 1301 data.RunUntilPaused(); | 1301 data.RunUntilPaused(); |
| 1302 EXPECT_EQ(response_len, stream->raw_received_bytes()); | 1302 EXPECT_EQ(response_len, stream->raw_received_bytes()); |
| 1303 | 1303 |
| 1304 // FIN | 1304 // FIN |
| 1305 data.Resume(); | 1305 data.Resume(); |
| 1306 EXPECT_THAT(delegate.WaitForClose(), IsError(ERR_CONNECTION_CLOSED)); | 1306 EXPECT_THAT(delegate.WaitForClose(), IsError(ERR_CONNECTION_CLOSED)); |
| 1307 } | 1307 } |
| 1308 | 1308 |
| 1309 } // namespace test | 1309 } // namespace test |
| 1310 | 1310 |
| 1311 } // namespace net | 1311 } // namespace net |
| OLD | NEW |