Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(615)

Side by Side Diff: net/quic/core/quic_connection_test.cc

Issue 2223983002: Flatten GeneralLossAlgorithm into QuicSentPacketManager. Not flag protected. (Closed) Base URL: https://chromium.googlesource.com/chromium/src.git@master
Patch Set: Created 4 years, 4 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 "net/quic/core/quic_connection.h" 5 #include "net/quic/core/quic_connection.h"
6 6
7 #include <errno.h> 7 #include <errno.h>
8 #include <memory> 8 #include <memory>
9 #include <ostream> 9 #include <ostream>
10 #include <utility> 10 #include <utility>
(...skipping 694 matching lines...) Expand 10 before | Expand all | Expand 10 after
705 kDefaultPathId)), 705 kDefaultPathId)),
706 frame1_(1, false, 0, StringPiece(data1)), 706 frame1_(1, false, 0, StringPiece(data1)),
707 frame2_(1, false, 3, StringPiece(data2)), 707 frame2_(1, false, 3, StringPiece(data2)),
708 packet_number_length_(PACKET_6BYTE_PACKET_NUMBER), 708 packet_number_length_(PACKET_6BYTE_PACKET_NUMBER),
709 connection_id_length_(PACKET_8BYTE_CONNECTION_ID) { 709 connection_id_length_(PACKET_8BYTE_CONNECTION_ID) {
710 connection_.set_defer_send_in_response_to_packets(GetParam().ack_response == 710 connection_.set_defer_send_in_response_to_packets(GetParam().ack_response ==
711 AckResponse::kDefer); 711 AckResponse::kDefer);
712 FLAGS_quic_always_log_bugs_for_tests = true; 712 FLAGS_quic_always_log_bugs_for_tests = true;
713 connection_.set_visitor(&visitor_); 713 connection_.set_visitor(&visitor_);
714 connection_.SetSendAlgorithm(kDefaultPathId, send_algorithm_); 714 connection_.SetSendAlgorithm(kDefaultPathId, send_algorithm_);
715 connection_.SetLossAlgorithm(kDefaultPathId, loss_algorithm_); 715 connection_.SetLossAlgorithm(kDefaultPathId, loss_algorithm_.get());
716 framer_.set_received_entropy_calculator(&entropy_calculator_); 716 framer_.set_received_entropy_calculator(&entropy_calculator_);
717 peer_framer_.set_received_entropy_calculator(&peer_entropy_calculator_); 717 peer_framer_.set_received_entropy_calculator(&peer_entropy_calculator_);
718 EXPECT_CALL(*send_algorithm_, TimeUntilSend(_, _)) 718 EXPECT_CALL(*send_algorithm_, TimeUntilSend(_, _))
719 .WillRepeatedly(Return(QuicTime::Delta::Zero())); 719 .WillRepeatedly(Return(QuicTime::Delta::Zero()));
720 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)) 720 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _))
721 .Times(AnyNumber()); 721 .Times(AnyNumber());
722 EXPECT_CALL(*send_algorithm_, RetransmissionDelay()) 722 EXPECT_CALL(*send_algorithm_, RetransmissionDelay())
723 .WillRepeatedly(Return(QuicTime::Delta::Zero())); 723 .WillRepeatedly(Return(QuicTime::Delta::Zero()));
724 EXPECT_CALL(*send_algorithm_, GetCongestionWindow()) 724 EXPECT_CALL(*send_algorithm_, GetCongestionWindow())
725 .WillRepeatedly(Return(kDefaultTCPMSS)); 725 .WillRepeatedly(Return(kDefaultTCPMSS));
(...skipping 335 matching lines...) Expand 10 before | Expand all | Expand 10 after
1061 QuicFramerPeer::SetPerspective(&peer_framer_, 1061 QuicFramerPeer::SetPerspective(&peer_framer_,
1062 InvertPerspective(perspective)); 1062 InvertPerspective(perspective));
1063 } 1063 }
1064 1064
1065 QuicConnectionId connection_id_; 1065 QuicConnectionId connection_id_;
1066 QuicFramer framer_; 1066 QuicFramer framer_;
1067 MockEntropyCalculator entropy_calculator_; 1067 MockEntropyCalculator entropy_calculator_;
1068 MockEntropyCalculator peer_entropy_calculator_; 1068 MockEntropyCalculator peer_entropy_calculator_;
1069 1069
1070 MockSendAlgorithm* send_algorithm_; 1070 MockSendAlgorithm* send_algorithm_;
1071 MockLossAlgorithm* loss_algorithm_; 1071 std::unique_ptr<MockLossAlgorithm> loss_algorithm_;
1072 MockClock clock_; 1072 MockClock clock_;
1073 MockRandom random_generator_; 1073 MockRandom random_generator_;
1074 SimpleBufferAllocator buffer_allocator_; 1074 SimpleBufferAllocator buffer_allocator_;
1075 std::unique_ptr<TestConnectionHelper> helper_; 1075 std::unique_ptr<TestConnectionHelper> helper_;
1076 std::unique_ptr<TestAlarmFactory> alarm_factory_; 1076 std::unique_ptr<TestAlarmFactory> alarm_factory_;
1077 QuicFramer peer_framer_; 1077 QuicFramer peer_framer_;
1078 QuicPacketCreator peer_creator_; 1078 QuicPacketCreator peer_creator_;
1079 std::unique_ptr<TestPacketWriter> writer_; 1079 std::unique_ptr<TestPacketWriter> writer_;
1080 TestConnection connection_; 1080 TestConnection connection_;
1081 QuicPacketCreator* creator_; 1081 QuicPacketCreator* creator_;
(...skipping 3904 matching lines...) Expand 10 before | Expand all | Expand 10 after
4986 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(2); 4986 EXPECT_CALL(*send_algorithm_, OnPacketSent(_, _, _, _, _)).Times(2);
4987 EXPECT_CALL(visitor_, OnConnectionClosed(QUIC_PACKET_WRITE_ERROR, _, 4987 EXPECT_CALL(visitor_, OnConnectionClosed(QUIC_PACKET_WRITE_ERROR, _,
4988 ConnectionCloseSource::FROM_SELF)) 4988 ConnectionCloseSource::FROM_SELF))
4989 .Times(1); 4989 .Times(1);
4990 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, nullptr); 4990 connection_.SendStreamDataWithString(3, "foo", 0, !kFin, nullptr);
4991 } 4991 }
4992 4992
4993 } // namespace 4993 } // namespace
4994 } // namespace test 4994 } // namespace test
4995 } // namespace net 4995 } // namespace net
OLDNEW
« no previous file with comments | « net/quic/core/congestion_control/general_loss_algorithm.cc ('k') | net/quic/core/quic_sent_packet_manager.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698