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/quic/core/congestion_control/bbr_sender.h" | 5 #include "net/quic/core/congestion_control/bbr_sender.h" |
6 | 6 |
7 #include <algorithm> | 7 #include <algorithm> |
8 #include <map> | 8 #include <map> |
9 #include <memory> | 9 #include <memory> |
10 | 10 |
(...skipping 64 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
75 /*connection_id=*/42), | 75 /*connection_id=*/42), |
76 competing_sender_(&simulator_, | 76 competing_sender_(&simulator_, |
77 "Competing sender", | 77 "Competing sender", |
78 "Competing receiver", | 78 "Competing receiver", |
79 Perspective::IS_CLIENT, | 79 Perspective::IS_CLIENT, |
80 /*connection_id=*/43), | 80 /*connection_id=*/43), |
81 receiver_(&simulator_, | 81 receiver_(&simulator_, |
82 "Receiver", | 82 "Receiver", |
83 "BBR sender", | 83 "BBR sender", |
84 Perspective::IS_SERVER, | 84 Perspective::IS_SERVER, |
85 /*connection_id=*/42), | 85 /*connection_id=*/GetPeerInMemoryConnectionId(42)), |
86 competing_receiver_(&simulator_, | 86 competing_receiver_(&simulator_, |
87 "Competing receiver", | 87 "Competing receiver", |
88 "Competing sender", | 88 "Competing sender", |
89 Perspective::IS_SERVER, | 89 Perspective::IS_SERVER, |
90 /*connection_id=*/43), | 90 /*connection_id=*/GetPeerInMemoryConnectionId(43)), |
91 receiver_multiplexer_("Receiver multiplexer", | 91 receiver_multiplexer_("Receiver multiplexer", |
92 {&receiver_, &competing_receiver_}) { | 92 {&receiver_, &competing_receiver_}) { |
93 rtt_stats_ = bbr_sender_.connection()->sent_packet_manager().GetRttStats(); | 93 rtt_stats_ = bbr_sender_.connection()->sent_packet_manager().GetRttStats(); |
94 sender_ = SetupBbrSender(&bbr_sender_); | 94 sender_ = SetupBbrSender(&bbr_sender_); |
95 | 95 |
96 clock_ = simulator_.GetClock(); | 96 clock_ = simulator_.GetClock(); |
97 simulator_.set_random_generator(&random_); | 97 simulator_.set_random_generator(&random_); |
98 | 98 |
99 uint64_t seed = QuicRandom::GetInstance()->RandUint64(); | 99 uint64_t seed = QuicRandom::GetInstance()->RandUint64(); |
100 random_.set_seed(seed); | 100 random_.set_seed(seed); |
(...skipping 623 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
724 sender_->ResumeConnectionState(params, false); | 724 sender_->ResumeConnectionState(params, false); |
725 EXPECT_EQ(kTestLinkBandwidth, sender_->ExportDebugState().max_bandwidth); | 725 EXPECT_EQ(kTestLinkBandwidth, sender_->ExportDebugState().max_bandwidth); |
726 EXPECT_EQ(kTestLinkBandwidth, sender_->BandwidthEstimate()); | 726 EXPECT_EQ(kTestLinkBandwidth, sender_->BandwidthEstimate()); |
727 ExpectApproxEq(kTestRtt, sender_->ExportDebugState().min_rtt, 0.01f); | 727 ExpectApproxEq(kTestRtt, sender_->ExportDebugState().min_rtt, 0.01f); |
728 | 728 |
729 DriveOutOfStartup(); | 729 DriveOutOfStartup(); |
730 } | 730 } |
731 | 731 |
732 } // namespace test | 732 } // namespace test |
733 } // namespace net | 733 } // namespace net |
OLD | NEW |