| 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 |