| 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 <memory> | 5 #include <memory> |
| 6 #include <ostream> | 6 #include <ostream> |
| 7 #include <utility> | 7 #include <utility> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
| (...skipping 15 matching lines...) Expand all Loading... |
| 26 #include "net/http/http_network_transaction.h" | 26 #include "net/http/http_network_transaction.h" |
| 27 #include "net/http/http_server_properties_impl.h" | 27 #include "net/http/http_server_properties_impl.h" |
| 28 #include "net/http/http_transaction_test_util.h" | 28 #include "net/http/http_transaction_test_util.h" |
| 29 #include "net/http/transport_security_state.h" | 29 #include "net/http/transport_security_state.h" |
| 30 #include "net/proxy/proxy_service.h" | 30 #include "net/proxy/proxy_service.h" |
| 31 #include "net/quic/test_tools/crypto_test_utils.h" | 31 #include "net/quic/test_tools/crypto_test_utils.h" |
| 32 #include "net/quic/test_tools/quic_test_utils.h" | 32 #include "net/quic/test_tools/quic_test_utils.h" |
| 33 #include "net/ssl/default_channel_id_store.h" | 33 #include "net/ssl/default_channel_id_store.h" |
| 34 #include "net/ssl/ssl_config_service_defaults.h" | 34 #include "net/ssl/ssl_config_service_defaults.h" |
| 35 #include "net/test/cert_test_util.h" | 35 #include "net/test/cert_test_util.h" |
| 36 #include "net/test/gtest_util.h" |
| 36 #include "net/test/test_data_directory.h" | 37 #include "net/test/test_data_directory.h" |
| 37 #include "net/tools/quic/quic_in_memory_cache.h" | 38 #include "net/tools/quic/quic_in_memory_cache.h" |
| 38 #include "net/tools/quic/quic_server.h" | 39 #include "net/tools/quic/quic_server.h" |
| 39 #include "net/tools/quic/test_tools/quic_in_memory_cache_peer.h" | 40 #include "net/tools/quic/test_tools/quic_in_memory_cache_peer.h" |
| 40 #include "net/tools/quic/test_tools/server_thread.h" | 41 #include "net/tools/quic/test_tools/server_thread.h" |
| 42 #include "testing/gmock/include/gmock/gmock.h" |
| 41 #include "testing/gtest/include/gtest/gtest.h" | 43 #include "testing/gtest/include/gtest/gtest.h" |
| 42 #include "testing/platform_test.h" | 44 #include "testing/platform_test.h" |
| 43 | 45 |
| 44 using base::StringPiece; | 46 using base::StringPiece; |
| 45 | 47 |
| 46 namespace net { | 48 namespace net { |
| 47 | 49 |
| 50 using test::IsOk; |
| 48 using test::QuicInMemoryCachePeer; | 51 using test::QuicInMemoryCachePeer; |
| 49 using test::ServerThread; | 52 using test::ServerThread; |
| 50 | 53 |
| 51 namespace test { | 54 namespace test { |
| 52 | 55 |
| 53 namespace { | 56 namespace { |
| 54 | 57 |
| 55 const char kResponseBody[] = "some arbitrary response body"; | 58 const char kResponseBody[] = "some arbitrary response body"; |
| 56 | 59 |
| 57 // Factory for creating HttpTransactions, used by TestTransactionConsumer. | 60 // Factory for creating HttpTransactions, used by TestTransactionConsumer. |
| (...skipping 169 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 227 void InitializePostRequest(size_t length) { | 230 void InitializePostRequest(size_t length) { |
| 228 GenerateBody(length); | 231 GenerateBody(length); |
| 229 std::vector<std::unique_ptr<UploadElementReader>> element_readers; | 232 std::vector<std::unique_ptr<UploadElementReader>> element_readers; |
| 230 element_readers.push_back(base::WrapUnique(new UploadBytesElementReader( | 233 element_readers.push_back(base::WrapUnique(new UploadBytesElementReader( |
| 231 request_body_.data(), request_body_.length()))); | 234 request_body_.data(), request_body_.length()))); |
| 232 upload_data_stream_.reset( | 235 upload_data_stream_.reset( |
| 233 new ElementsUploadDataStream(std::move(element_readers), 0)); | 236 new ElementsUploadDataStream(std::move(element_readers), 0)); |
| 234 request_.method = "POST"; | 237 request_.method = "POST"; |
| 235 request_.url = GURL("https://test.example.com/"); | 238 request_.url = GURL("https://test.example.com/"); |
| 236 request_.upload_data_stream = upload_data_stream_.get(); | 239 request_.upload_data_stream = upload_data_stream_.get(); |
| 237 ASSERT_EQ(OK, request_.upload_data_stream->Init(CompletionCallback())); | 240 ASSERT_THAT(request_.upload_data_stream->Init(CompletionCallback()), |
| 241 IsOk()); |
| 238 } | 242 } |
| 239 | 243 |
| 240 // Checks that |consumer| completed and received |status_line| and |body|. | 244 // Checks that |consumer| completed and received |status_line| and |body|. |
| 241 void CheckResponse(const TestTransactionConsumer& consumer, | 245 void CheckResponse(const TestTransactionConsumer& consumer, |
| 242 const std::string& status_line, | 246 const std::string& status_line, |
| 243 const std::string& body) { | 247 const std::string& body) { |
| 244 ASSERT_TRUE(consumer.is_done()); | 248 ASSERT_TRUE(consumer.is_done()); |
| 245 ASSERT_EQ(OK, consumer.error()); | 249 ASSERT_THAT(consumer.error(), IsOk()); |
| 246 EXPECT_EQ(status_line, consumer.response_info()->headers->GetStatusLine()); | 250 EXPECT_EQ(status_line, consumer.response_info()->headers->GetStatusLine()); |
| 247 EXPECT_EQ(body, consumer.content()); | 251 EXPECT_EQ(body, consumer.content()); |
| 248 } | 252 } |
| 249 | 253 |
| 250 std::unique_ptr<MockHostResolver> host_resolver_impl_; | 254 std::unique_ptr<MockHostResolver> host_resolver_impl_; |
| 251 MappedHostResolver host_resolver_; | 255 MappedHostResolver host_resolver_; |
| 252 MockCertVerifier cert_verifier_; | 256 MockCertVerifier cert_verifier_; |
| 253 std::unique_ptr<ChannelIDService> channel_id_service_; | 257 std::unique_ptr<ChannelIDService> channel_id_service_; |
| 254 TransportSecurityState transport_security_state_; | 258 TransportSecurityState transport_security_state_; |
| 255 std::unique_ptr<CTVerifier> cert_transparency_verifier_; | 259 std::unique_ptr<CTVerifier> cert_transparency_verifier_; |
| (...skipping 121 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 377 base::MessageLoop::current()->Run(); | 381 base::MessageLoop::current()->Run(); |
| 378 | 382 |
| 379 for (size_t i = 0; i < num_requests; ++i) { | 383 for (size_t i = 0; i < num_requests; ++i) { |
| 380 CheckResponse(*consumers[i], "HTTP/1.1 200", kResponseBody); | 384 CheckResponse(*consumers[i], "HTTP/1.1 200", kResponseBody); |
| 381 } | 385 } |
| 382 STLDeleteElements(&consumers); | 386 STLDeleteElements(&consumers); |
| 383 } | 387 } |
| 384 | 388 |
| 385 } // namespace test | 389 } // namespace test |
| 386 } // namespace net | 390 } // namespace net |
| OLD | NEW |