| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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/bidirectional_stream_spdy_impl.h" | 5 #include "net/spdy/bidirectional_stream_spdy_impl.h" |
| 6 | 6 |
| 7 #include <memory> | 7 #include <memory> |
| 8 #include <string> | 8 #include <string> |
| 9 | 9 |
| 10 #include "base/macros.h" | 10 #include "base/macros.h" |
| (...skipping 247 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 258 kDefaultUrl, 1, kBodyDataSize * 3, LOW, nullptr, 0)); | 258 kDefaultUrl, 1, kBodyDataSize * 3, LOW, nullptr, 0)); |
| 259 SpdySerializedFrame rst( | 259 SpdySerializedFrame rst( |
| 260 spdy_util_.ConstructSpdyRstStream(1, RST_STREAM_PROTOCOL_ERROR)); | 260 spdy_util_.ConstructSpdyRstStream(1, RST_STREAM_PROTOCOL_ERROR)); |
| 261 | 261 |
| 262 MockWrite writes[] = { | 262 MockWrite writes[] = { |
| 263 CreateMockWrite(req, 0), CreateMockWrite(rst, 2), | 263 CreateMockWrite(req, 0), CreateMockWrite(rst, 2), |
| 264 }; | 264 }; |
| 265 | 265 |
| 266 const char* const kExtraHeaders[] = {"X-UpperCase", "yes"}; | 266 const char* const kExtraHeaders[] = {"X-UpperCase", "yes"}; |
| 267 SpdySerializedFrame resp( | 267 SpdySerializedFrame resp( |
| 268 spdy_util_.ConstructSpdyGetSynReply(kExtraHeaders, 1, 1)); | 268 spdy_util_.ConstructSpdyGetReply(kExtraHeaders, 1, 1)); |
| 269 | 269 |
| 270 MockRead reads[] = { | 270 MockRead reads[] = { |
| 271 CreateMockRead(resp, 1), MockRead(ASYNC, 0, 3), | 271 CreateMockRead(resp, 1), MockRead(ASYNC, 0, 3), |
| 272 }; | 272 }; |
| 273 | 273 |
| 274 InitSession(reads, arraysize(reads), writes, arraysize(writes)); | 274 InitSession(reads, arraysize(reads), writes, arraysize(writes)); |
| 275 | 275 |
| 276 BidirectionalStreamRequestInfo request_info; | 276 BidirectionalStreamRequestInfo request_info; |
| 277 request_info.method = "POST"; | 277 request_info.method = "POST"; |
| 278 request_info.url = default_url_; | 278 request_info.url = default_url_; |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 311 spdy_util_.ConstructSpdyDataFrame(1, kBodyData, kBodyDataSize, | 311 spdy_util_.ConstructSpdyDataFrame(1, kBodyData, kBodyDataSize, |
| 312 /*fin=*/false)); | 312 /*fin=*/false)); |
| 313 SpdySerializedFrame rst( | 313 SpdySerializedFrame rst( |
| 314 spdy_util_.ConstructSpdyRstStream(1, RST_STREAM_CANCEL)); | 314 spdy_util_.ConstructSpdyRstStream(1, RST_STREAM_CANCEL)); |
| 315 | 315 |
| 316 MockWrite writes[] = { | 316 MockWrite writes[] = { |
| 317 CreateMockWrite(req, 0), CreateMockWrite(data_frame, 3), | 317 CreateMockWrite(req, 0), CreateMockWrite(data_frame, 3), |
| 318 CreateMockWrite(rst, 5), | 318 CreateMockWrite(rst, 5), |
| 319 }; | 319 }; |
| 320 | 320 |
| 321 SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetSynReply(nullptr, 0, 1)); | 321 SpdySerializedFrame resp(spdy_util_.ConstructSpdyGetReply(nullptr, 0, 1)); |
| 322 SpdySerializedFrame response_body_frame( | 322 SpdySerializedFrame response_body_frame( |
| 323 spdy_util_.ConstructSpdyDataFrame(1, false)); | 323 spdy_util_.ConstructSpdyDataFrame(1, false)); |
| 324 | 324 |
| 325 MockRead reads[] = { | 325 MockRead reads[] = { |
| 326 CreateMockRead(resp, 1), | 326 CreateMockRead(resp, 1), |
| 327 MockRead(ASYNC, ERR_IO_PENDING, 2), // Force a pause. | 327 MockRead(ASYNC, ERR_IO_PENDING, 2), // Force a pause. |
| 328 MockRead(ASYNC, ERR_IO_PENDING, 4), // Force a pause. | 328 MockRead(ASYNC, ERR_IO_PENDING, 4), // Force a pause. |
| 329 MockRead(ASYNC, 0, 6), | 329 MockRead(ASYNC, 0, 6), |
| 330 }; | 330 }; |
| 331 | 331 |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 364 EXPECT_FALSE(delegate->on_failed_called()); | 364 EXPECT_FALSE(delegate->on_failed_called()); |
| 365 | 365 |
| 366 EXPECT_EQ("200", delegate->response_headers().find(":status")->second); | 366 EXPECT_EQ("200", delegate->response_headers().find(":status")->second); |
| 367 EXPECT_EQ(0, delegate->on_data_read_count()); | 367 EXPECT_EQ(0, delegate->on_data_read_count()); |
| 368 EXPECT_EQ(kProtoHTTP2, delegate->GetProtocol()); | 368 EXPECT_EQ(kProtoHTTP2, delegate->GetProtocol()); |
| 369 EXPECT_EQ(0, delegate->GetTotalSentBytes()); | 369 EXPECT_EQ(0, delegate->GetTotalSentBytes()); |
| 370 EXPECT_EQ(0, delegate->GetTotalReceivedBytes()); | 370 EXPECT_EQ(0, delegate->GetTotalReceivedBytes()); |
| 371 } | 371 } |
| 372 | 372 |
| 373 } // namespace net | 373 } // namespace net |
| OLD | NEW |