OLD | NEW |
---|---|
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 <string> | 5 #include <string> |
6 #include <vector> | 6 #include <vector> |
7 | 7 |
8 #include "base/bind.h" | 8 #include "base/bind.h" |
9 #include "base/bind_helpers.h" | 9 #include "base/bind_helpers.h" |
10 #include "base/files/file_util.h" | 10 #include "base/files/file_util.h" |
11 #include "base/files/scoped_temp_dir.h" | 11 #include "base/files/scoped_temp_dir.h" |
12 #include "base/memory/scoped_vector.h" | |
13 #include "base/run_loop.h" | 12 #include "base/run_loop.h" |
14 #include "base/stl_util.h" | 13 #include "base/stl_util.h" |
15 #include "base/strings/string_piece.h" | 14 #include "base/strings/string_piece.h" |
16 #include "base/test/test_file_util.h" | 15 #include "base/test/test_file_util.h" |
17 #include "base/thread_task_runner_handle.h" | 16 #include "base/thread_task_runner_handle.h" |
18 #include "net/base/auth.h" | 17 #include "net/base/auth.h" |
19 #include "net/base/chunked_upload_data_stream.h" | 18 #include "net/base/chunked_upload_data_stream.h" |
20 #include "net/base/elements_upload_data_stream.h" | 19 #include "net/base/elements_upload_data_stream.h" |
21 #include "net/base/request_priority.h" | 20 #include "net/base/request_priority.h" |
22 #include "net/base/test_data_directory.h" | 21 #include "net/base/test_data_directory.h" |
(...skipping 430 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
453 get_request_.url = GURL(GetDefaultUrl()); | 452 get_request_.url = GURL(GetDefaultUrl()); |
454 get_request_.load_flags = 0; | 453 get_request_.load_flags = 0; |
455 get_request_.extra_headers.SetHeader("User-Agent", "Chrome"); | 454 get_request_.extra_headers.SetHeader("User-Agent", "Chrome"); |
456 get_request_initialized_ = true; | 455 get_request_initialized_ = true; |
457 } | 456 } |
458 return get_request_; | 457 return get_request_; |
459 } | 458 } |
460 | 459 |
461 const HttpRequestInfo& CreatePostRequest() { | 460 const HttpRequestInfo& CreatePostRequest() { |
462 if (!post_request_initialized_) { | 461 if (!post_request_initialized_) { |
463 ScopedVector<UploadElementReader> element_readers; | 462 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
mmenke
2015/11/24 17:25:08
include scoped_ptr
| |
464 element_readers.push_back( | 463 element_readers.push_back(make_scoped_ptr( |
465 new UploadBytesElementReader(kUploadData, kUploadDataSize)); | 464 new UploadBytesElementReader(kUploadData, kUploadDataSize))); |
466 upload_data_stream_.reset( | 465 upload_data_stream_.reset( |
467 new ElementsUploadDataStream(element_readers.Pass(), 0)); | 466 new ElementsUploadDataStream(std::move(element_readers), 0)); |
468 | 467 |
469 post_request_.method = "POST"; | 468 post_request_.method = "POST"; |
470 post_request_.url = GURL(GetDefaultUrl()); | 469 post_request_.url = GURL(GetDefaultUrl()); |
471 post_request_.upload_data_stream = upload_data_stream_.get(); | 470 post_request_.upload_data_stream = upload_data_stream_.get(); |
472 post_request_initialized_ = true; | 471 post_request_initialized_ = true; |
473 } | 472 } |
474 return post_request_; | 473 return post_request_; |
475 } | 474 } |
476 | 475 |
477 const HttpRequestInfo& CreateFilePostRequest() { | 476 const HttpRequestInfo& CreateFilePostRequest() { |
478 if (!post_request_initialized_) { | 477 if (!post_request_initialized_) { |
479 base::FilePath file_path; | 478 base::FilePath file_path; |
480 CHECK(base::CreateTemporaryFileInDir(temp_dir_.path(), &file_path)); | 479 CHECK(base::CreateTemporaryFileInDir(temp_dir_.path(), &file_path)); |
481 CHECK_EQ(static_cast<int>(kUploadDataSize), | 480 CHECK_EQ(static_cast<int>(kUploadDataSize), |
482 base::WriteFile(file_path, kUploadData, kUploadDataSize)); | 481 base::WriteFile(file_path, kUploadData, kUploadDataSize)); |
483 | 482 |
484 ScopedVector<UploadElementReader> element_readers; | 483 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
485 element_readers.push_back(new UploadFileElementReader( | 484 element_readers.push_back(make_scoped_ptr(new UploadFileElementReader( |
486 base::ThreadTaskRunnerHandle::Get().get(), file_path, 0, | 485 base::ThreadTaskRunnerHandle::Get().get(), file_path, 0, |
487 kUploadDataSize, base::Time())); | 486 kUploadDataSize, base::Time()))); |
488 upload_data_stream_.reset( | 487 upload_data_stream_.reset( |
489 new ElementsUploadDataStream(element_readers.Pass(), 0)); | 488 new ElementsUploadDataStream(std::move(element_readers), 0)); |
490 | 489 |
491 post_request_.method = "POST"; | 490 post_request_.method = "POST"; |
492 post_request_.url = GURL(GetDefaultUrl()); | 491 post_request_.url = GURL(GetDefaultUrl()); |
493 post_request_.upload_data_stream = upload_data_stream_.get(); | 492 post_request_.upload_data_stream = upload_data_stream_.get(); |
494 post_request_initialized_ = true; | 493 post_request_initialized_ = true; |
495 } | 494 } |
496 return post_request_; | 495 return post_request_; |
497 } | 496 } |
498 | 497 |
499 const HttpRequestInfo& CreateUnreadableFilePostRequest() { | 498 const HttpRequestInfo& CreateUnreadableFilePostRequest() { |
500 if (post_request_initialized_) | 499 if (post_request_initialized_) |
501 return post_request_; | 500 return post_request_; |
502 | 501 |
503 base::FilePath file_path; | 502 base::FilePath file_path; |
504 CHECK(base::CreateTemporaryFileInDir(temp_dir_.path(), &file_path)); | 503 CHECK(base::CreateTemporaryFileInDir(temp_dir_.path(), &file_path)); |
505 CHECK_EQ(static_cast<int>(kUploadDataSize), | 504 CHECK_EQ(static_cast<int>(kUploadDataSize), |
506 base::WriteFile(file_path, kUploadData, kUploadDataSize)); | 505 base::WriteFile(file_path, kUploadData, kUploadDataSize)); |
507 CHECK(base::MakeFileUnreadable(file_path)); | 506 CHECK(base::MakeFileUnreadable(file_path)); |
508 | 507 |
509 ScopedVector<UploadElementReader> element_readers; | 508 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
510 element_readers.push_back(new UploadFileElementReader( | 509 element_readers.push_back(make_scoped_ptr(new UploadFileElementReader( |
511 base::ThreadTaskRunnerHandle::Get().get(), file_path, 0, | 510 base::ThreadTaskRunnerHandle::Get().get(), file_path, 0, |
512 kUploadDataSize, base::Time())); | 511 kUploadDataSize, base::Time()))); |
513 upload_data_stream_.reset( | 512 upload_data_stream_.reset( |
514 new ElementsUploadDataStream(element_readers.Pass(), 0)); | 513 new ElementsUploadDataStream(std::move(element_readers), 0)); |
515 | 514 |
516 post_request_.method = "POST"; | 515 post_request_.method = "POST"; |
517 post_request_.url = GURL(GetDefaultUrl()); | 516 post_request_.url = GURL(GetDefaultUrl()); |
518 post_request_.upload_data_stream = upload_data_stream_.get(); | 517 post_request_.upload_data_stream = upload_data_stream_.get(); |
519 post_request_initialized_ = true; | 518 post_request_initialized_ = true; |
520 return post_request_; | 519 return post_request_; |
521 } | 520 } |
522 | 521 |
523 const HttpRequestInfo& CreateComplexPostRequest() { | 522 const HttpRequestInfo& CreateComplexPostRequest() { |
524 if (!post_request_initialized_) { | 523 if (!post_request_initialized_) { |
525 const int kFileRangeOffset = 1; | 524 const int kFileRangeOffset = 1; |
526 const int kFileRangeLength = 3; | 525 const int kFileRangeLength = 3; |
527 CHECK_LT(kFileRangeOffset + kFileRangeLength, kUploadDataSize); | 526 CHECK_LT(kFileRangeOffset + kFileRangeLength, kUploadDataSize); |
528 | 527 |
529 base::FilePath file_path; | 528 base::FilePath file_path; |
530 CHECK(base::CreateTemporaryFileInDir(temp_dir_.path(), &file_path)); | 529 CHECK(base::CreateTemporaryFileInDir(temp_dir_.path(), &file_path)); |
531 CHECK_EQ(static_cast<int>(kUploadDataSize), | 530 CHECK_EQ(static_cast<int>(kUploadDataSize), |
532 base::WriteFile(file_path, kUploadData, kUploadDataSize)); | 531 base::WriteFile(file_path, kUploadData, kUploadDataSize)); |
533 | 532 |
534 ScopedVector<UploadElementReader> element_readers; | 533 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
535 element_readers.push_back( | 534 element_readers.push_back(make_scoped_ptr( |
536 new UploadBytesElementReader(kUploadData, kFileRangeOffset)); | 535 new UploadBytesElementReader(kUploadData, kFileRangeOffset))); |
537 element_readers.push_back(new UploadFileElementReader( | 536 element_readers.push_back(make_scoped_ptr(new UploadFileElementReader( |
538 base::ThreadTaskRunnerHandle::Get().get(), file_path, | 537 base::ThreadTaskRunnerHandle::Get().get(), file_path, |
539 kFileRangeOffset, kFileRangeLength, base::Time())); | 538 kFileRangeOffset, kFileRangeLength, base::Time()))); |
540 element_readers.push_back(new UploadBytesElementReader( | 539 element_readers.push_back(make_scoped_ptr(new UploadBytesElementReader( |
541 kUploadData + kFileRangeOffset + kFileRangeLength, | 540 kUploadData + kFileRangeOffset + kFileRangeLength, |
542 kUploadDataSize - (kFileRangeOffset + kFileRangeLength))); | 541 kUploadDataSize - (kFileRangeOffset + kFileRangeLength)))); |
543 upload_data_stream_.reset( | 542 upload_data_stream_.reset( |
544 new ElementsUploadDataStream(element_readers.Pass(), 0)); | 543 new ElementsUploadDataStream(std::move(element_readers), 0)); |
545 | 544 |
546 post_request_.method = "POST"; | 545 post_request_.method = "POST"; |
547 post_request_.url = GURL(GetDefaultUrl()); | 546 post_request_.url = GURL(GetDefaultUrl()); |
548 post_request_.upload_data_stream = upload_data_stream_.get(); | 547 post_request_.upload_data_stream = upload_data_stream_.get(); |
549 post_request_initialized_ = true; | 548 post_request_initialized_ = true; |
550 } | 549 } |
551 return post_request_; | 550 return post_request_; |
552 } | 551 } |
553 | 552 |
554 const HttpRequestInfo& CreateChunkedPostRequest() { | 553 const HttpRequestInfo& CreateChunkedPostRequest() { |
(...skipping 1386 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
1941 TransactionHelperResult out = helper.output(); | 1940 TransactionHelperResult out = helper.output(); |
1942 EXPECT_EQ(OK, out.rv); | 1941 EXPECT_EQ(OK, out.rv); |
1943 EXPECT_EQ("HTTP/1.1 200 OK", out.status_line); | 1942 EXPECT_EQ("HTTP/1.1 200 OK", out.status_line); |
1944 EXPECT_EQ("hello!", out.response_data); | 1943 EXPECT_EQ("hello!", out.response_data); |
1945 } | 1944 } |
1946 | 1945 |
1947 // Test that a simple POST works. | 1946 // Test that a simple POST works. |
1948 TEST_P(SpdyNetworkTransactionTest, EmptyPost) { | 1947 TEST_P(SpdyNetworkTransactionTest, EmptyPost) { |
1949 BufferedSpdyFramer framer(spdy_util_.spdy_version(), false); | 1948 BufferedSpdyFramer framer(spdy_util_.spdy_version(), false); |
1950 // Create an empty UploadDataStream. | 1949 // Create an empty UploadDataStream. |
1951 ScopedVector<UploadElementReader> element_readers; | 1950 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
1952 ElementsUploadDataStream stream(element_readers.Pass(), 0); | 1951 ElementsUploadDataStream stream(std::move(element_readers), 0); |
1953 | 1952 |
1954 // Setup the request | 1953 // Setup the request |
1955 HttpRequestInfo request; | 1954 HttpRequestInfo request; |
1956 request.method = "POST"; | 1955 request.method = "POST"; |
1957 request.url = GURL(GetDefaultUrl()); | 1956 request.url = GURL(GetDefaultUrl()); |
1958 request.upload_data_stream = &stream; | 1957 request.upload_data_stream = &stream; |
1959 | 1958 |
1960 const uint64 kContentLength = 0; | 1959 const uint64 kContentLength = 0; |
1961 | 1960 |
1962 scoped_ptr<SpdyHeaderBlock> req_block( | 1961 scoped_ptr<SpdyHeaderBlock> req_block( |
(...skipping 3875 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
5838 CreateMockRead(*window_update, 8), // kDeltaWindowSize * 4 | 5837 CreateMockRead(*window_update, 8), // kDeltaWindowSize * 4 |
5839 CreateMockRead(*window_update, 9), | 5838 CreateMockRead(*window_update, 9), |
5840 CreateMockRead(*resp, 10), | 5839 CreateMockRead(*resp, 10), |
5841 CreateMockRead(*body_end, 11), | 5840 CreateMockRead(*body_end, 11), |
5842 MockRead(ASYNC, 0, 0, 12) // EOF | 5841 MockRead(ASYNC, 0, 0, 12) // EOF |
5843 }; | 5842 }; |
5844 | 5843 |
5845 DeterministicSocketData data(reads, arraysize(reads), | 5844 DeterministicSocketData data(reads, arraysize(reads), |
5846 writes, arraysize(writes)); | 5845 writes, arraysize(writes)); |
5847 | 5846 |
5848 ScopedVector<UploadElementReader> element_readers; | 5847 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
5849 for (int i = 0; i < kFrameCount; ++i) { | 5848 for (int i = 0; i < kFrameCount; ++i) { |
5850 element_readers.push_back( | 5849 element_readers.push_back(make_scoped_ptr( |
5851 new UploadBytesElementReader(content->c_str(), content->size())); | 5850 new UploadBytesElementReader(content->c_str(), content->size()))); |
5852 } | 5851 } |
5853 ElementsUploadDataStream upload_data_stream(element_readers.Pass(), 0); | 5852 ElementsUploadDataStream upload_data_stream(std::move(element_readers), 0); |
5854 | 5853 |
5855 // Setup the request | 5854 // Setup the request |
5856 HttpRequestInfo request; | 5855 HttpRequestInfo request; |
5857 request.method = "POST"; | 5856 request.method = "POST"; |
5858 request.url = GURL(GetDefaultUrl()); | 5857 request.url = GURL(GetDefaultUrl()); |
5859 request.upload_data_stream = &upload_data_stream; | 5858 request.upload_data_stream = &upload_data_stream; |
5860 | 5859 |
5861 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, | 5860 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, |
5862 BoundNetLog(), GetParam(), NULL); | 5861 BoundNetLog(), GetParam(), NULL); |
5863 helper.SetDeterministic(); | 5862 helper.SetDeterministic(); |
(...skipping 188 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
6052 scoped_ptr<SpdyFrame> window_update( | 6051 scoped_ptr<SpdyFrame> window_update( |
6053 spdy_util_.ConstructSpdyWindowUpdate(1, kDeltaWindowSize)); | 6052 spdy_util_.ConstructSpdyWindowUpdate(1, kDeltaWindowSize)); |
6054 MockRead reads[] = { | 6053 MockRead reads[] = { |
6055 CreateMockRead(*window_update, 1), | 6054 CreateMockRead(*window_update, 1), |
6056 MockRead(ASYNC, 0, 4) // EOF | 6055 MockRead(ASYNC, 0, 4) // EOF |
6057 }; | 6056 }; |
6058 | 6057 |
6059 DeterministicSocketData data(reads, arraysize(reads), | 6058 DeterministicSocketData data(reads, arraysize(reads), |
6060 writes, arraysize(writes)); | 6059 writes, arraysize(writes)); |
6061 | 6060 |
6062 ScopedVector<UploadElementReader> element_readers; | 6061 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
6063 for (int i = 0; i < kFrameCount; ++i) { | 6062 for (int i = 0; i < kFrameCount; ++i) { |
6064 element_readers.push_back( | 6063 element_readers.push_back(make_scoped_ptr( |
6065 new UploadBytesElementReader(content->c_str(), content->size())); | 6064 new UploadBytesElementReader(content->c_str(), content->size()))); |
6066 } | 6065 } |
6067 ElementsUploadDataStream upload_data_stream(element_readers.Pass(), 0); | 6066 ElementsUploadDataStream upload_data_stream(std::move(element_readers), 0); |
6068 | 6067 |
6069 // Setup the request | 6068 // Setup the request |
6070 HttpRequestInfo request; | 6069 HttpRequestInfo request; |
6071 request.method = "POST"; | 6070 request.method = "POST"; |
6072 request.url = GURL(GetDefaultUrl()); | 6071 request.url = GURL(GetDefaultUrl()); |
6073 request.upload_data_stream = &upload_data_stream; | 6072 request.upload_data_stream = &upload_data_stream; |
6074 | 6073 |
6075 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, | 6074 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, |
6076 BoundNetLog(), GetParam(), NULL); | 6075 BoundNetLog(), GetParam(), NULL); |
6077 helper.SetDeterministic(); | 6076 helper.SetDeterministic(); |
(...skipping 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
6160 CreateMockRead(*window_update, i + 3), | 6159 CreateMockRead(*window_update, i + 3), |
6161 // Now the last write will occur. | 6160 // Now the last write will occur. |
6162 CreateMockRead(*reply, i + 5), | 6161 CreateMockRead(*reply, i + 5), |
6163 CreateMockRead(*body2, i + 6), | 6162 CreateMockRead(*body2, i + 6), |
6164 CreateMockRead(*body3, i + 7), | 6163 CreateMockRead(*body3, i + 7), |
6165 MockRead(ASYNC, 0, i + 8) // EOF | 6164 MockRead(ASYNC, 0, i + 8) // EOF |
6166 }; | 6165 }; |
6167 | 6166 |
6168 SequencedSocketData data(reads, arraysize(reads), writes.get(), num_writes); | 6167 SequencedSocketData data(reads, arraysize(reads), writes.get(), num_writes); |
6169 | 6168 |
6170 ScopedVector<UploadElementReader> element_readers; | 6169 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
6171 std::string upload_data_string(initial_window_size, 'a'); | 6170 std::string upload_data_string(initial_window_size, 'a'); |
6172 upload_data_string.append(kUploadData, kUploadDataSize); | 6171 upload_data_string.append(kUploadData, kUploadDataSize); |
6173 element_readers.push_back(new UploadBytesElementReader( | 6172 element_readers.push_back(make_scoped_ptr(new UploadBytesElementReader( |
6174 upload_data_string.c_str(), upload_data_string.size())); | 6173 upload_data_string.c_str(), upload_data_string.size()))); |
6175 ElementsUploadDataStream upload_data_stream(element_readers.Pass(), 0); | 6174 ElementsUploadDataStream upload_data_stream(std::move(element_readers), 0); |
6176 | 6175 |
6177 HttpRequestInfo request; | 6176 HttpRequestInfo request; |
6178 request.method = "POST"; | 6177 request.method = "POST"; |
6179 request.url = GURL(GetDefaultUrl()); | 6178 request.url = GURL(GetDefaultUrl()); |
6180 request.upload_data_stream = &upload_data_stream; | 6179 request.upload_data_stream = &upload_data_stream; |
6181 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, | 6180 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, |
6182 BoundNetLog(), GetParam(), NULL); | 6181 BoundNetLog(), GetParam(), NULL); |
6183 helper.AddData(&data); | 6182 helper.AddData(&data); |
6184 helper.RunPreTestSetup(); | 6183 helper.RunPreTestSetup(); |
6185 | 6184 |
(...skipping 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
6275 reads.push_back(CreateMockRead(*reply, i++)); | 6274 reads.push_back(CreateMockRead(*reply, i++)); |
6276 reads.push_back(CreateMockRead(*body2, i++)); | 6275 reads.push_back(CreateMockRead(*body2, i++)); |
6277 reads.push_back(CreateMockRead(*body3, i++)); | 6276 reads.push_back(CreateMockRead(*body3, i++)); |
6278 reads.push_back(MockRead(ASYNC, 0, i++)); // EOF | 6277 reads.push_back(MockRead(ASYNC, 0, i++)); // EOF |
6279 | 6278 |
6280 // Force all writes to happen before any read, last write will not | 6279 // Force all writes to happen before any read, last write will not |
6281 // actually queue a frame, due to window size being 0. | 6280 // actually queue a frame, due to window size being 0. |
6282 DeterministicSocketData data(vector_as_array(&reads), reads.size(), | 6281 DeterministicSocketData data(vector_as_array(&reads), reads.size(), |
6283 vector_as_array(&writes), writes.size()); | 6282 vector_as_array(&writes), writes.size()); |
6284 | 6283 |
6285 ScopedVector<UploadElementReader> element_readers; | 6284 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
6286 std::string upload_data_string(initial_window_size, 'a'); | 6285 std::string upload_data_string(initial_window_size, 'a'); |
6287 upload_data_string.append(kUploadData, kUploadDataSize); | 6286 upload_data_string.append(kUploadData, kUploadDataSize); |
6288 element_readers.push_back(new UploadBytesElementReader( | 6287 element_readers.push_back(make_scoped_ptr(new UploadBytesElementReader( |
6289 upload_data_string.c_str(), upload_data_string.size())); | 6288 upload_data_string.c_str(), upload_data_string.size()))); |
6290 ElementsUploadDataStream upload_data_stream(element_readers.Pass(), 0); | 6289 ElementsUploadDataStream upload_data_stream(std::move(element_readers), 0); |
6291 | 6290 |
6292 HttpRequestInfo request; | 6291 HttpRequestInfo request; |
6293 request.method = "POST"; | 6292 request.method = "POST"; |
6294 request.url = GURL(GetDefaultUrl()); | 6293 request.url = GURL(GetDefaultUrl()); |
6295 request.upload_data_stream = &upload_data_stream; | 6294 request.upload_data_stream = &upload_data_stream; |
6296 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, | 6295 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, |
6297 BoundNetLog(), GetParam(), NULL); | 6296 BoundNetLog(), GetParam(), NULL); |
6298 helper.SetDeterministic(); | 6297 helper.SetDeterministic(); |
6299 helper.RunPreTestSetup(); | 6298 helper.RunPreTestSetup(); |
6300 helper.AddDeterministicData(&data); | 6299 helper.AddDeterministicData(&data); |
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
6396 reads.push_back(CreateMockRead(*reply, i++)); | 6395 reads.push_back(CreateMockRead(*reply, i++)); |
6397 reads.push_back(CreateMockRead(*body2, i++)); | 6396 reads.push_back(CreateMockRead(*body2, i++)); |
6398 reads.push_back(CreateMockRead(*body3, i++)); | 6397 reads.push_back(CreateMockRead(*body3, i++)); |
6399 reads.push_back(MockRead(ASYNC, 0, i++)); // EOF | 6398 reads.push_back(MockRead(ASYNC, 0, i++)); // EOF |
6400 | 6399 |
6401 // Force all writes to happen before any read, last write will not | 6400 // Force all writes to happen before any read, last write will not |
6402 // actually queue a frame, due to window size being 0. | 6401 // actually queue a frame, due to window size being 0. |
6403 DeterministicSocketData data(vector_as_array(&reads), reads.size(), | 6402 DeterministicSocketData data(vector_as_array(&reads), reads.size(), |
6404 vector_as_array(&writes), writes.size()); | 6403 vector_as_array(&writes), writes.size()); |
6405 | 6404 |
6406 ScopedVector<UploadElementReader> element_readers; | 6405 std::vector<scoped_ptr<UploadElementReader>> element_readers; |
6407 std::string upload_data_string(initial_window_size, 'a'); | 6406 std::string upload_data_string(initial_window_size, 'a'); |
6408 upload_data_string.append(kUploadData, kUploadDataSize); | 6407 upload_data_string.append(kUploadData, kUploadDataSize); |
6409 element_readers.push_back(new UploadBytesElementReader( | 6408 element_readers.push_back(make_scoped_ptr(new UploadBytesElementReader( |
6410 upload_data_string.c_str(), upload_data_string.size())); | 6409 upload_data_string.c_str(), upload_data_string.size()))); |
6411 ElementsUploadDataStream upload_data_stream(element_readers.Pass(), 0); | 6410 ElementsUploadDataStream upload_data_stream(std::move(element_readers), 0); |
6412 | 6411 |
6413 HttpRequestInfo request; | 6412 HttpRequestInfo request; |
6414 request.method = "POST"; | 6413 request.method = "POST"; |
6415 request.url = GURL(GetDefaultUrl()); | 6414 request.url = GURL(GetDefaultUrl()); |
6416 request.upload_data_stream = &upload_data_stream; | 6415 request.upload_data_stream = &upload_data_stream; |
6417 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, | 6416 NormalSpdyTransactionHelper helper(request, DEFAULT_PRIORITY, |
6418 BoundNetLog(), GetParam(), NULL); | 6417 BoundNetLog(), GetParam(), NULL); |
6419 helper.SetDeterministic(); | 6418 helper.SetDeterministic(); |
6420 helper.RunPreTestSetup(); | 6419 helper.RunPreTestSetup(); |
6421 helper.AddDeterministicData(&data); | 6420 helper.AddDeterministicData(&data); |
(...skipping 231 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
6653 TEST_P(SpdyNetworkTransactionTLSUsageCheckTest, TLSCipherSuiteSucky) { | 6652 TEST_P(SpdyNetworkTransactionTLSUsageCheckTest, TLSCipherSuiteSucky) { |
6654 scoped_ptr<SSLSocketDataProvider> ssl_provider( | 6653 scoped_ptr<SSLSocketDataProvider> ssl_provider( |
6655 new SSLSocketDataProvider(ASYNC, OK)); | 6654 new SSLSocketDataProvider(ASYNC, OK)); |
6656 // Set to TLS_RSA_WITH_NULL_MD5 | 6655 // Set to TLS_RSA_WITH_NULL_MD5 |
6657 SSLConnectionStatusSetCipherSuite(0x1, &ssl_provider->connection_status); | 6656 SSLConnectionStatusSetCipherSuite(0x1, &ssl_provider->connection_status); |
6658 | 6657 |
6659 RunTLSUsageCheckTest(ssl_provider.Pass()); | 6658 RunTLSUsageCheckTest(ssl_provider.Pass()); |
6660 } | 6659 } |
6661 | 6660 |
6662 } // namespace net | 6661 } // namespace net |
OLD | NEW |