| 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 "net/quic/quic_connection.h" | 5 #include "net/quic/quic_connection.h" |
| 6 | 6 |
| 7 #include <ostream> | 7 #include <ostream> |
| 8 | 8 |
| 9 #include "base/bind.h" | 9 #include "base/bind.h" |
| 10 #include "base/macros.h" | 10 #include "base/macros.h" |
| (...skipping 720 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 731 if (FLAGS_quic_general_loss_algorithm) { | 731 if (FLAGS_quic_general_loss_algorithm) { |
| 732 EXPECT_CALL(*loss_algorithm_, DetectLosses(_, _, _, _)) | 732 EXPECT_CALL(*loss_algorithm_, DetectLosses(_, _, _, _)) |
| 733 .Times(AnyNumber()); | 733 .Times(AnyNumber()); |
| 734 } else { | 734 } else { |
| 735 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) | 735 EXPECT_CALL(*loss_algorithm_, DetectLostPackets(_, _, _, _)) |
| 736 .WillRepeatedly(Return(PacketNumberSet())); | 736 .WillRepeatedly(Return(PacketNumberSet())); |
| 737 } | 737 } |
| 738 // TODO(ianswett): Fix QuicConnectionTests so they don't attempt to write | 738 // TODO(ianswett): Fix QuicConnectionTests so they don't attempt to write |
| 739 // non-crypto stream data at ENCRYPTION_NONE. | 739 // non-crypto stream data at ENCRYPTION_NONE. |
| 740 FLAGS_quic_never_write_unencrypted_data = false; | 740 FLAGS_quic_never_write_unencrypted_data = false; |
| 741 FLAGS_quic_no_unencrypted_fec = false; |
| 741 } | 742 } |
| 742 | 743 |
| 743 QuicVersion version() { return GetParam().version; } | 744 QuicVersion version() { return GetParam().version; } |
| 744 | 745 |
| 745 QuicAckFrame* outgoing_ack() { | 746 QuicAckFrame* outgoing_ack() { |
| 746 QuicConnectionPeer::PopulateAckFrame(&connection_, &ack_); | 747 QuicConnectionPeer::PopulateAckFrame(&connection_, &ack_); |
| 747 return &ack_; | 748 return &ack_; |
| 748 } | 749 } |
| 749 | 750 |
| 750 QuicStopWaitingFrame* stop_waiting() { | 751 QuicStopWaitingFrame* stop_waiting() { |
| (...skipping 4816 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 5567 EXPECT_CALL(visitor_, | 5568 EXPECT_CALL(visitor_, |
| 5568 OnConnectionClosed(QUIC_UNENCRYPTED_STREAM_DATA, false)); | 5569 OnConnectionClosed(QUIC_UNENCRYPTED_STREAM_DATA, false)); |
| 5569 EXPECT_DFATAL(connection_.SendStreamDataWithString(3, "", 0, kFin, nullptr), | 5570 EXPECT_DFATAL(connection_.SendStreamDataWithString(3, "", 0, kFin, nullptr), |
| 5570 "Cannot send stream data without encryption."); | 5571 "Cannot send stream data without encryption."); |
| 5571 EXPECT_FALSE(connection_.connected()); | 5572 EXPECT_FALSE(connection_.connected()); |
| 5572 } | 5573 } |
| 5573 | 5574 |
| 5574 } // namespace | 5575 } // namespace |
| 5575 } // namespace test | 5576 } // namespace test |
| 5576 } // namespace net | 5577 } // namespace net |
| OLD | NEW |