Chromium Code Reviews| 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 |