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 <stddef.h> | 5 #include <stddef.h> |
6 #include <sys/epoll.h> | 6 #include <sys/epoll.h> |
7 | 7 |
8 #include <cstdint> | 8 #include <cstdint> |
9 #include <list> | 9 #include <list> |
10 #include <memory> | 10 #include <memory> |
(...skipping 15 matching lines...) Expand all Loading... |
26 #include "net/quic/core/quic_framer.h" | 26 #include "net/quic/core/quic_framer.h" |
27 #include "net/quic/core/quic_packet_creator.h" | 27 #include "net/quic/core/quic_packet_creator.h" |
28 #include "net/quic/core/quic_packets.h" | 28 #include "net/quic/core/quic_packets.h" |
29 #include "net/quic/core/quic_server_id.h" | 29 #include "net/quic/core/quic_server_id.h" |
30 #include "net/quic/core/quic_session.h" | 30 #include "net/quic/core/quic_session.h" |
31 #include "net/quic/core/quic_utils.h" | 31 #include "net/quic/core/quic_utils.h" |
32 #include "net/quic/platform/api/quic_logging.h" | 32 #include "net/quic/platform/api/quic_logging.h" |
33 #include "net/quic/platform/api/quic_ptr_util.h" | 33 #include "net/quic/platform/api/quic_ptr_util.h" |
34 #include "net/quic/platform/api/quic_socket_address.h" | 34 #include "net/quic/platform/api/quic_socket_address.h" |
35 #include "net/quic/platform/api/quic_str_cat.h" | 35 #include "net/quic/platform/api/quic_str_cat.h" |
| 36 #include "net/quic/platform/api/quic_string_piece.h" |
36 #include "net/quic/platform/api/quic_text_utils.h" | 37 #include "net/quic/platform/api/quic_text_utils.h" |
37 #include "net/quic/test_tools/crypto_test_utils.h" | 38 #include "net/quic/test_tools/crypto_test_utils.h" |
38 #include "net/quic/test_tools/quic_config_peer.h" | 39 #include "net/quic/test_tools/quic_config_peer.h" |
39 #include "net/quic/test_tools/quic_connection_peer.h" | 40 #include "net/quic/test_tools/quic_connection_peer.h" |
40 #include "net/quic/test_tools/quic_flow_controller_peer.h" | 41 #include "net/quic/test_tools/quic_flow_controller_peer.h" |
41 #include "net/quic/test_tools/quic_sent_packet_manager_peer.h" | 42 #include "net/quic/test_tools/quic_sent_packet_manager_peer.h" |
42 #include "net/quic/test_tools/quic_session_peer.h" | 43 #include "net/quic/test_tools/quic_session_peer.h" |
43 #include "net/quic/test_tools/quic_spdy_session_peer.h" | 44 #include "net/quic/test_tools/quic_spdy_session_peer.h" |
44 #include "net/quic/test_tools/quic_stream_peer.h" | 45 #include "net/quic/test_tools/quic_stream_peer.h" |
45 #include "net/quic/test_tools/quic_stream_sequencer_peer.h" | 46 #include "net/quic/test_tools/quic_stream_sequencer_peer.h" |
(...skipping 11 matching lines...) Expand all Loading... |
57 #include "net/tools/quic/test_tools/packet_reordering_writer.h" | 58 #include "net/tools/quic/test_tools/packet_reordering_writer.h" |
58 #include "net/tools/quic/test_tools/quic_client_peer.h" | 59 #include "net/tools/quic/test_tools/quic_client_peer.h" |
59 #include "net/tools/quic/test_tools/quic_dispatcher_peer.h" | 60 #include "net/tools/quic/test_tools/quic_dispatcher_peer.h" |
60 #include "net/tools/quic/test_tools/quic_server_peer.h" | 61 #include "net/tools/quic/test_tools/quic_server_peer.h" |
61 #include "net/tools/quic/test_tools/quic_test_client.h" | 62 #include "net/tools/quic/test_tools/quic_test_client.h" |
62 #include "net/tools/quic/test_tools/quic_test_server.h" | 63 #include "net/tools/quic/test_tools/quic_test_server.h" |
63 #include "net/tools/quic/test_tools/server_thread.h" | 64 #include "net/tools/quic/test_tools/server_thread.h" |
64 #include "testing/gtest/include/gtest/gtest.h" | 65 #include "testing/gtest/include/gtest/gtest.h" |
65 | 66 |
66 using base::IntToString; | 67 using base::IntToString; |
67 using base::StringPiece; | |
68 using base::WaitableEvent; | 68 using base::WaitableEvent; |
69 using std::string; | 69 using std::string; |
70 | 70 |
71 namespace net { | 71 namespace net { |
72 namespace test { | 72 namespace test { |
73 namespace { | 73 namespace { |
74 | 74 |
75 const char kFooResponseBody[] = "Artichoke hearts make me happy."; | 75 const char kFooResponseBody[] = "Artichoke hearts make me happy."; |
76 const char kBarResponseBody[] = "Palm hearts are pretty delicious, also."; | 76 const char kBarResponseBody[] = "Palm hearts are pretty delicious, also."; |
77 const float kSessionToStreamRatio = 1.5; | 77 const float kSessionToStreamRatio = 1.5; |
(...skipping 392 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
470 | 470 |
471 void StopServer() { | 471 void StopServer() { |
472 if (!server_started_) | 472 if (!server_started_) |
473 return; | 473 return; |
474 if (server_thread_.get()) { | 474 if (server_thread_.get()) { |
475 server_thread_->Quit(); | 475 server_thread_->Quit(); |
476 server_thread_->Join(); | 476 server_thread_->Join(); |
477 } | 477 } |
478 } | 478 } |
479 | 479 |
480 void AddToCache(StringPiece path, int response_code, StringPiece body) { | 480 void AddToCache(QuicStringPiece path, |
| 481 int response_code, |
| 482 QuicStringPiece body) { |
481 response_cache_.AddSimpleResponse(server_hostname_, path, response_code, | 483 response_cache_.AddSimpleResponse(server_hostname_, path, response_code, |
482 body); | 484 body); |
483 } | 485 } |
484 | 486 |
485 void SetPacketLossPercentage(int32_t loss) { | 487 void SetPacketLossPercentage(int32_t loss) { |
486 // TODO(rtenneti): enable when we can do random packet loss tests in | 488 // TODO(rtenneti): enable when we can do random packet loss tests in |
487 // chrome's tree. | 489 // chrome's tree. |
488 if (loss != 0 && loss != 100) | 490 if (loss != 0 && loss != 100) |
489 return; | 491 return; |
490 client_writer_->set_fake_packet_loss_percentage(loss); | 492 client_writer_->set_fake_packet_loss_percentage(loss); |
(...skipping 2563 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
3054 client_->WaitForResponse(); | 3056 client_->WaitForResponse(); |
3055 EXPECT_EQ(kBarResponseBody, client_->response_body()); | 3057 EXPECT_EQ(kBarResponseBody, client_->response_body()); |
3056 QuicConnectionStats client_stats = | 3058 QuicConnectionStats client_stats = |
3057 client_->client()->session()->connection()->GetStats(); | 3059 client_->client()->session()->connection()->GetStats(); |
3058 EXPECT_EQ(0u, client_stats.packets_lost); | 3060 EXPECT_EQ(0u, client_stats.packets_lost); |
3059 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); | 3061 EXPECT_EQ(1, client_->client()->GetNumSentClientHellos()); |
3060 } | 3062 } |
3061 } // namespace | 3063 } // namespace |
3062 } // namespace test | 3064 } // namespace test |
3063 } // namespace net | 3065 } // namespace net |
OLD | NEW |